更新文档及项目框架

pkg/rpcs/common.go

@@ -8,10 +8,11 @@ type ReplyEmptyResult struct{}
 
 // 定义 rpc服务的名字
 const (
-	RegistryServerName = "registry"
-	MQTTAccessName     = "MQTTAccess"
-	DeviceManagerName  = "deviceManager"
-	ControllerName     = "controller"
-	HttpAccessName     = "HTTPAccess"
-	ShadowServiceName  = "ShadowServer"
+	RegistryServerName   = "registry"
+	MQTTAccessName       = "MQTTAccess"
+	DeviceManagerName    = "deviceManager"
+	ControllerName       = "controller"
+	HttpAccessName       = "HTTPAccess"
+	ShadowServiceName    = "ShadowServer"
+	EmqxAgentServiceName = "EmqxAgentServer"
 )

services/emqx-agent/emqx-agent.go

@@ -0,0 +1 @@
+package main

services/emqx-agent/main.go

@@ -227,7 +227,7 @@ func (s *emqttServer) OnMessageAcked(ctx context.Context, in *pb.MessageAckedReq
 func main() {
 
 	// init emqttServer
-	err := server.Init(rpcs.HttpAccessName)
+	err := server.Init(rpcs.EmqxAgentServiceName)
 	if err != nil {
 		server.Log.Fatal(err)
 		return

services/emqx-agent/readme.md

@@ -0,0 +1,10 @@
+## emqx 代理服务
+
+主要作为 emqx 服务的代理，实现emqx hook服务，监听设备接入的事件，维护设备上下线状态，服务启动后订阅所有设备消息并作预处理，转发到规则引擎中。
+
+### 核心功能
+
+* EMQX服务 ExHook 服务，实现了 GPRC
+* 根据hook 事件，完成设备上下线状态维护
+* 订阅设备消息并转发到规则引擎中
+* 实现 easeLink 协议,适配 api provider 服务中的请求，生成协议包转发到设备相应的主题上。