wip:重新生代码

.idea/workspace.xml

@@ -6,20 +6,10 @@
   <component name="ChangeListManager">
     <list default="true" id="f5220264-ecf0-4305-ada3-6105184077a7" name="Changes" comment="">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/README.md" beforeDir="false" afterPath="$PROJECT_DIR$/README.md" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/etc/messagecenter.yaml" beforeDir="false" afterPath="$PROJECT_DIR$/api/etc/messagecenter.yaml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/internal/config/config.go" beforeDir="false" afterPath="$PROJECT_DIR$/api/internal/config/config.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/internal/handler/counthandler.go" beforeDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/internal/handler/messagehandler.go" beforeDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/internal/handler/routes.go" beforeDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/internal/logic/messagelogic.go" beforeDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/internal/svc/servicecontext.go" beforeDir="false" afterPath="$PROJECT_DIR$/api/internal/svc/servicecontext.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/api/internal/types/types.go" beforeDir="false" afterPath="$PROJECT_DIR$/api/internal/types/types.go" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/api/messageCenter.api" beforeDir="false" afterPath="$PROJECT_DIR$/api/messageCenter.api" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/rpc/etc/messagecenter.yaml" beforeDir="false" afterPath="$PROJECT_DIR$/rpc/etc/messagecenter.yaml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/rpc/messagecenter/messageCenter.pb.go" beforeDir="false" afterPath="$PROJECT_DIR$/rpc/messagecenter/messageCenter.pb.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/rpc/messagecenter/messageCenter_grpc.pb.go" beforeDir="false" afterPath="$PROJECT_DIR$/rpc/messagecenter/messageCenter_grpc.pb.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/rpc/messagecenterclient/messagecenter.go" beforeDir="false" afterPath="$PROJECT_DIR$/rpc/messagecenterclient/messagecenter.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/api/messagecenter.go" beforeDir="false" afterPath="$PROJECT_DIR$/api/messagecenter.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/go.mod" beforeDir="false" afterPath="$PROJECT_DIR$/go.mod" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/go.sum" beforeDir="false" afterPath="$PROJECT_DIR$/go.sum" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -52,27 +42,27 @@
     <option name="hideEmptyMiddlePackages" value="true" />
     <option name="showLibraryContents" value="true" />
   </component>
-  <component name="PropertiesComponent"><![CDATA[{
-  "keyToString": {
-    "DefaultApiTemplateProperty": "Api Template",
-    "DefaultGoTemplateProperty": "Go File",
-    "DefaultProtoTemplateProperty": "Proto Template",
-    "RunOnceActivity.OpenProjectViewOnStart": "true",
-    "RunOnceActivity.ShowReadmeOnStart": "true",
-    "RunOnceActivity.go.formatter.settings.were.checked": "true",
-    "RunOnceActivity.go.migrated.go.modules.settings": "true",
-    "RunOnceActivity.go.modules.go.list.on.any.changes.was.set": "true",
-    "RunOnceActivity.go.watchers.conflict.with.on.save.actions.check.performed": "true",
-    "WebServerToolWindowFactoryState": "false",
-    "configurable..is.expanded": "false",
-    "configurable.GoLibrariesConfigurable.is.expanded": "true",
-    "go.import.settings.migrated": "true",
-    "go.sdk.automatically.set": "true",
-    "last_opened_file_path": "D:/workspace/top_project/SocialPlatform/messageCenter/rpc/messagecenterclient",
-    "nodejs_package_manager_path": "npm",
-    "settings.editor.selected.configurable": "com.goide.configuration.GoLibrariesConfigurableProvider"
+  <component name="PropertiesComponent">{
+  &quot;keyToString&quot;: {
+    &quot;DefaultApiTemplateProperty&quot;: &quot;Api Template&quot;,
+    &quot;DefaultGoTemplateProperty&quot;: &quot;Go File&quot;,
+    &quot;DefaultProtoTemplateProperty&quot;: &quot;Proto Template&quot;,
+    &quot;RunOnceActivity.OpenProjectViewOnStart&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.ShowReadmeOnStart&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.go.formatter.settings.were.checked&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.go.migrated.go.modules.settings&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.go.modules.go.list.on.any.changes.was.set&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.go.watchers.conflict.with.on.save.actions.check.performed&quot;: &quot;true&quot;,
+    &quot;WebServerToolWindowFactoryState&quot;: &quot;false&quot;,
+    &quot;configurable..is.expanded&quot;: &quot;false&quot;,
+    &quot;configurable.GoLibrariesConfigurable.is.expanded&quot;: &quot;true&quot;,
+    &quot;go.import.settings.migrated&quot;: &quot;true&quot;,
+    &quot;go.sdk.automatically.set&quot;: &quot;true&quot;,
+    &quot;last_opened_file_path&quot;: &quot;D:/workspace/top_project/SocialPlatform/socialPlatform&quot;,
+    &quot;nodejs_package_manager_path&quot;: &quot;npm&quot;,
+    &quot;settings.editor.selected.configurable&quot;: &quot;preference.GoLinterConfigurable&quot;
   }
-}]]></component>
+}</component>
   <component name="RecentsManager">
     <key name="CopyFile.RECENT_KEYS">
       <recent name="D:\workspace\top_project\SocialPlatform\messageCenter\rpc\messagecenterclient" />
@@ -87,7 +77,7 @@
       <recent name="D:\workspace\top_project\SocialPlatform\messageCenter\api" />
     </key>
   </component>
-  <component name="RunManager" selected="Go Build.go build SocialPlatform.messageCenter/rpc">
+  <component name="RunManager" selected="Makefile Target.genrpc">
     <configuration default="true" type="GoApplicationRunConfiguration" factoryName="Go Application">
       <module name="messageCenter" />
       <working_directory value="$PROJECT_DIR$" />
@@ -97,37 +87,22 @@
       <filePath value="$PROJECT_DIR$" />
       <method v="2" />
     </configuration>
-    <configuration name="go build SocialPlatform.messageCenter/rpc" type="GoApplicationRunConfiguration" factoryName="Go Application" temporary="true" nameIsGenerated="true">
+    <configuration name="go build SocialPlatform.messageCenter/api" type="GoApplicationRunConfiguration" factoryName="Go Application" temporary="true" nameIsGenerated="true">
       <module name="messageCenter" />
-      <working_directory value="$PROJECT_DIR$/rpc" />
+      <working_directory value="$PROJECT_DIR$/api" />
       <kind value="PACKAGE" />
-      <package value="SocialPlatform.messageCenter/rpc" />
+      <package value="SocialPlatform.messageCenter/api" />
       <directory value="$PROJECT_DIR$" />
-      <filePath value="$PROJECT_DIR$/rpc/messagecenter.go" />
+      <filePath value="$PROJECT_DIR$/api/messagecenter.go" />
       <method v="2" />
     </configuration>
-    <configuration name="TestMessageMailBox_Count/case1 in SocialPlatform.messageCenter/entity" type="GoTestRunConfiguration" factoryName="Go Test" temporary="true" nameIsGenerated="true">
-      <module name="messageCenter" />
-      <working_directory value="$PROJECT_DIR$/entity" />
-      <root_directory value="$PROJECT_DIR$" />
-      <kind value="PACKAGE" />
-      <package value="SocialPlatform.messageCenter/entity" />
-      <directory value="$PROJECT_DIR$" />
-      <filePath value="$PROJECT_DIR$" />
-      <framework value="gotest" />
-      <pattern value="^\QTestMessageMailBox_Count\E$/^\Qcase1\E$" />
-      <method v="2" />
-    </configuration>
-    <configuration name="TestMessageMailBox_GetLast/case1 in SocialPlatform.messageCenter/entity" type="GoTestRunConfiguration" factoryName="Go Test" temporary="true" nameIsGenerated="true">
+    <configuration name="go build SocialPlatform.messageCenter/rpc" type="GoApplicationRunConfiguration" factoryName="Go Application" temporary="true" nameIsGenerated="true">
       <module name="messageCenter" />
-      <working_directory value="$PROJECT_DIR$/entity" />
-      <root_directory value="$PROJECT_DIR$" />
+      <working_directory value="$PROJECT_DIR$/rpc" />
       <kind value="PACKAGE" />
-      <package value="SocialPlatform.messageCenter/entity" />
+      <package value="SocialPlatform.messageCenter/rpc" />
       <directory value="$PROJECT_DIR$" />
-      <filePath value="$PROJECT_DIR$" />
-      <framework value="gotest" />
-      <pattern value="^\QTestMessageMailBox_GetLast\E$/^\Qcase1\E$" />
+      <filePath value="$PROJECT_DIR$/rpc/messagecenter.go" />
       <method v="2" />
     </configuration>
     <configuration name="TestMessage_Get in SocialPlatform.messageCenter/entity" type="GoTestRunConfiguration" factoryName="Go Test" temporary="true" nameIsGenerated="true">
@@ -164,20 +139,26 @@
       <framework value="gotest" />
       <method v="2" />
     </configuration>
+    <configuration name="genrpc" type="MAKEFILE_TARGET_RUN_CONFIGURATION" factoryName="Makefile" temporary="true">
+      <makefile filename="$PROJECT_DIR$/MakeFile" target="genrpc" workingDirectory="" arguments="">
+        <envs />
+      </makefile>
+      <method v="2" />
+    </configuration>
     <list>
+      <item itemvalue="Go Build.go build SocialPlatform.messageCenter/api" />
       <item itemvalue="Go Build.go build SocialPlatform.messageCenter/rpc" />
-      <item itemvalue="Go Test.TestMessageMailBox_Count/case1 in SocialPlatform.messageCenter/entity" />
-      <item itemvalue="Go Test.TestMessageMailBox_GetLast/case1 in SocialPlatform.messageCenter/entity" />
       <item itemvalue="Go Test.TestMessage_Get in SocialPlatform.messageCenter/entity" />
       <item itemvalue="Go Test.TestMessage_Get/case1 in SocialPlatform.messageCenter/entity" />
+      <item itemvalue="Makefile Target.genrpc" />
     </list>
     <recent_temporary>
       <list>
+        <item itemvalue="Makefile Target.genrpc" />
+        <item itemvalue="Go Build.go build SocialPlatform.messageCenter/api" />
         <item itemvalue="Go Build.go build SocialPlatform.messageCenter/rpc" />
         <item itemvalue="Go Test.TestMessage_Get in SocialPlatform.messageCenter/entity" />
         <item itemvalue="Go Test.TestMessage_Get/case1 in SocialPlatform.messageCenter/entity" />
-        <item itemvalue="Go Test.TestMessageMailBox_GetLast/case1 in SocialPlatform.messageCenter/entity" />
-        <item itemvalue="Go Test.TestMessageMailBox_Count/case1 in SocialPlatform.messageCenter/entity" />
       </list>
     </recent_temporary>
   </component>

api/etc/logs.yaml

@@ -1,6 +0,0 @@
-Mode: file
-Path: ./logs
-Level:
-  - info
-  - error
-KeepDays: 10

api/etc/messagecenter.yaml

@@ -1,17 +0,0 @@
-Name: social-messageCenter
-Host: 0.0.0.0
-Port: 8888
-WebRpcPort: 8016
-Gateway:
-  ServerCode: jyinfo
-  Etcd:
-    - 127.0.0.1:2379
-Message:
-  Etcd:
-    Hosts:
-      - 192.168.3.206:2379
-    Key: social-messagecenter.rpc
-  Timeout: 10000
-AppId: 10000
-MaxBytes: 2097152
-Timeout:  500000

api/internal/config/config.go

@@ -1,11 +0,0 @@
-package config
-
-import (
-	"github.com/zeromicro/go-zero/rest"
-	"github.com/zeromicro/go-zero/zrpc"
-)
-
-type Config struct {
-	rest.RestConf
-	Message zrpc.RpcClientConf
-}

api/internal/handler/counthandler.go

@@ -1,29 +0,0 @@
-package handler
-
-import (
-	"net/http"
-
-	"SocialPlatform.messageCenter/api/internal/logic"
-	"SocialPlatform.messageCenter/api/internal/svc"
-	"SocialPlatform.messageCenter/api/internal/types"
-
-	"github.com/zeromicro/go-zero/rest/httpx"
-)
-
-func countHandler(ctx *svc.ServiceContext) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		var req types.CountReq
-		if err := httpx.Parse(r, &req); err != nil {
-			httpx.Error(w, err)
-			return
-		}
-
-		l := logic.NewCountLogic(r.Context(), ctx)
-		resp, err := l.Count(req)
-		if err != nil {
-			httpx.Error(w, err)
-		} else {
-			httpx.OkJson(w, resp)
-		}
-	}
-}

api/internal/handler/lastmessagehandler.go

@@ -1,29 +0,0 @@
-package handler
-
-import (
-	"net/http"
-
-	"SocialPlatform.messageCenter/api/internal/logic"
-	"SocialPlatform.messageCenter/api/internal/svc"
-	"SocialPlatform.messageCenter/api/internal/types"
-
-	"github.com/zeromicro/go-zero/rest/httpx"
-)
-
-func lastMessageHandler(ctx *svc.ServiceContext) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		var req types.GetReq
-		if err := httpx.Parse(r, &req); err != nil {
-			httpx.Error(w, err)
-			return
-		}
-
-		l := logic.NewLastMessageLogic(r.Context(), ctx)
-		resp, err := l.LastMessage(req)
-		if err != nil {
-			httpx.Error(w, err)
-		} else {
-			httpx.OkJson(w, resp)
-		}
-	}
-}

api/internal/handler/routes.go

@@ -1,27 +0,0 @@
-// Code generated by goctl. DO NOT EDIT.
-package handler
-
-import (
-	"net/http"
-
-	"SocialPlatform.messageCenter/api/internal/svc"
-
-	"github.com/zeromicro/go-zero/rest"
-)
-
-func RegisterHandlers(engine *rest.Server, serverCtx *svc.ServiceContext) {
-	engine.AddRoutes(
-		[]rest.Route{
-			{
-				Method:  http.MethodGet,
-				Path:    "/api/message/count",
-				Handler: countHandler(serverCtx),
-			},
-			{
-				Method:  http.MethodGet,
-				Path:    "/api/message/last",
-				Handler: lastMessageHandler(serverCtx),
-			},
-		},
-	)
-}

api/internal/logic/countlogic.go

@@ -1,30 +0,0 @@
-package logic
-
-import (
-	"context"
-
-	"SocialPlatform.messageCenter/api/internal/svc"
-	"SocialPlatform.messageCenter/api/internal/types"
-
-	"github.com/zeromicro/go-zero/core/logx"
-)
-
-type CountLogic struct {
-	logx.Logger
-	ctx    context.Context
-	svcCtx *svc.ServiceContext
-}
-
-func NewCountLogic(ctx context.Context, svcCtx *svc.ServiceContext) CountLogic {
-	return CountLogic{
-		Logger: logx.WithContext(ctx),
-		ctx:    ctx,
-		svcCtx: svcCtx,
-	}
-}
-
-func (l *CountLogic) Count(req types.CountReq) (*types.CountRes, error) {
-	// todo: add your logic here and delete this line
-
-	return &types.CountRes{}, nil
-}

api/internal/logic/lastmessagelogic.go

@@ -1,30 +0,0 @@
-package logic
-
-import (
-	"context"
-
-	"SocialPlatform.messageCenter/api/internal/svc"
-	"SocialPlatform.messageCenter/api/internal/types"
-
-	"github.com/zeromicro/go-zero/core/logx"
-)
-
-type LastMessageLogic struct {
-	logx.Logger
-	ctx    context.Context
-	svcCtx *svc.ServiceContext
-}
-
-func NewLastMessageLogic(ctx context.Context, svcCtx *svc.ServiceContext) LastMessageLogic {
-	return LastMessageLogic{
-		Logger: logx.WithContext(ctx),
-		ctx:    ctx,
-		svcCtx: svcCtx,
-	}
-}
-
-func (l *LastMessageLogic) LastMessage(req types.GetReq) (*types.GetRes, error) {
-	// todo: add your logic here and delete this line
-
-	return &types.GetRes{}, nil
-}

api/internal/svc/servicecontext.go

@@ -1,19 +0,0 @@
-package svc
-
-import (
-	"SocialPlatform.messageCenter/api/internal/config"
-	"SocialPlatform.messageCenter/rpc/messagecenterclient"
-	"github.com/zeromicro/go-zero/zrpc"
-)
-
-type ServiceContext struct {
-	Config     config.Config
-	MessageRpc messagecenterclient.MessageCenter
-}
-
-func NewServiceContext(c config.Config) *ServiceContext {
-	return &ServiceContext{
-		Config:     c,
-		MessageRpc: messagecenterclient.NewMessageCenter(zrpc.MustNewClient(c.Message)),
-	}
-}

api/internal/types/types.go

@@ -1,28 +0,0 @@
-// Code generated by goctl. DO NOT EDIT.
-package types
-
-type Request struct {
-}
-
-type Response struct {
-}
-
-type CountReq struct {
-	ReadType  int64  `json:"readType"`  // 已读类型
-	MsgType   int64  `json:"msgType"`   // 消息类型
-	SendId    string `json:"sendId"`    // 发送方id
-	ReceiveId string `json:"receiveId"` // 接收方id
-}
-
-type CountRes struct {
-}
-
-type GetReq struct {
-}
-
-type GetRes struct {
-	ReadType  int64  `json:"readType"`  // 已读类型
-	MsgType   int64  `json:"msgType"`   // 消息类型
-	SendId    string `json:"sendId"`    // 发送方id
-	ReceiveId string `json:"receiveId"` // 接收方id
-}

api/messageCenter.api

@@ -1,42 +0,0 @@
-syntax = "v1"
-
-info(
-	title: "type title here"
-	desc: "type desc here"
-	author: "type author here"
-	email: "type email here"
-	version: "type version here"
-)
-
-type request {
-	// TODO: add members here and delete this comment
-}
-
-type response {
-	// TODO: add members here and delete this comment
-}
-
-type countReq {
-	ReadType  int64  `json:"readType"`  // 已读类型
-	MsgType   int64  `json:"msgType"`   // 消息类型
-	SendId    string `json:"sendId"`    // 发送方id
-	ReceiveId string `json:"receiveId"` // 接收方id
-}
-type countRes {
-}
-type getReq {
-}
-type getRes {
-	ReadType  int64  `json:"readType"`  // 已读类型
-	MsgType   int64  `json:"msgType"`   // 消息类型
-	SendId    string `json:"sendId"`    // 发送方id
-	ReceiveId string `json:"receiveId"` // 接收方id
-}
-service messageCenter {
-	//
-	@handler count
-	get /api/message/count (countReq) returns (countRes)
-	//
-	@handler lastMessage
-	get /api/message/last (getReq) returns (getRes)
-}

api/messagecenter/etc/messagecenter-api.yaml

@@ -0,0 +1,3 @@
+Name: messagecenter-api
+Host: 0.0.0.0
+Port: 8888

api/messagecenter/internal/config/config.go

@@ -0,0 +1,7 @@
+package config
+
+import "github.com/zeromicro/go-zero/rest"
+
+type Config struct {
+	rest.RestConf
+}

api/messagecenter/internal/handler/messagecenterhandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+	"messagecenter/api/messagecenter/internal/logic"
+	"messagecenter/api/messagecenter/internal/svc"
+	"messagecenter/api/messagecenter/internal/types"
+)
+
+func MessagecenterHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.Request
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.Error(w, err)
+			return
+		}
+
+		l := logic.NewMessagecenterLogic(r.Context(), svcCtx)
+		resp, err := l.Messagecenter(&req)
+		if err != nil {
+			httpx.Error(w, err)
+		} else {
+			httpx.OkJson(w, resp)
+		}
+	}
+}

api/messagecenter/internal/handler/routes.go

@@ -0,0 +1,22 @@
+// Code generated by goctl. DO NOT EDIT.
+package handler
+
+import (
+	"net/http"
+
+	"messagecenter/api/messagecenter/internal/svc"
+
+	"github.com/zeromicro/go-zero/rest"
+)
+
+func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
+	server.AddRoutes(
+		[]rest.Route{
+			{
+				Method:  http.MethodGet,
+				Path:    "/from/:name",
+				Handler: MessagecenterHandler(serverCtx),
+			},
+		},
+	)
+}

api/messagecenter/internal/logic/messagecenterlogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"messagecenter/api/messagecenter/internal/svc"
+	"messagecenter/api/messagecenter/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type MessagecenterLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewMessagecenterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *MessagecenterLogic {
+	return &MessagecenterLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *MessagecenterLogic) Messagecenter(req *types.Request) (resp *types.Response, err error) {
+	// todo: add your logic here and delete this line
+
+	return
+}

api/messagecenter/internal/svc/servicecontext.go

@@ -0,0 +1,15 @@
+package svc
+
+import (
+	"messagecenter/api/messagecenter/internal/config"
+)
+
+type ServiceContext struct {
+	Config config.Config
+}
+
+func NewServiceContext(c config.Config) *ServiceContext {
+	return &ServiceContext{
+		Config: c,
+	}
+}

api/messagecenter/internal/types/types.go

@@ -0,0 +1,10 @@
+// Code generated by goctl. DO NOT EDIT.
+package types
+
+type Request struct {
+	Name string `path:"name,options=you|me"`
+}
+
+type Response struct {
+	Message string `json:"message"`
+}

api/messagecenter/messagecenter.api

@@ -0,0 +1,12 @@
+type Request {
+	Name string `path:"name,options=you|me"`
+}
+
+type Response {
+	Message string `json:"message"`
+}
+
+service messagecenter-api {
+	@handler MessagecenterHandler
+	get /from/:name(Request) returns (Response)
+}

api/messagecenter.go → api/messagecenter/messagecenter.go

@@ -4,15 +4,15 @@ import (
 	"flag"
 	"fmt"
 
-	"SocialPlatform.messageCenter/api/internal/config"
-	"SocialPlatform.messageCenter/api/internal/handler"
-	"SocialPlatform.messageCenter/api/internal/svc"
+	"messagecenter/api/messagecenter/internal/config"
+	"messagecenter/api/messagecenter/internal/handler"
+	"messagecenter/api/messagecenter/internal/svc"
 
 	"github.com/zeromicro/go-zero/core/conf"
 	"github.com/zeromicro/go-zero/rest"
 )
 
-var configFile = flag.String("f", "etc/messageCenter.yaml", "the config file")
+var configFile = flag.String("f", "etc/messagecenter-api.yaml", "the config file")
 
 func main() {
 	flag.Parse()
@@ -20,10 +20,10 @@ func main() {
 	var c config.Config
 	conf.MustLoad(*configFile, &c)
 
-	ctx := svc.NewServiceContext(c)
 	server := rest.MustNewServer(c.RestConf)
 	defer server.Stop()
 
+	ctx := svc.NewServiceContext(c)
 	handler.RegisterHandlers(server, ctx)
 
 	fmt.Printf("Starting server at %s:%d...\n", c.Host, c.Port)

go.mod

@@ -1,10 +1,11 @@
-module SocialPlatform.messageCenter
+module messagecenter
 
 go 1.16
 
 require (
 	app.yhyue.com/moapp/jybase v0.0.0-20220617085837-48c1bf245c2f
 	github.com/go-sql-driver/mysql v1.6.0
+	github.com/golang/protobuf v1.5.2 // indirect
 	github.com/zeromicro/go-zero v1.3.4
 	google.golang.org/grpc v1.46.2
 	google.golang.org/protobuf v1.28.0

go.sum

@@ -189,6 +189,7 @@ github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5x
 github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
 github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
 github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
+github.com/golang-jwt/jwt/v4 v4.4.1 h1:pC5DB52sCeK48Wlb9oPcdhnjkz1TKt1D/P7WKJ0kUcQ=
 github.com/golang-jwt/jwt/v4 v4.4.1/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0=
 github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
 github.com/golang/groupcache v0.0.0-20190702054246-869f871628b6/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
@@ -309,6 +310,7 @@ github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1
 github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk=
 github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w=
 github.com/julienschmidt/httprouter v1.3.0/go.mod h1:JR6WtHb+2LUe8TCKY3cZOxFyyO8IZAc4RVcycCCAKdM=
+github.com/justinas/alice v1.2.0 h1:+MHSA/vccVCF4Uq37S42jwlkvI2Xzl7zTPCN5BnZNVo=
 github.com/justinas/alice v1.2.0/go.mod h1:fN5HRH/reO/zrUflLfTN43t3vXvKzvZIENsNEe7i7qA=
 github.com/karrick/godirwalk v1.8.0/go.mod h1:H5KPZjojv4lE+QYImBI8xVtrBRgYrIVsaRPx4tDPEn4=
 github.com/karrick/godirwalk v1.10.3/go.mod h1:RoGL9dQei4vP9ilrpETWE8CLOZ1kiN0LhBygSwrAsHA=

rpc/etc/logs.yaml

@@ -1,6 +0,0 @@
-Mode: file
-Path: ./logs
-Level:
-  - info
-  - error
-KeepDays: 10

rpc/etc/messagecenter.yaml

@@ -1,13 +0,0 @@
-Name: messagecenter.rpc
-ListenOn: 127.0.0.1:8080
-Etcd:
-  Hosts:
-  - 127.0.0.1:2379
-  Key: social-messagecenter.rpc
-MysqlMain:
-  dbName: base_service
-  address: 192.168.3.11:3366
-  userName: root
-  passWord: Topnet123
-  maxOpenConns: 5
-  maxIdleConns: 5

rpc/init/init.go

@@ -1,59 +0,0 @@
-package init
-
-import (
-	"SocialPlatform.messageCenter/entity"
-	"SocialPlatform.messageCenter/rpc/internal/config"
-	"app.yhyue.com/moapp/jybase/mysql"
-	"flag"
-	_ "github.com/go-sql-driver/mysql"
-	"github.com/zeromicro/go-zero/core/conf"
-	"github.com/zeromicro/go-zero/core/logx"
-	"log"
-)
-
-var configF = flag.String("ff", "etc/messagecenter.yaml", "the config file")
-
-//
-var logFile = flag.String("lf", "etc/logs.yaml", "the config file")
-
-type logConfig struct {
-	Mode     string
-	Path     string
-	Level    []string
-	KeepDays int
-}
-
-var logC logConfig
-
-var C config.Config
-
-func init() {
-	conf.MustLoad(*configF, &C)
-	//初始化mysql
-	if C.MysqlMain.Address != "" {
-		log.Println("--初始化 mysql--")
-		entity.Mysql = &mysql.Mysql{
-			Address:      C.MysqlMain.Address,
-			UserName:     C.MysqlMain.UserName,
-			PassWord:     C.MysqlMain.PassWord,
-			DBName:       C.MysqlMain.DbName,
-			MaxOpenConns: C.MysqlMain.MaxOpenConns,
-			MaxIdleConns: C.MysqlMain.MaxIdleConns,
-		}
-		entity.Mysql.Init()
-	}
-
-	//初始化日志信息
-	conf.MustLoad(*logFile, &logC)
-	if len(logC.Level) > 0 {
-		for _, v := range logC.Level {
-			logx.MustSetup(logx.LogConf{
-				Mode:     logC.Mode,
-				Path:     logC.Path,
-				Level:    v,
-				KeepDays: logC.KeepDays,
-			})
-			logx.Info(v, "--日志记录")
-		}
-	}
-}

rpc/internal/config/config.go

@@ -1,16 +0,0 @@
-package config
-
-import "github.com/zeromicro/go-zero/zrpc"
-
-type Config struct {
-	zrpc.RpcServerConf
-	MysqlMain MysqlMainStruct
-}
-type MysqlMainStruct struct {
-	DbName       string `json:"dbName"`
-	Address      string `json:"address"`
-	UserName     string `json:"userName"`
-	PassWord     string `json:"passWord"`
-	MaxOpenConns int    `json:"maxOpenConns"`
-	MaxIdleConns int    `json:"maxIdleConns"`
-}

rpc/internal/logic/countlogic.go

@@ -1,39 +0,0 @@
-package logic
-
-import (
-	"SocialPlatform.messageCenter/entity"
-	"context"
-
-	"SocialPlatform.messageCenter/rpc/internal/svc"
-	"SocialPlatform.messageCenter/rpc/messagecenter"
-
-	"github.com/zeromicro/go-zero/core/logx"
-)
-
-type CountLogic struct {
-	ctx    context.Context
-	svcCtx *svc.ServiceContext
-	logx.Logger
-}
-
-func NewCountLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CountLogic {
-	return &CountLogic{
-		ctx:    ctx,
-		svcCtx: svcCtx,
-		Logger: logx.WithContext(ctx),
-	}
-}
-
-//  查询数量
-func (l *CountLogic) Count(in *messageCenter.CountReq) (*messageCenter.CountResp, error) {
-	// todo: add your logic here and delete this line
-	m := entity.MessageMailBox{}
-	count, err := m.Count(in.ReceiveId, in.SendId, int(in.MsgType), int(in.ReadType))
-	if err != nil {
-		return nil, err
-	}
-
-	return &messageCenter.CountResp{
-		Count: int64(count),
-	}, nil
-}

rpc/internal/logic/getlastlogic.go

@@ -1,40 +0,0 @@
-package logic
-
-import (
-	"SocialPlatform.messageCenter/entity"
-	"app.yhyue.com/moapp/jybase/common"
-	"context"
-
-	"SocialPlatform.messageCenter/rpc/internal/svc"
-	"SocialPlatform.messageCenter/rpc/messagecenter"
-
-	"github.com/zeromicro/go-zero/core/logx"
-)
-
-type GetLastLogic struct {
-	ctx    context.Context
-	svcCtx *svc.ServiceContext
-	logx.Logger
-}
-
-func NewGetLastLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetLastLogic {
-	return &GetLastLogic{
-		ctx:    ctx,
-		svcCtx: svcCtx,
-		Logger: logx.WithContext(ctx),
-	}
-}
-
-//  获取消息
-func (l *GetLastLogic) GetLast(in *messageCenter.GetReq) (*messageCenter.GetResp, error) {
-	m := entity.MessageMailBox{}
-	last, err := m.GetLast(in.ReceiveId, in.SendId, int(in.MsgType))
-	if err != nil {
-		return nil, err
-	}
-
-	return &messageCenter.GetResp{
-		CreateTime: common.ObjToString(last["create_time"]),
-		Content:    common.ObjToString(last["content"]),
-	}, nil
-}

rpc/internal/server/messagecenterserver.go

@@ -1,34 +0,0 @@
-// Code generated by goctl. DO NOT EDIT!
-// Source: messageCenter.proto
-
-package server
-
-import (
-	"context"
-
-	"SocialPlatform.messageCenter/rpc/internal/logic"
-	"SocialPlatform.messageCenter/rpc/internal/svc"
-	"SocialPlatform.messageCenter/rpc/messageCenter"
-)
-
-type MessageCenterServer struct {
-	svcCtx *svc.ServiceContext
-}
-
-func NewMessageCenterServer(svcCtx *svc.ServiceContext) *MessageCenterServer {
-	return &MessageCenterServer{
-		svcCtx: svcCtx,
-	}
-}
-
-//  查询数量
-func (s *MessageCenterServer) Count(ctx context.Context, in *messageCenter.CountReq) (*messageCenter.CountResp, error) {
-	l := logic.NewCountLogic(ctx, s.svcCtx)
-	return l.Count(in)
-}
-
-//  获取消息
-func (s *MessageCenterServer) GetLast(ctx context.Context, in *messageCenter.GetReq) (*messageCenter.GetResp, error) {
-	l := logic.NewGetLastLogic(ctx, s.svcCtx)
-	return l.GetLast(in)
-}

rpc/messageCenter.proto

@@ -1,33 +0,0 @@
-syntax = "proto3";
-
-package messageCenter;
-option go_package = "./messageCenter";
-
-message CountReq {
-  int64 readType = 1;    // 已读类型
-  int64 msgType = 2;     // 消息类型
-  string sendId = 3;     // 发送方id
-  string receiveId = 4;  // 接收方id
-}
-
-message CountResp {
-  int64 count = 1;
-
-}
-message GetReq {
-  int64 msgType = 1;     // 消息类型
-  string sendId = 2;     // 发送方id
-  string receiveId = 3;  // 接收方id
-}
-
-message GetResp {
-  string content = 1;
-  string createTime = 2;
-}
-service messageCenter {
-  // 查询数量
-  rpc Count(CountReq) returns (CountResp);
-  // 获取消息
-  rpc GetLast(GetReq)   returns (GetResp);
-
-}

rpc/messageCenter/messageCenter.pb.go

@@ -1,379 +0,0 @@
-// Code generated by protoc-gen-go. DO NOT EDIT.
-// source: messageCenter.proto
-
-package messageCenter
-
-import (
-	context "context"
-	fmt "fmt"
-	proto "github.com/golang/protobuf/proto"
-	grpc "google.golang.org/grpc"
-	codes "google.golang.org/grpc/codes"
-	status "google.golang.org/grpc/status"
-	math "math"
-)
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ = proto.Marshal
-var _ = fmt.Errorf
-var _ = math.Inf
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the proto package it is being compiled against.
-// A compilation error at this line likely means your copy of the
-// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
-
-type CountReq struct {
-	ReadType             int64    `protobuf:"varint,1,opt,name=readType,proto3" json:"readType,omitempty"`
-	MsgType              int64    `protobuf:"varint,2,opt,name=msgType,proto3" json:"msgType,omitempty"`
-	SendId               string   `protobuf:"bytes,3,opt,name=sendId,proto3" json:"sendId,omitempty"`
-	ReceiveId            string   `protobuf:"bytes,4,opt,name=receiveId,proto3" json:"receiveId,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *CountReq) Reset()         { *m = CountReq{} }
-func (m *CountReq) String() string { return proto.CompactTextString(m) }
-func (*CountReq) ProtoMessage()    {}
-func (*CountReq) Descriptor() ([]byte, []int) {
-	return fileDescriptor_e1ab527c77caa1b6, []int{0}
-}
-
-func (m *CountReq) XXX_Unmarshal(b []byte) error {
-	return xxx_messageInfo_CountReq.Unmarshal(m, b)
-}
-func (m *CountReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	return xxx_messageInfo_CountReq.Marshal(b, m, deterministic)
-}
-func (m *CountReq) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_CountReq.Merge(m, src)
-}
-func (m *CountReq) XXX_Size() int {
-	return xxx_messageInfo_CountReq.Size(m)
-}
-func (m *CountReq) XXX_DiscardUnknown() {
-	xxx_messageInfo_CountReq.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_CountReq proto.InternalMessageInfo
-
-func (m *CountReq) GetReadType() int64 {
-	if m != nil {
-		return m.ReadType
-	}
-	return 0
-}
-
-func (m *CountReq) GetMsgType() int64 {
-	if m != nil {
-		return m.MsgType
-	}
-	return 0
-}
-
-func (m *CountReq) GetSendId() string {
-	if m != nil {
-		return m.SendId
-	}
-	return ""
-}
-
-func (m *CountReq) GetReceiveId() string {
-	if m != nil {
-		return m.ReceiveId
-	}
-	return ""
-}
-
-type CountResp struct {
-	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *CountResp) Reset()         { *m = CountResp{} }
-func (m *CountResp) String() string { return proto.CompactTextString(m) }
-func (*CountResp) ProtoMessage()    {}
-func (*CountResp) Descriptor() ([]byte, []int) {
-	return fileDescriptor_e1ab527c77caa1b6, []int{1}
-}
-
-func (m *CountResp) XXX_Unmarshal(b []byte) error {
-	return xxx_messageInfo_CountResp.Unmarshal(m, b)
-}
-func (m *CountResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	return xxx_messageInfo_CountResp.Marshal(b, m, deterministic)
-}
-func (m *CountResp) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_CountResp.Merge(m, src)
-}
-func (m *CountResp) XXX_Size() int {
-	return xxx_messageInfo_CountResp.Size(m)
-}
-func (m *CountResp) XXX_DiscardUnknown() {
-	xxx_messageInfo_CountResp.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_CountResp proto.InternalMessageInfo
-
-func (m *CountResp) GetCount() int64 {
-	if m != nil {
-		return m.Count
-	}
-	return 0
-}
-
-type GetReq struct {
-	MsgType              int64    `protobuf:"varint,1,opt,name=msgType,proto3" json:"msgType,omitempty"`
-	SendId               string   `protobuf:"bytes,2,opt,name=sendId,proto3" json:"sendId,omitempty"`
-	ReceiveId            string   `protobuf:"bytes,3,opt,name=receiveId,proto3" json:"receiveId,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *GetReq) Reset()         { *m = GetReq{} }
-func (m *GetReq) String() string { return proto.CompactTextString(m) }
-func (*GetReq) ProtoMessage()    {}
-func (*GetReq) Descriptor() ([]byte, []int) {
-	return fileDescriptor_e1ab527c77caa1b6, []int{2}
-}
-
-func (m *GetReq) XXX_Unmarshal(b []byte) error {
-	return xxx_messageInfo_GetReq.Unmarshal(m, b)
-}
-func (m *GetReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	return xxx_messageInfo_GetReq.Marshal(b, m, deterministic)
-}
-func (m *GetReq) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_GetReq.Merge(m, src)
-}
-func (m *GetReq) XXX_Size() int {
-	return xxx_messageInfo_GetReq.Size(m)
-}
-func (m *GetReq) XXX_DiscardUnknown() {
-	xxx_messageInfo_GetReq.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_GetReq proto.InternalMessageInfo
-
-func (m *GetReq) GetMsgType() int64 {
-	if m != nil {
-		return m.MsgType
-	}
-	return 0
-}
-
-func (m *GetReq) GetSendId() string {
-	if m != nil {
-		return m.SendId
-	}
-	return ""
-}
-
-func (m *GetReq) GetReceiveId() string {
-	if m != nil {
-		return m.ReceiveId
-	}
-	return ""
-}
-
-type GetResp struct {
-	Content              string   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
-	CreateTime           string   `protobuf:"bytes,2,opt,name=createTime,proto3" json:"createTime,omitempty"`
-	XXX_NoUnkeyedLiteral struct{} `json:"-"`
-	XXX_unrecognized     []byte   `json:"-"`
-	XXX_sizecache        int32    `json:"-"`
-}
-
-func (m *GetResp) Reset()         { *m = GetResp{} }
-func (m *GetResp) String() string { return proto.CompactTextString(m) }
-func (*GetResp) ProtoMessage()    {}
-func (*GetResp) Descriptor() ([]byte, []int) {
-	return fileDescriptor_e1ab527c77caa1b6, []int{3}
-}
-
-func (m *GetResp) XXX_Unmarshal(b []byte) error {
-	return xxx_messageInfo_GetResp.Unmarshal(m, b)
-}
-func (m *GetResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
-	return xxx_messageInfo_GetResp.Marshal(b, m, deterministic)
-}
-func (m *GetResp) XXX_Merge(src proto.Message) {
-	xxx_messageInfo_GetResp.Merge(m, src)
-}
-func (m *GetResp) XXX_Size() int {
-	return xxx_messageInfo_GetResp.Size(m)
-}
-func (m *GetResp) XXX_DiscardUnknown() {
-	xxx_messageInfo_GetResp.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_GetResp proto.InternalMessageInfo
-
-func (m *GetResp) GetContent() string {
-	if m != nil {
-		return m.Content
-	}
-	return ""
-}
-
-func (m *GetResp) GetCreateTime() string {
-	if m != nil {
-		return m.CreateTime
-	}
-	return ""
-}
-
-func init() {
-	proto.RegisterType((*CountReq)(nil), "messageCenter.CountReq")
-	proto.RegisterType((*CountResp)(nil), "messageCenter.CountResp")
-	proto.RegisterType((*GetReq)(nil), "messageCenter.GetReq")
-	proto.RegisterType((*GetResp)(nil), "messageCenter.GetResp")
-}
-
-func init() { proto.RegisterFile("messageCenter.proto", fileDescriptor_e1ab527c77caa1b6) }
-
-var fileDescriptor_e1ab527c77caa1b6 = []byte{
-	// 265 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x91, 0x41, 0x4b, 0xc3, 0x40,
-	0x10, 0x85, 0xd9, 0xc6, 0xa6, 0xcd, 0x80, 0x88, 0xa3, 0xd6, 0x25, 0x88, 0xd4, 0x9c, 0x7a, 0x8a,
-	0xa0, 0x17, 0xf1, 0x68, 0x0e, 0x52, 0xf0, 0x14, 0x7a, 0x10, 0x6f, 0x31, 0x19, 0x4a, 0x0f, 0x49,
-	0xd6, 0x9d, 0xb5, 0xe0, 0x0f, 0xf0, 0x7f, 0x4b, 0xb7, 0x1b, 0xdb, 0x2d, 0xcd, 0xf1, 0xbd, 0x17,
-	0xde, 0x37, 0x79, 0x0b, 0x17, 0x35, 0x31, 0x17, 0x4b, 0xca, 0xa8, 0x31, 0xa4, 0x53, 0xa5, 0x5b,
-	0xd3, 0xe2, 0xa9, 0x67, 0x26, 0x6b, 0x18, 0x67, 0xed, 0x77, 0x63, 0x72, 0xfa, 0xc2, 0x18, 0xc6,
-	0x9a, 0x8a, 0x6a, 0xf1, 0xa3, 0x48, 0x8a, 0xa9, 0x98, 0x05, 0xf9, 0xbf, 0x46, 0x09, 0xa3, 0x9a,
-	0x97, 0x36, 0x1a, 0xd8, 0xa8, 0x93, 0x38, 0x81, 0x90, 0xa9, 0xa9, 0xe6, 0x95, 0x0c, 0xa6, 0x62,
-	0x16, 0xe5, 0x4e, 0xe1, 0x0d, 0x44, 0x9a, 0x4a, 0x5a, 0xad, 0x69, 0x5e, 0xc9, 0x13, 0x1b, 0xed,
-	0x8c, 0xe4, 0x0e, 0x22, 0xc7, 0x65, 0x85, 0x97, 0x30, 0x2c, 0x37, 0xc2, 0x51, 0xb7, 0x22, 0x79,
-	0x87, 0xf0, 0x95, 0xec, 0x61, 0x7b, 0x70, 0xd1, 0x07, 0x1f, 0xf4, 0xc3, 0x83, 0x43, 0x78, 0x06,
-	0x23, 0xdb, 0xcc, 0x6a, 0x53, 0x5d, 0xb6, 0x8d, 0x21, 0x07, 0x8f, 0xf2, 0x4e, 0xe2, 0x2d, 0x40,
-	0xa9, 0xa9, 0x30, 0xb4, 0x58, 0xd5, 0xe4, 0xea, 0xf7, 0x9c, 0x87, 0x5f, 0x01, 0xfe, 0x96, 0xf8,
-	0x0c, 0x43, 0xfb, 0x4f, 0x78, 0x9d, 0xfa, 0xcb, 0x77, 0x0b, 0xc7, 0xf2, 0x78, 0xc0, 0x0a, 0x9f,
-	0xec, 0x49, 0x6f, 0x05, 0x1b, 0xbc, 0x3a, 0xf8, 0x68, 0x3b, 0x42, 0x3c, 0x39, 0x66, 0xb3, 0x7a,
-	0x39, 0xff, 0x38, 0x4b, 0xef, 0xbd, 0xe8, 0x33, 0xb4, 0x4f, 0xfd, 0xf8, 0x17, 0x00, 0x00, 0xff,
-	0xff, 0x91, 0x3b, 0x3d, 0xef, 0x01, 0x02, 0x00, 0x00,
-}
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ context.Context
-var _ grpc.ClientConn
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the grpc package it is being compiled against.
-const _ = grpc.SupportPackageIsVersion4
-
-// MessageCenterClient is the client API for MessageCenter service.
-//
-// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
-type MessageCenterClient interface {
-	// 查询数量
-	Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error)
-	// 获取消息
-	GetLast(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*GetResp, error)
-}
-
-type messageCenterClient struct {
-	cc *grpc.ClientConn
-}
-
-func NewMessageCenterClient(cc *grpc.ClientConn) MessageCenterClient {
-	return &messageCenterClient{cc}
-}
-
-func (c *messageCenterClient) Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error) {
-	out := new(CountResp)
-	err := c.cc.Invoke(ctx, "/messageCenter.messageCenter/Count", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-func (c *messageCenterClient) GetLast(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*GetResp, error) {
-	out := new(GetResp)
-	err := c.cc.Invoke(ctx, "/messageCenter.messageCenter/GetLast", in, out, opts...)
-	if err != nil {
-		return nil, err
-	}
-	return out, nil
-}
-
-// MessageCenterServer is the server API for MessageCenter service.
-type MessageCenterServer interface {
-	// 查询数量
-	Count(context.Context, *CountReq) (*CountResp, error)
-	// 获取消息
-	GetLast(context.Context, *GetReq) (*GetResp, error)
-}
-
-// UnimplementedMessageCenterServer can be embedded to have forward compatible implementations.
-type UnimplementedMessageCenterServer struct {
-}
-
-func (*UnimplementedMessageCenterServer) Count(ctx context.Context, req *CountReq) (*CountResp, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method Count not implemented")
-}
-func (*UnimplementedMessageCenterServer) GetLast(ctx context.Context, req *GetReq) (*GetResp, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method GetLast not implemented")
-}
-
-func RegisterMessageCenterServer(s *grpc.Server, srv MessageCenterServer) {
-	s.RegisterService(&_MessageCenter_serviceDesc, srv)
-}
-
-func _MessageCenter_Count_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CountReq)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(MessageCenterServer).Count(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/messageCenter.messageCenter/Count",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(MessageCenterServer).Count(ctx, req.(*CountReq))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-func _MessageCenter_GetLast_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(GetReq)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	if interceptor == nil {
-		return srv.(MessageCenterServer).GetLast(ctx, in)
-	}
-	info := &grpc.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: "/messageCenter.messageCenter/GetLast",
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(MessageCenterServer).GetLast(ctx, req.(*GetReq))
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
-var _MessageCenter_serviceDesc = grpc.ServiceDesc{
-	ServiceName: "messageCenter.messageCenter",
-	HandlerType: (*MessageCenterServer)(nil),
-	Methods: []grpc.MethodDesc{
-		{
-			MethodName: "Count",
-			Handler:    _MessageCenter_Count_Handler,
-		},
-		{
-			MethodName: "GetLast",
-			Handler:    _MessageCenter_GetLast_Handler,
-		},
-	},
-	Streams:  []grpc.StreamDesc{},
-	Metadata: "messageCenter.proto",
-}

rpc/messagecenter.go

@@ -1,34 +0,0 @@
-package main
-
-import (
-	"flag"
-	"fmt"
-
-	"SocialPlatform.messageCenter/rpc/internal/config"
-	"SocialPlatform.messageCenter/rpc/internal/server"
-	"SocialPlatform.messageCenter/rpc/internal/svc"
-	"SocialPlatform.messageCenter/rpc/messageCenter"
-
-	"github.com/tal-tech/go-zero/core/conf"
-	"github.com/tal-tech/go-zero/zrpc"
-	"google.golang.org/grpc"
-)
-
-var configFile = flag.String("f", "etc/messagecenter.yaml", "the config file")
-
-func main() {
-	flag.Parse()
-
-	var c config.Config
-	conf.MustLoad(*configFile, &c)
-	ctx := svc.NewServiceContext(c)
-	srv := server.NewMessageCenterServer(ctx)
-
-	s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
-		messageCenter.RegisterMessageCenterServer(grpcServer, srv)
-	})
-	defer s.Stop()
-
-	fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
-	s.Start()
-}

rpc/messagecenter/etc/messagecenter.yaml

@@ -0,0 +1,6 @@
+Name: messagecenter.rpc
+ListenOn: 127.0.0.1:8080
+Etcd:
+  Hosts:
+  - 127.0.0.1:2379
+  Key: messagecenter.rpc

rpc/messagecenter/internal/config/config.go

@@ -0,0 +1,7 @@
+package config
+
+import "github.com/zeromicro/go-zero/zrpc"
+
+type Config struct {
+	zrpc.RpcServerConf
+}

rpc/messagecenter/internal/logic/pinglogic.go

@@ -0,0 +1,30 @@
+package logic
+
+import (
+	"context"
+
+	"messagecenter/rpc/messagecenter/internal/svc"
+	"messagecenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type PingLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewPingLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PingLogic {
+	return &PingLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *PingLogic) Ping(in *messagecenter.Request) (*messagecenter.Response, error) {
+	// todo: add your logic here and delete this line
+
+	return &messagecenter.Response{}, nil
+}

rpc/messagecenter/internal/server/messagecenterserver.go

@@ -0,0 +1,28 @@
+// Code generated by goctl. DO NOT EDIT!
+// Source: messagecenter.proto
+
+package server
+
+import (
+	"context"
+
+	"messagecenter/rpc/messagecenter/internal/logic"
+	"messagecenter/rpc/messagecenter/internal/svc"
+	"messagecenter/rpc/messagecenter/messagecenter"
+)
+
+type MessagecenterServer struct {
+	svcCtx *svc.ServiceContext
+	messagecenter.UnimplementedMessagecenterServer
+}
+
+func NewMessagecenterServer(svcCtx *svc.ServiceContext) *MessagecenterServer {
+	return &MessagecenterServer{
+		svcCtx: svcCtx,
+	}
+}
+
+func (s *MessagecenterServer) Ping(ctx context.Context, in *messagecenter.Request) (*messagecenter.Response, error) {
+	l := logic.NewPingLogic(ctx, s.svcCtx)
+	return l.Ping(in)
+}

rpc/internal/svc/servicecontext.go → rpc/messagecenter/internal/svc/servicecontext.go

@@ -1,6 +1,6 @@
 package svc
 
-import "SocialPlatform.messageCenter/rpc/internal/config"
+import "messagecenter/rpc/messagecenter/internal/config"
 
 type ServiceContext struct {
 	Config config.Config

rpc/messagecenter/messagecenter.go

@@ -0,0 +1,40 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+
+	"messagecenter/rpc/messagecenter/internal/config"
+	"messagecenter/rpc/messagecenter/internal/server"
+	"messagecenter/rpc/messagecenter/internal/svc"
+	"messagecenter/rpc/messagecenter/messagecenter"
+
+	"github.com/zeromicro/go-zero/core/conf"
+	"github.com/zeromicro/go-zero/core/service"
+	"github.com/zeromicro/go-zero/zrpc"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/reflection"
+)
+
+var configFile = flag.String("f", "etc/messagecenter.yaml", "the config file")
+
+func main() {
+	flag.Parse()
+
+	var c config.Config
+	conf.MustLoad(*configFile, &c)
+	ctx := svc.NewServiceContext(c)
+	svr := server.NewMessagecenterServer(ctx)
+
+	s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
+		messagecenter.RegisterMessagecenterServer(grpcServer, svr)
+
+		if c.Mode == service.DevMode || c.Mode == service.TestMode {
+			reflection.Register(grpcServer)
+		}
+	})
+	defer s.Stop()
+
+	fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
+	s.Start()
+}

rpc/messagecenter/messagecenter.proto

@@ -0,0 +1,16 @@
+syntax = "proto3";
+
+package messagecenter;
+option go_package="./messagecenter";
+
+message Request {
+  string ping = 1;
+}
+
+message Response {
+  string pong = 1;
+}
+
+service Messagecenter {
+  rpc Ping(Request) returns(Response);
+}

rpc/messagecenter/messagecenter/messagecenter.go

@@ -0,0 +1,32 @@
+// Code generated by goctl. DO NOT EDIT!
+// Source: messagecenter.proto
+
+package messagecenter
+
+import (
+	"context"
+
+	"github.com/zeromicro/go-zero/zrpc"
+	"google.golang.org/grpc"
+)
+
+type (
+	Messagecenter interface {
+		Ping(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
+	}
+
+	defaultMessagecenter struct {
+		cli zrpc.Client
+	}
+)
+
+func NewMessagecenter(cli zrpc.Client) Messagecenter {
+	return &defaultMessagecenter{
+		cli: cli,
+	}
+}
+
+func (m *defaultMessagecenter) Ping(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) {
+	client := NewMessagecenterClient(m.cli.Conn())
+	return client.Ping(ctx, in, opts...)
+}

rpc/messagecenter/messagecenter/messagecenter.pb.go

@@ -0,0 +1,211 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.28.0
+// 	protoc        v3.19.4
+// source: messagecenter.proto
+
+package messagecenter
+
+import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	reflect "reflect"
+	sync "sync"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+type Request struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Ping string `protobuf:"bytes,1,opt,name=ping,proto3" json:"ping,omitempty"`
+}
+
+func (x *Request) Reset() {
+	*x = Request{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_messagecenter_proto_msgTypes[0]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *Request) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*Request) ProtoMessage() {}
+
+func (x *Request) ProtoReflect() protoreflect.Message {
+	mi := &file_messagecenter_proto_msgTypes[0]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use Request.ProtoReflect.Descriptor instead.
+func (*Request) Descriptor() ([]byte, []int) {
+	return file_messagecenter_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *Request) GetPing() string {
+	if x != nil {
+		return x.Ping
+	}
+	return ""
+}
+
+type Response struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Pong string `protobuf:"bytes,1,opt,name=pong,proto3" json:"pong,omitempty"`
+}
+
+func (x *Response) Reset() {
+	*x = Response{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_messagecenter_proto_msgTypes[1]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *Response) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*Response) ProtoMessage() {}
+
+func (x *Response) ProtoReflect() protoreflect.Message {
+	mi := &file_messagecenter_proto_msgTypes[1]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use Response.ProtoReflect.Descriptor instead.
+func (*Response) Descriptor() ([]byte, []int) {
+	return file_messagecenter_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *Response) GetPong() string {
+	if x != nil {
+		return x.Pong
+	}
+	return ""
+}
+
+var File_messagecenter_proto protoreflect.FileDescriptor
+
+var file_messagecenter_proto_rawDesc = []byte{
+	0x0a, 0x13, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x2e,
+	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0d, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x63, 0x65,
+	0x6e, 0x74, 0x65, 0x72, 0x22, 0x1d, 0x0a, 0x07, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
+	0x12, 0x0a, 0x04, 0x70, 0x69, 0x6e, 0x67, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70,
+	0x69, 0x6e, 0x67, 0x22, 0x1e, 0x0a, 0x08, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
+	0x12, 0x0a, 0x04, 0x70, 0x6f, 0x6e, 0x67, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70,
+	0x6f, 0x6e, 0x67, 0x32, 0x48, 0x0a, 0x0d, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x63, 0x65,
+	0x6e, 0x74, 0x65, 0x72, 0x12, 0x37, 0x0a, 0x04, 0x50, 0x69, 0x6e, 0x67, 0x12, 0x16, 0x2e, 0x6d,
+	0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x2e, 0x52, 0x65, 0x71,
+	0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x63, 0x65,
+	0x6e, 0x74, 0x65, 0x72, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x11, 0x5a,
+	0x0f, 0x2e, 0x2f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72,
+	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+	file_messagecenter_proto_rawDescOnce sync.Once
+	file_messagecenter_proto_rawDescData = file_messagecenter_proto_rawDesc
+)
+
+func file_messagecenter_proto_rawDescGZIP() []byte {
+	file_messagecenter_proto_rawDescOnce.Do(func() {
+		file_messagecenter_proto_rawDescData = protoimpl.X.CompressGZIP(file_messagecenter_proto_rawDescData)
+	})
+	return file_messagecenter_proto_rawDescData
+}
+
+var file_messagecenter_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
+var file_messagecenter_proto_goTypes = []interface{}{
+	(*Request)(nil),  // 0: messagecenter.Request
+	(*Response)(nil), // 1: messagecenter.Response
+}
+var file_messagecenter_proto_depIdxs = []int32{
+	0, // 0: messagecenter.Messagecenter.Ping:input_type -> messagecenter.Request
+	1, // 1: messagecenter.Messagecenter.Ping:output_type -> messagecenter.Response
+	1, // [1:2] is the sub-list for method output_type
+	0, // [0:1] is the sub-list for method input_type
+	0, // [0:0] is the sub-list for extension type_name
+	0, // [0:0] is the sub-list for extension extendee
+	0, // [0:0] is the sub-list for field type_name
+}
+
+func init() { file_messagecenter_proto_init() }
+func file_messagecenter_proto_init() {
+	if File_messagecenter_proto != nil {
+		return
+	}
+	if !protoimpl.UnsafeEnabled {
+		file_messagecenter_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*Request); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_messagecenter_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*Response); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+	}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: file_messagecenter_proto_rawDesc,
+			NumEnums:      0,
+			NumMessages:   2,
+			NumExtensions: 0,
+			NumServices:   1,
+		},
+		GoTypes:           file_messagecenter_proto_goTypes,
+		DependencyIndexes: file_messagecenter_proto_depIdxs,
+		MessageInfos:      file_messagecenter_proto_msgTypes,
+	}.Build()
+	File_messagecenter_proto = out.File
+	file_messagecenter_proto_rawDesc = nil
+	file_messagecenter_proto_goTypes = nil
+	file_messagecenter_proto_depIdxs = nil
+}

rpc/messagecenter/messagecenter/messagecenter_grpc.pb.go

@@ -0,0 +1,105 @@
+// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-grpc v1.2.0
+// - protoc             v3.19.4
+// source: messagecenter.proto
+
+package messagecenter
+
+import (
+	context "context"
+	grpc "google.golang.org/grpc"
+	codes "google.golang.org/grpc/codes"
+	status "google.golang.org/grpc/status"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+// Requires gRPC-Go v1.32.0 or later.
+const _ = grpc.SupportPackageIsVersion7
+
+// MessagecenterClient is the client API for Messagecenter service.
+//
+// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
+type MessagecenterClient interface {
+	Ping(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
+}
+
+type messagecenterClient struct {
+	cc grpc.ClientConnInterface
+}
+
+func NewMessagecenterClient(cc grpc.ClientConnInterface) MessagecenterClient {
+	return &messagecenterClient{cc}
+}
+
+func (c *messagecenterClient) Ping(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) {
+	out := new(Response)
+	err := c.cc.Invoke(ctx, "/messagecenter.Messagecenter/Ping", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+// MessagecenterServer is the server API for Messagecenter service.
+// All implementations must embed UnimplementedMessagecenterServer
+// for forward compatibility
+type MessagecenterServer interface {
+	Ping(context.Context, *Request) (*Response, error)
+	mustEmbedUnimplementedMessagecenterServer()
+}
+
+// UnimplementedMessagecenterServer must be embedded to have forward compatible implementations.
+type UnimplementedMessagecenterServer struct {
+}
+
+func (UnimplementedMessagecenterServer) Ping(context.Context, *Request) (*Response, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented")
+}
+func (UnimplementedMessagecenterServer) mustEmbedUnimplementedMessagecenterServer() {}
+
+// UnsafeMessagecenterServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to MessagecenterServer will
+// result in compilation errors.
+type UnsafeMessagecenterServer interface {
+	mustEmbedUnimplementedMessagecenterServer()
+}
+
+func RegisterMessagecenterServer(s grpc.ServiceRegistrar, srv MessagecenterServer) {
+	s.RegisterService(&Messagecenter_ServiceDesc, srv)
+}
+
+func _Messagecenter_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(Request)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(MessagecenterServer).Ping(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/messagecenter.Messagecenter/Ping",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(MessagecenterServer).Ping(ctx, req.(*Request))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+// Messagecenter_ServiceDesc is the grpc.ServiceDesc for Messagecenter service.
+// It's only intended for direct use with grpc.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var Messagecenter_ServiceDesc = grpc.ServiceDesc{
+	ServiceName: "messagecenter.Messagecenter",
+	HandlerType: (*MessagecenterServer)(nil),
+	Methods: []grpc.MethodDesc{
+		{
+			MethodName: "Ping",
+			Handler:    _Messagecenter_Ping_Handler,
+		},
+	},
+	Streams:  []grpc.StreamDesc{},
+	Metadata: "messagecenter.proto",
+}

rpc/messagecenterclient/messagecenter.go

@@ -1,50 +0,0 @@
-// Code generated by goctl. DO NOT EDIT!
-// Source: messageCenter.proto
-
-//go:generate mockgen -destination ./messagecenter_mock.go -package messagecenter -source $GOFILE
-
-package messagecenterclient
-
-import (
-	"context"
-
-	"SocialPlatform.messageCenter/rpc/messageCenter"
-
-	"github.com/zeromicro/go-zero/zrpc"
-)
-
-type (
-	GetReq    = messageCenter.GetReq
-	GetResp   = messageCenter.GetResp
-	CountReq  = messageCenter.CountReq
-	CountResp = messageCenter.CountResp
-
-	MessageCenter interface {
-		//  查询数量
-		Count(ctx context.Context, in *CountReq) (*CountResp, error)
-		//  获取消息
-		GetLast(ctx context.Context, in *GetReq) (*GetResp, error)
-	}
-
-	defaultMessageCenter struct {
-		cli zrpc.Client
-	}
-)
-
-func NewMessageCenter(cli zrpc.Client) MessageCenter {
-	return &defaultMessageCenter{
-		cli: cli,
-	}
-}
-
-//  查询数量
-func (m *defaultMessageCenter) Count(ctx context.Context, in *CountReq) (*CountResp, error) {
-	client := messageCenter.NewMessageCenterClient(m.cli.Conn())
-	return client.Count(ctx, in)
-}
-
-//  获取消息
-func (m *defaultMessageCenter) GetLast(ctx context.Context, in *GetReq) (*GetResp, error) {
-	client := messageCenter.NewMessageCenterClient(m.cli.Conn())
-	return client.GetLast(ctx, in)
-}