{"id":172047,"date":"2020-10-21T21:09:00","date_gmt":"2020-10-21T13:09:00","guid":{"rendered":"http:\/\/4563.org\/?p=172047"},"modified":"2020-10-21T21:09:00","modified_gmt":"2020-10-21T13:09:00","slug":"go-%e6%b2%a1%e6%9c%89%e6%b3%9b%e5%9e%8b%ef%bc%8c%e4%b8%9a%e5%8a%a1%e9%80%bb%e8%be%91%e7%9b%b8%e4%bc%bc%e7%9a%84-grpc-%e8%b0%83%e7%94%a8%e4%bb%a3%e7%a0%81%e5%a6%82%e4%bd%95%e8%83%bd%e6%9b%b4%e4%bc%98","status":"publish","type":"post","link":"http:\/\/4563.org\/?p=172047","title":{"rendered":"Go \u6ca1\u6709\u6cdb\u578b\uff0c\u4e1a\u52a1\u903b\u8f91\u76f8\u4f3c\u7684 grpc \u8c03\u7528\u4ee3\u7801\u5982\u4f55\u80fd\u66f4\u4f18\u96c5\u4e00\u4e9b\uff1f"},"content":{"rendered":"
\n
\n
\n

Go \u6ca1\u6709\u6cdb\u578b\uff0c\u4e1a\u52a1\u903b\u8f91\u76f8\u4f3c\u7684 grpc \u8c03\u7528\u4ee3\u7801\u5982\u4f55\u80fd\u66f4\u4f18\u96c5\u4e00\u4e9b\uff1f <\/h1>\n

<\/p>\n

\n
\u8cc7\u6df1\u5927\u4f6c : xmcy0011 <\/span> <\/i> 2<\/span> <\/div>\n
<\/div>\n<\/p><\/div>\n<\/p><\/div>\n<\/p><\/div>\n
<\/p>\n

\u6709\u4e2a gate \u7f51\u5173\uff0c\u5305\u88c5\u4e00\u5c42 grpc \u8c03\u7528 logic \u4e0a\u7684\u63a5\u53e3\uff0c\u534f\u8bae\u4f7f\u7528\u7684 protobuf \u3002\u5927\u81f4\u4e1a\u52a1\u6d41\u7a0b\u90fd\u5dee\u4e0d\u591a\uff1a 1.\u53cd\u5e8f\u5217\u5316\u6210\u5bf9\u8c61 2.\u8c03\u7528 grpc \u63a5\u53e3 3.\u6839\u636e\u7ed3\u679c\uff0c\u53d1\u9001\u5230\u5ba2\u6237\u7aef\u3002<\/p>\n

\u5177\u4f53\u4ee3\u7801\u5982\u4e0b\uff1a<\/p>\n

\/\/ \u521b\u5efa\u7fa4 func (tcp *TcpConn) onHandleCreateGroup(header *cim.ImHeader, buff []byte) {  req := &cim.CIMGroupCreateReq{}  err := proto.Unmarshal(buff, req)  if err != nil {   logger.Sugar.Warnf(\"onHandleCreateGroup error\")   return  }   logger.Sugar.Info(\"onHandleCreateGroup\")   conn := GetMessageConn()  ctx, cancelFun := context.WithTimeout(context.Background(), time.Second*3)  defer cancelFun()   rsp, err := conn.CreateGroup(ctx, req)  if err != nil {   logger.Sugar.Warnf(\"CreateGroup(gRPC) err:\", err.Error())  } else {   _, err = tcp.Send(header.SeqNum, uint16(GROUP_CREATE_DEFAULT_REQ), rsp)   logger.Sugar.Infof(\"onHandleCreateGroup CreateGroup(gRPC) res\")  } }  \/\/ \u89e3\u6563\u7fa4 func (tcp *TcpConn) onHandleDisbandingGroup(header *cim.ImHeader, buff []byte) {  req := &cim.CIMGroupDisbandingReq{}  err := proto.Unmarshal(buff, req)  if err != nil {   logger.Sugar.Warnf(\"onHandleDisbandingGroup error\")   return  }   logger.Sugar.Info(\"onHandleDisbandingGroup\")   conn := GetMessageConn()  ctx, cancelFun := context.WithTimeout(context.Background(), time.Second*3)  defer cancelFun()   rsp, err := conn.DisbandingGroup(ctx, req)  if err != nil {   logger.Sugar.Warnf(\"DisbandingGroup(gRPC) err:\")  } else {   _, err = tcp.Send(header.SeqNum, uint16(GROUP_DISBINGDING_RSP), rsp)   logger.Sugar.Infof(\"onHandleDisbandingGroup res\")  } } <\/code><\/pre>\n<\/p><\/div>\n
 \u5927\u4f6c\u6709\u8a71\u8aaa<\/b> (13<\/span>)        <\/div>\n
 <\/div>\n<\/p><\/div>\n<\/p><\/div>\n
    \n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : BoarBoar <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u4e00\u822c\u90fd\u662f interface{}\u4ee3\u66ff\u6cdb\u578b\uff0c\u4e0d\u8fc7\u4f1a\u5199\u5f88\u591a\u7528\u53cd\u5c04\u6216\u8005\u65ad\u8a00\u53bb\u5224\u65ad interface \u6301\u6709\u7c7b\u578b\u7684\u4ee3\u7801\uff0c\u7528\u5f97\u5c11\u7684\u8bdd\u6ca1\u5fc5\u8981\u641e                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : lance6716 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u6211\u5f53\u65f6\u7528\u7684\u8fd0\u884c\u65f6\u548c\u53cd\u5c04\u3002\u5f53\u65f6\u4e5f\u8003\u8651\u8fc7 go generate template\u2026                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : fuis <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @xmcy0011 \u968f\u624b\u5199\u4e86\u4e00\u6bb5\uff0c\u5927\u6982\u770b\u4e2a\u610f\u601d\u3002\u57fa\u672c\u601d\u8def\u5c31\u662f\u628a\u91cd\u590d\u7684\u5730\u65b9\u62a0\u51fa\u6765\u505a\u6210 func\uff0c\u7136\u540e\u7528\u53e6\u4e00\u4e2a helper func \u53bb\u8c03\u7528\u5b83\u4eec\u3002\u53c2\u6570\u5c3d\u91cf\u770b\u51c6\u539f\u6765\u5c31\u4f7f\u7528 interface{} \u7684\u5730\u65b9\uff0c\u8fd9\u6837\u4e0d\u7528\u5199\u5f88\u591a type assert<\/p>\n
    “`go
    func (tcp *TcpConn) onHandleCreateGroup(header *cim.ImHeader, buff []byte) {
     req := &cim.CIMGroupCreateReq{}
     call(header, buff, req, func() {
     return conn.CreateGroup(ctx, req)
     }, func(rsp Response) {
     _, err = tcp.Send(…)
     })
    }<\/p>\n
    func (tcp *TcpConn) onHandleDisbandingGroup(header *cim.ImHeader, buff []byte) {
     req := &cim.CIMGroupDisbandingReq{}
     call(header, buff, req, func () {
     return conn.DisbandingGroup(ctx, req)
     }, func(rsp Response) {
     _, err = tcp.Send(…)
     })
    }<\/p>\n
    func (t *TcpConn) call(
     header *cim.ImHeader,
     buff []byte,
     req interface{},
     method string,
     rpcFn func(context.Context, interface{}) (Response, error),
     callback func(Response) error) func() {
     return func() {
     err := proto.Unmarshal(buff, req)
     if err != nil {
     logger.Sugar.Warnf(“%s error”, method)
     return
     }<\/p>\n
     logger.Sugar.Info(method)<\/p>\n
     conn := GetMessageConn()
     ctx, cancelFun := context.WithTimeout(context.Background(), time.Second*3)
     defer cancelFun()<\/p>\n
     rsp, err := rpcFn(ctx, req)
     if err != nil {
     logger.Sugar.Warnf(“DisbandingGroup(gRPC) err:”)
     } else {
     _, err := callback(rsp)
     logger.Sugar.Infof(“onHandleDisbandingGroup res”)
     }
     }
    }<\/p>\n
    “`                                                            <\/p><\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : hakono <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u53cd\u5c04\u4f1a\u5f71\u54cd\u7a0b\u5e8f\u6027\u80fd                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : beidounanxizi <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u522b\u6574\u53cd\u5c04 \u53bb\u770b\u770b go proverb 
    \u6cdb\u578b \u53bb\u7528\u56de JAVA \u5427 
    \u6ca1\u6cdb\u578b \u66f4\u4f18\u96c5                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : deepreader <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u7b49 go 1.15 \u652f\u6301\u6cdb\u578b\u5427 https:\/\/blog.golang.org\/why-generics                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : raaaaaar <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u5728\u5199\u4e86\u5728\u5199\u4e86\uff0c\u522b\u50ac                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : xuanbg <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u7528\u4e0d\u7740\u6cdb\u578b\uff0clog \u7684\u5185\u5bb9\u53ef\u4ee5\u53c2\u6570\u62fc\u63a5\uff0c\u53d1\u9001\u7684\u5185\u5bb9\u53ef\u4ee5\u5148\u5e8f\u5217\u5316\u518d\u4f5c\u4e3a\u53c2\u6570\u4f20\u5165\u8fdb\u884c\u53d1\u9001\u3002\u4f60\u9700\u8981\u7684\u53ea\u662f\u5206\u62c6\u51e0\u4e2a\u9759\u6001\u65b9\u6cd5\u800c\u5df2\u3002                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : eudore <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u4e0d\u662f\u6709 pb \u63d2\u4ef6\u81ea\u52a8\u751f\u6210\u7684\u8c03\u7528\u4ee3\u7801\uff1f \u4f60\u8fd8\u81ea\u5df1\u624b\u5199\u4e2a\u5565                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : zunceng <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u6211\u5728\u81ea\u5df1\u7684 infra \u91cc\u9762\u5199\u4e86\u4e2a\u4ee3\u7801\u751f\u6210\u7684\u811a\u672c                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : mikulch <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @beidounanxizi \u5df2\u7ecf\u5728\u505a\u4e86\uff0c\u8fd9\u4e2a\u8bed\u6cd5\u3002                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : joesonw <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u81ea\u5df1\u5199\u4e2a protoc-plugin \u8fdb\u53bb, \u751f\u6210 go \u4ee3\u7801?                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : troywinter <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u4f20\u4e2a\u95ed\u5305\u8fdb\u6765\uff0c\u7528\u6237\u4f7f\u7528\u65f6\uff0c\u5728 func \u91cc\u81ea\u5df1 cast \u5230\u60f3\u8981\u7684\u7c7b\u578b\uff0c\u7a0d\u5fae\u5570\u55e6\u4e00\u4e24\u884c\u3002                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n","protected":false},"excerpt":{"rendered":"
    Go \u6ca1\u6709\u6cdb\u578b\uff0c\u4e1a\u52a1\u903b\u8f91\u76f8\u4f3c\u7684 g…<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[],"tags":[],"_links":{"self":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/172047"}],"collection":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=172047"}],"version-history":[{"count":0,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/172047\/revisions"}],"wp:attachment":[{"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=172047"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=172047"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=172047"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}