利用爱星物联服务脚手架实现定制服务

[复制链接]
查看3109 | 回复11 | 2024-5-11 16:11:54 | 显示全部楼层 |阅读模式
本帖最后由 chensg 于 2024-5-11 16:10 编辑

  上篇文章《爱星物联开源版后台定制开发简介》介绍了爱星物联开源版的后台定制开发介绍,纯理论的内容说明,开发者朋友们如果没有深入去了解源代码和相关工具,可能理解起来还是云里雾里,还是没法下手定制开发吧?别急,续编来了,理论指导实践,本文继续介绍后台定制开发,但偏实践。

  本文介绍基于API脚手架和微服务脚手架构建自定义的API和微服务,以及自定义服务怎么与爱星物联IoT平台服务进行交互。内容属于下图红色线框部分。

   1.PNG

  为了方便演示和理解,我们以一个最简单的需求为例,给平台增加一个产品功能项告警配置功能,比如我们的可充电电池版设备,当电量过低时,需要在平台端判定为告警,而这个告警阈值,可能因用户而异。我们的需求是实现告警配置(判定告警和记录告警的逻辑不在演示范围),转化为后台技术需求是提供告警阈值的增删改查的接口。需求就是这样,我们按照要实现这个功能需要做的主流程走一遍。

  (一)创建数据库、数据表。
  为简化起见,省略设计过程。经过简单梳理,由于是设备状态相关的内容,因此,我们可在设备库iot_device下创建数据表t_iot_device_alarm_config,数据表字段内容整理如下:
  
列名
  
类型
备注
id
bigint(20) unsigned
编号,主键
dev_id
varchar(22)
设备ID
dpid
int(11) unsigned
功能点ID
low
float
告警下限,低于告警                                 
low_enable
tinyint(4) unsigned
告警下限使能,1-启用;0-禁用                       
high
float
告警上限,高于告警                                 
high_enable
tinyint(4) unsigned
告警上限使能,1-启用;0-禁用                       
duration   
int(11) unsigned
持续时间,持续多长时间算告警,单位秒               
level      
tinyint(4)
告警等级,0-预警,1-普通,2-严重                  
enabled   
tinyint(4) unsigned
使能,1-启用;0-禁用                              
created_by
bigint(20) unsigned
创建人
updated_by
bigint(20) unsigned
修改人
created_at
timestamp         
创建时间
updated_at
timestamp         
修改时间

  其中dev_id、dpid两列创建唯一索引。在数据库中建好数据表后,可进入下一步。

  (二)数据库操作代码生成
  在爱星物联IoT平台中,所有配置类业务,全部采用了MySQL数据库。Go语言的MySQL数据库ORM相关的框架,开源的有很多,功能基本相同。平台使用了在国内备受欢迎的数据库ORM框架gorm及其配套的gen代码生成工具。gen工具我有定制部分功能,主要是对特定列名、驼峰方式,MySQL部分数据类型转换做了特定修改定制,代码已开源。后台的老铁们可以到https://github.com/ubases/gen找到定制的仓库。这个工具我们有打包exe,建仓库代码中的tool/mysql-to-model/gentool.exe,windows下的开发者可以直接使用,linux下的开发者可从源码仓库中下载gen代码编译工具。
  iot_device数据库对应的ORM包,在路径iot_model/db_device下,进入该目录后,可看到有gentoo.bat文件,打开该文件,内容如下:
rem 生成整个库
..\\..\\tool\\mysql-to-model\\gentool.exe  -dsn "root:iLmz8sCXjkTYuh@tcp(192.168.5.56:3306)/iot_device?charset=utf8mb4&parseTime=True&loc=Local"  -outPath  orm -modelPkgName model

rem 生成单元测试加 -withUnitTest true

rem 生成某个表,后边加 -tables {table name}


  将其中的数据库用户名、密码、IP、端口部分改成实际部署环境的参数,然后执行gentoo.bat.如果环境和参数配置都正确,那么会在model和orm子目录下,会生成很多go文件。仔细观察,会发现,这两个子目录新生成1个名为t_iot_device_alarm_config.gen.go的文件,这个2个文件就是我们新增加的表t_iot_device_alarm_config的所有公共代码。
  其中model目录的t_iot_device_alarm_config.gen.go里边包含t_iot_device_alarm_config表对应go结构体及映射关系.
   2.png

  orm目录的t_iot_device_alarm_config.gen.go里边包含该表的常用增删改查操作方法。

   9.png

  Model目录下的model包比较好理解,orm目录下的orm包,每个表的操作方法一样,开发者只需要熟悉掌握其中的1个表的所有方案,即可掌握orm包下所有方法的用法。本文不再详细展开介绍。

(三)创建自定义服务骨架
  看过上篇文章的开发者朋友们,应该了解咱们爱星物联API和微服务脚手架的源代码结构。开源仓库中的iot_demo_api_service是API的脚手架,自定义API服务可以基于这个脚手架进行开发。仓库中的iot_demo_service是微服务的脚手架。爱星物联IoT平台有一条未明确说明的规则,Web、APP、小程序等的入口都是API类的服务,该类API服务对外提供http/websocket+json接口;API调用内部服务以及内部服务之间,全部是基于grpc+protobuf的接口。
  所以,为了演示需要,也按照这个规则,基于iot_demo_api_service和iot_demo_service服务分别拷贝整个工程目录到新的目录,并改名为iot_my_api_service和iot_my_service(正式服务定制时请用正常名称,这里演示,取名随意),修改后的代码结构见下图,左侧是脚手架,右侧是自定义的API和微服务。
   3.png
  拷贝完成后,开始进行包名和代码修改。进入iot_my_api_service目录,挨个将go文件import的所有包名中的包含的iot_demo_api_service全部替换为iot_my_api_service。进入iot_my_service目录,挨个将go文件import的所有包名中的包含的iot_demo_service全部替换为iot_my_service。改为后,进行简单的编译,确保编译通过。
  这一步完成后,可以进入下一步。

  (四)微服务和API代码生成和完善
  开源仓库中,各个类似这种名称iot_{XXX}_service的目录中,都是一个个服务。这些服务结构看起来是不是很整齐的样子,那是因为大部分增删改查之类的代码、部分实体、及RPC接口都是用工具生成,上一步用到的脚手架部分代码也是这样生成的。
  代码生成工具在tool/mysql-to-service路径下。具体的用法可以参考README.md文件,这里不再详细介绍,直接实际操作。

  (1)修改config.yaml配置文件。
   10.png

  (2)执行gen.bat。
  打开gen.bat文件,并修改为如下内容:
   4.png
  后边--tableName 后边跟着表明,这个例子就是我们第一步创建的表的名字。
  修改后运行,就会在gen目录下,生成如下目录结构的文件。
   5.png
  注意到上面有个proto目录,工具生成了2个文件:iot_device_alarm_config_model.gen.proto
iot_device_alarm_config_service.gen.proto。这2个文件里边有定义grpc接口和消息结构。
  本次生成的代码,感兴趣的开发者们可以仔细看看代码结构,这里不贴代码介绍了。
      
  (3)执行gengo.bat。
  这一步依赖上一步生成proto文件,这一步的目标是利用protoc工具将proto文件生成go语言代码。
  这一步比较简单,不需要修改gengo.bat文件,执行执行即可。执行完成后,会在protosService下生成对应的go代码,这个例子生成了4个文件:
    iot_device_alarm_config_model.gen.pb.go
    iot_device_alarm_config_model.gen.pb.micro.go
    iot_device_alarm_config_service.gen.pb.go
    iot_device_alarm_config_service.gen.pb.micro.go
  将这4个文件拷贝到iot_proto/protos/protosService路径下。

  (4)代码拷贝。
  将gen目录下的convert、entitys、handler、service目录整体拷贝到iot_my_service下,覆盖原来的文件。覆盖后的目录文件结构如下所示:
   6.png

  将entitys下的文件iot_device_alarm_config_entitys.gen.go拷贝到iot_my_api_service/controls/system/entitys下(这里演示放到了system模块下,实际定制开发中请根据实际需要放到controls下的子模块中)。


  (5)完成iot_my_service服务。
   1、打开iot_my_service/handler/register_handler.go文件,把刚生成的handler注册进去。
    7.png

   2、进入bin/conf/open,复制一份iot_demo_service.yml,将其改名为iot_my_service.yml,并修改配置文件中的内容。重点是logfile和database下的内容,注意修改正确。
   3、打开源代码iot_my_service/config/config.go,修改配置文件为iot_my_service.yml。
   4、原来demo中的表config_dict_type在iot_config数据库,现在切换到了iot_device数据库,因此,需要删除掉原来config_dict_type相关的内容。
   5、进入iot_common/iotconst/service_name.go,给服务定义一个常量IOT_MY_SERVICE,并取个服务名,其它服务会根据这个服务名去微服务注册中心找到地址信息。并在main.go中将服务名修改为新取得名称,即将iotconst.IOT_DEMO_SERVICE修改为iotconst.IOT_MY_SERVICE。
   6、至此iot_my_service全部改造完成,可直接编译运行。

  (6)完成iot_my_api_service服务。
  1、定义rpc客户端。进入rpc目录打开globalService.go,修改为如下内容:
   8.png
  2、进入iot_my_api_service/controls下,实现HTTP接口,这块目前没有代码生成工具生成,可以仿照basedata开头的文件,实现自己的api和service。代码中可以使用上一步创建的客户端接口,类似调用本地函数类似,调用接口方法。关于这块的代码生成,后续可能会推出。

  3、打开iot_my_api_service/router/router.go,注册新实现的模块的路由。如果共用demo提供的system则不需要重复注册。
  4、仿照iot_my_service添加配置文件。
  5、修改config.go,将配置文件名称改为第4步添加的配置文件。
  6、至此iot_my_api_service全部改造完成,可直接编译运行。

  经过以上步骤,就完成了微服务和API服务代码的基本定制,通过API接口调用微服务实现告警配置的增删改查。基于脚手架的配置步骤有点多,但不复杂,熟练了这个过程是很快的。



回复

使用道具 举报

爱笑 | 2024-5-11 16:45:19 | 显示全部楼层
用心做好保姆工作
回复

使用道具 举报

1084504793 | 2024-5-11 16:47:21 | 显示全部楼层
回复

使用道具 举报

1055173307 | 2024-5-12 13:17:18 | 显示全部楼层
回复

使用道具 举报

干簧管 | 2024-5-12 17:19:02 | 显示全部楼层
回复

使用道具 举报

timo | 2024-5-24 08:05:53 | 显示全部楼层
感谢分享
回复

使用道具 举报

wurong | 2024-5-24 21:22:50 | 显示全部楼层
恭喜
回复

使用道具 举报

物联网 | 2024-5-29 22:25:51 | 显示全部楼层
赞一下
回复

使用道具 举报

noonezero | 2024-6-13 20:42:36 | 显示全部楼层
厉害了
回复

使用道具 举报

望风阁 | 2024-6-14 18:01:35 | 显示全部楼层
你家云云对接?
回复 支持 反对

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则