{"id":757,"date":"2024-11-15T23:58:14","date_gmt":"2024-11-15T15:58:14","guid":{"rendered":"https:\/\/www.db2go.net\/?p=757"},"modified":"2024-11-17T20:42:25","modified_gmt":"2024-11-17T12:42:25","slug":"757","status":"publish","type":"post","link":"https:\/\/www.db2go.net\/?p=757","title":{"rendered":"\u4e03.\u53ef\u6269\u5c55\u7684\u67b6\u6784\u8bbe\u8ba1\u7684\u6838\u5fc3\u4ee3\u7801"},"content":{"rendered":"

KubeEdge \u7684\u53ef\u6269\u5c55\u67b6\u6784\u8bbe\u8ba1\u4e3b\u8981\u4f53\u73b0\u5728\u6a21\u5757\u5316\u7684\u67b6\u6784\u3001\u63d2\u4ef6\u5f0f\u7684\u6a21\u5757\u7ba1\u7406\u4ee5\u53ca\u5bf9\u81ea\u5b9a\u4e49\u8d44\u6e90\uff08CRD\uff09\u7684\u652f\u6301\u4e0a\u3002\u901a\u8fc7\u6a21\u5757\u5316\u8bbe\u8ba1\uff0cKubeEdge \u53ef\u4ee5\u7075\u6d3b\u5730\u6269\u5c55\u65b0\u529f\u80fd\uff0c\u5f00\u53d1\u8005\u53ef\u4ee5\u6839\u636e\u9700\u6c42\u6dfb\u52a0\u65b0\u6a21\u5757\u6216\u6269\u5c55\u73b0\u6709\u529f\u80fd\u3002KubeEdge \u7684\u6269\u5c55\u673a\u5236\u4f9d\u8d56\u4e8e modules<\/code> \u548c messaging<\/code> \u6846\u67b6\uff0c\u4e3b\u8981\u8d1f\u8d23\u6a21\u5757\u7684\u52a0\u8f7d\u3001\u7ba1\u7406\u548c\u901a\u4fe1\u3002\u4ee5\u4e0b\u662f\u53ef\u6269\u5c55\u67b6\u6784\u8bbe\u8ba1\u7684\u6838\u5fc3\u4ee3\u7801\u5206\u6790\u3002<\/p>\n

1. \u6a21\u5757\u5316\u7684\u67b6\u6784\u8bbe\u8ba1<\/h3>\n

KubeEdge \u91c7\u7528\u6a21\u5757\u5316\u67b6\u6784\uff0c\u6a21\u5757\u4e4b\u95f4\u901a\u8fc7\u6d88\u606f\u901a\u4fe1\u6846\u67b6\u8fdb\u884c\u4ea4\u4e92\u3002\u5404\u4e2a\u6a21\u5757\u88ab\u5212\u5206\u4e3a\u72ec\u7acb\u7684\u7ec4\u4ef6\uff0c\u4e91\u7aef\u6709 cloudcore<\/code> \u7684\u591a\u4e2a\u5b50\u6a21\u5757\uff08\u5982 devicecontroller<\/code>\u3001cloudhub<\/code>\uff09\uff0c\u8fb9\u7aef\u6709 edgecore<\/code> \u7684\u591a\u4e2a\u5b50\u6a21\u5757\uff08\u5982 edged<\/code>\u3001eventbus<\/code>\u3001edgehub<\/code>\uff09\u3002\u6bcf\u4e2a\u6a21\u5757\u5728\u529f\u80fd\u4e0a\u662f\u76f8\u5bf9\u72ec\u7acb\u7684\uff0c\u4f46\u901a\u8fc7\u6d88\u606f\u6846\u67b6\u5f7c\u6b64\u534f\u4f5c\u3002<\/p>\n

\u6a21\u5757\u521d\u59cb\u5316\u4e0e\u7ba1\u7406<\/h4>\n

\u6a21\u5757\u7ba1\u7406\u6846\u67b6\u7684\u6838\u5fc3\u4ee3\u7801\u4f4d\u4e8e edge\/pkg\/common\/modules<\/code> \u76ee\u5f55\u4e0b\uff0c\u5b9a\u4e49\u4e86\u6a21\u5757\u7684\u6ce8\u518c\u3001\u521d\u59cb\u5316\u548c\u7ba1\u7406\u673a\u5236\u3002\u6a21\u5757\u901a\u8fc7 Register<\/code> \u51fd\u6570\u6ce8\u518c\uff0c\u6a21\u5757\u7ba1\u7406\u5668\u4f1a\u81ea\u52a8\u52a0\u8f7d\u5df2\u6ce8\u518c\u7684\u6a21\u5757\u3002<\/p>\n

    \n
  • \u6a21\u5757\u6ce8\u518c<\/strong>\uff1a\u5728 modules.go<\/code> \u6587\u4ef6\u4e2d\uff0cModuleManager<\/code> \u7ba1\u7406\u6240\u6709\u5df2\u6ce8\u518c\u7684\u6a21\u5757\u3002\u901a\u8fc7 Register<\/code> \u51fd\u6570\u5c06\u6a21\u5757\u6dfb\u52a0\u5230\u6a21\u5757\u7ba1\u7406\u5668\u3002\n
    func (m *ModuleManager) Register(name string, module Module) {\n  m.modules[name] = module\n}\n<\/code><\/pre>\n
    \u8fd9\u4e2a\u51fd\u6570\u5c06\u6a21\u5757\u540d\u79f0\u548c\u6a21\u5757\u5b9e\u4f8b\u6620\u5c04\u5230 modules<\/code> \u5b57\u5178\u4e2d\uff0c\u4ee5\u4fbf\u540e\u7eed\u8fdb\u884c\u7ba1\u7406\u548c\u901a\u4fe1\u3002\u6a21\u5757\u53ef\u4ee5\u5728\u521d\u59cb\u5316\u65f6\u8c03\u7528 Register<\/code> \u51fd\u6570\u5b8c\u6210\u6ce8\u518c\u3002<\/p>\n<\/li>\n
  • \n
    \u6a21\u5757\u542f\u52a8\u4e0e\u505c\u6b62<\/strong>\uff1aModuleManager<\/code> \u7684 Start<\/code> \u548c Stop<\/code> \u51fd\u6570\u7528\u4e8e\u542f\u52a8\u548c\u505c\u6b62\u6240\u6709\u6a21\u5757\u3002Start<\/code> \u51fd\u6570\u4f1a\u4f9d\u6b21\u542f\u52a8\u6bcf\u4e2a\u6ce8\u518c\u6a21\u5757\u7684 Start<\/code> \u65b9\u6cd5\uff0c\u5b8c\u6210\u6a21\u5757\u521d\u59cb\u5316\u548c\u8fd0\u884c\u3002<\/p>\n
    func (m *ModuleManager) Start() {\n  for _, module := range m.modules {\n      go module.Start()\n  }\n}\n<\/code><\/pre>\n<\/li>\n<\/ul>\n
    \u6a21\u5757\u751f\u547d\u5468\u671f\u7ba1\u7406<\/h4>\n
    \u6bcf\u4e2a\u6a21\u5757\u9700\u8981\u5b9e\u73b0 Module<\/code> \u63a5\u53e3\uff0c\u5305\u542b Name<\/code>\u3001Start<\/code> \u548c Cleanup<\/code> \u7b49\u65b9\u6cd5\uff0c\u4ee5\u7ba1\u7406\u6a21\u5757\u7684\u751f\u547d\u5468\u671f\u3002<\/p>\n
    type Module interface {\n    Name() string\n    Start()\n    Cleanup()\n}\n<\/code><\/pre>\n
      \n
    • Name<\/code>\uff1a\u8fd4\u56de\u6a21\u5757\u540d\u79f0\uff0c\u7528\u4e8e\u6a21\u5757\u4e4b\u95f4\u7684\u6d88\u606f\u8def\u7531\u3002<\/li>\n
    • Start<\/code>\uff1a\u542f\u52a8\u6a21\u5757\u7684\u4e3b\u903b\u8f91\u3002<\/li>\n
    • Cleanup<\/code>\uff1a\u6a21\u5757\u9000\u51fa\u65f6\u7684\u6e05\u7406\u903b\u8f91\u3002<\/li>\n<\/ul>\n
      2. \u6d88\u606f\u901a\u4fe1\u6846\u67b6\uff08\u6a21\u5757\u95f4\u901a\u4fe1\uff09<\/h3>\n
      \u6a21\u5757\u95f4\u901a\u4fe1\u662f KubeEdge \u53ef\u6269\u5c55\u67b6\u6784\u7684\u91cd\u8981\u7ec4\u6210\u90e8\u5206\uff0c\u6d88\u606f\u901a\u4fe1\u6846\u67b6\u4f7f\u5f97\u6a21\u5757\u95f4\u53ef\u4ee5\u901a\u8fc7\u6d88\u606f\u603b\u7ebf\u8fdb\u884c\u89e3\u8026\u901a\u4fe1\u3002\u6d88\u606f\u901a\u4fe1\u7684\u6838\u5fc3\u4ee3\u7801\u4f4d\u4e8e edge\/pkg\/common\/message<\/code> \u76ee\u5f55\u4e2d\u3002<\/p>\n
      \u6d88\u606f\u8def\u7531\u4e0e\u8ba2\u9605<\/h4>\n
      \u6bcf\u4e2a\u6a21\u5757\u901a\u8fc7\u8ba2\u9605\u7279\u5b9a\u7684\u6d88\u606f\u4e3b\u9898\u6765\u63a5\u6536\u6d88\u606f\uff0c\u901a\u8fc7\u6d88\u606f\u8def\u7531\u673a\u5236\u6765\u5b9e\u73b0\u6a21\u5757\u95f4\u7684\u89e3\u8026\u3002\u6d88\u606f\u7684\u8def\u7531\u548c\u5206\u53d1\u5728 message.go<\/code> \u4e2d\u5b9a\u4e49\u3002<\/p>\n
        \n
      • \u6d88\u606f\u7ed3\u6784<\/strong>\uff1aMessage<\/code> \u7ed3\u6784\u5b9a\u4e49\u4e86\u6d88\u606f\u7684\u683c\u5f0f\uff0c\u5305\u542b\u6d88\u606f\u7684\u6765\u6e90\u3001\u76ee\u6807\u3001\u5185\u5bb9\u7b49\u5b57\u6bb5\u3002\n
        type Message struct {\n  Header Header\n  Router Router\n  Content interface{}\n}\n<\/code><\/pre>\n
          \n
        • Header<\/code> \u5305\u542b\u6d88\u606f\u7684\u5143\u6570\u636e\uff0c\u5982\u6d88\u606f ID\u3002<\/li>\n
        • Router<\/code> \u5b9a\u4e49\u6d88\u606f\u7684\u6765\u6e90\u548c\u76ee\u6807\u6a21\u5757\u540d\u79f0\u3002<\/li>\n
        • Content<\/code> \u5b58\u50a8\u6d88\u606f\u7684\u5177\u4f53\u5185\u5bb9\uff0c\u53ef\u4ee5\u662f JSON \u683c\u5f0f\u7684\u6570\u636e\u6216\u81ea\u5b9a\u4e49\u7684\u6570\u636e\u7ed3\u6784\u3002<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
          \u6d88\u606f\u603b\u7ebf\u4e0e\u6a21\u5757\u901a\u4fe1<\/h4>\n
          \u6d88\u606f\u603b\u7ebf\u8d1f\u8d23\u63a5\u6536\u548c\u8f6c\u53d1\u6a21\u5757\u4e4b\u95f4\u7684\u6d88\u606f\u3002messaging<\/code> \u6846\u67b6\u7684\u6838\u5fc3\u4ee3\u7801\u4f4d\u4e8e edge\/pkg\/common\/messaging<\/code> \u4e2d\u3002<\/p>\n