{"id":24710,"date":"2021-11-28T16:36:11","date_gmt":"2021-11-28T08:36:11","guid":{"rendered":"https:\/\/aqzt.com\/24710.html"},"modified":"2021-11-28T16:36:11","modified_gmt":"2021-11-28T08:36:11","slug":"go-kit%e5%ae%9e%e8%b7%b5%e4%b9%8b1%ef%bc%9ago-kit-%e4%b8%8e-grpc-%e7%bb%93%e5%90%88%e5%bc%80%e5%8f%91%e5%be%ae%e6%9c%8d%e5%8a%a1%ef%bc%88go-kit-endpoint%e7%9a%84%e4%bd%bf%e7%94%a8%ef%bc%89-2","status":"publish","type":"post","link":"https:\/\/aqzt.com\/24710.html","title":{"rendered":"go-kit\u5b9e\u8df5\u4e4b1\uff1ago-kit \u4e0e grpc \u7ed3\u5408\u5f00\u53d1\u5fae\u670d\u52a1\uff08go-kit endpoint\u7684\u4f7f\u7528\uff09"},"content":{"rendered":"

go-kit<\/strong>\u00a0\u662f\u4e00\u4e2a\u5fae\u670d\u52a1\u7684\u5f00\u53d1\u5de5\u5177\u96c6\uff0c\u5fae\u670d\u52a1\u7cfb\u7edf\u4e2d\u7684\u5927\u591a\u6570\u5e38\u89c1\u95ee\u9898\uff0c\u56e0\u6b64\uff0c\u4f7f\u7528\u8005\u53ef\u4ee5\u5c06\u7cbe\u529b\u96c6\u4e2d\u5728\u4e1a\u52a1\u903b\u8f91\u4e0a\u3002<\/p>\n<\/p>\n

grpc\u7f3a\u4e4f\u670d\u52a1\u6cbb\u7406\u7684\u529f\u80fd\uff0c\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7go-kit\u7ed3\u5408grpc\u6765\u5b9e\u73b0\u6211\u4eec\u7684\u5b8c\u6574\u9700\u6c42\u3002go-kit\u62bd\u8c61\u7684endpoint\u8bbe\u8ba1\u8ba9\u6211\u4eec\u53ef\u4ee5\u5f88\u5bb9\u6613\u5305\u88c5\u5176\u5b83\u5fae\u670d\u52a1\u6846\u67b6\u4f7f\u7528\u7684\u534f\u8bae\u3002
\nendpoint\u4e3aServers\u548cClients\u63d0\u4f9b\u4e86\u57fa\u4e8eRPC\u65b9\u6cd5\u7684\u6784\u5efa\u6a21\u5757\u3002<\/strong><\/p>\n

\u5148\u6765\u770b\u770bendpoint\u6e90\u7801\uff1a<\/p>\n

\n\n
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
<\/div><\/td>
1package endpoint
\n2
\n3import (
\n4   &quot;context&quot;
\n5)
\n6
\n7\/\/ Endpoint is the fundamental building block of servers and clients.
\n8\/\/ It represents a single RPC method.
\n9type Endpoint func(ctx context.Context, request interface{}) (response interface{}, err error)
\n10
\n11\/\/ Nop is an endpoint that does nothing and returns a nil error.
\n12\/\/ Useful for tests.
\n13func Nop(context.Context, interface{}) (interface{}, error) { return struct{}{}, nil }
\n14
\n15\/\/ Middleware is a chainable behavior modifier for endpoints.
\n16type Middleware func(Endpoint) Endpoint
\n17
\n18\/\/ Chain is a helper function for composing middlewares. Requests will
\n19\/\/ traverse them in the order they&#x27;re declared. That is, the first middleware
\n20\/\/ is treated as the outermost middleware.
\n21func Chain(outer Middleware, others ...Middleware) Middleware {
\n22  return func(next Endpoint) Endpoint {
\n23      for i := len(others) - 1; i &gt;= 0; i-- { \/\/ reverse
\n24          next = others[i](next)
\n25      }
\n26      return outer(next)
\n27  }
\n28}
\n29
\n30\/\/ Failer may be implemented by Go kit response types that contain business
\n31\/\/ logic error details. If Failed returns a non-nil error, the Go kit transport
\n32\/\/ layer may interpret this as a business logic error, and may encode it
\n33\/\/ differently than a regular, successful response.
\n34\/\/
\n35\/\/ It&#x27;s not necessary for your response types to implement Failer, but it may
\n36\/\/ help for more sophisticated use cases. The addsvc example shows how Failer
\n37\/\/ should be used by a complete application.
\n38type Failer interface {
\n39  Failed() error
\n40}
\n41
\n42<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n\n<\/pre>\n
go-kit\u63d0\u4f9b\u4ee5\u4e0b\u529f\u80fd\uff1a<\/strong><\/p>\n
1\u3001Circuit breaker\uff08\u7194\u65ad\u5668\uff09<\/p>\n
2\u3001Rate limiter\uff08\u9650\u6d41\u5668\uff09<\/p>\n
3\u3001Logging\uff08\u65e5\u5fd7\uff09<\/p>\n
4\u3001Metrics\uff08Prometheus\u7edf\u8ba1\uff09<\/p>\n
5\u3001Request tracing\uff08\u8bf7\u6c42\u8ddf\u8e2a\uff09<\/p>\n
6\u3001Service discovery and load balancing\uff08\u670d\u52a1\u53d1\u73b0\u548c\u8d1f\u8f7d\u5747\u8861\uff09<\/p>\n
1\u3001\u5b89\u88c5go-kit\u5305<\/h3>\n
\n\n
1
2
<\/div><\/td>
1git clone https:\/\/github.com\/go-kit\/kit.git
\n2<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n\n<\/pre>\n
\u653e\u5165\u5230\u5bf9\u5e94\u7684gopath\u76ee\u5f55\u4e0b\u3002<\/p>\n
2\u3001protobuf\u6587\u4ef6<\/h3>\n
\n\n
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
<\/div><\/td>
1syntax = &quot;proto3&quot;;
\n2
\n3\/\/ \u8bf7\u6c42\u4e66\u8be6\u60c5\u7684\u53c2\u6570\u7ed3\u6784  book_id 32\u4f4d\u6574\u5f62
\n4message BookInfoParams {
\n5    int32 book_id = 1;
\n6}
\n7
\n8
\n9\/\/ \u4e66\u8be6\u60c5\u4fe1\u606f\u7684\u7ed3\u6784   book_name\u5b57\u7b26\u4e32\u7c7b\u578b
\n10message BookInfo {
\n11    int32 book_id = 1;
\n12    string  book_name = 2;
\n13}
\n14
\n15\/\/ \u8bf7\u6c42\u4e66\u5217\u8868\u7684\u53c2\u6570\u7ed3\u6784  page\u3001limit   32\u4f4d\u6574\u5f62
\n16message BookListParams {
\n17    int32 page = 1;
\n18    int32 limit = 2;
\n19}
\n20
\n21
\n22\/\/ \u4e66\u5217\u8868\u7684\u7ed3\u6784    BookInfo\u7ed3\u6784\u6570\u7ec4
\n23message BookList {
\n24    repeated BookInfo book_list = 1;
\n25}
\n26\/\/ \u5b9a\u4e49 \u83b7\u53d6\u4e66\u8be6\u60c5  \u548c \u4e66\u5217\u8868\u670d\u52a1   \u5165\u53c2\u51fa\u53c2\u5206\u522b\u4e3a\u4e0a\u9762\u6240\u5b9a\u4e49\u7684\u7ed3\u6784
\n27service BookService {
\n28    rpc GetBookInfo (BookInfoParams) returns (BookInfo) {}
\n29    rpc GetBookList (BookListParams) returns (BookList) {}
\n30}
\n31<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n\n<\/pre>\n
\u751f\u6210\u5bf9\u5e94\u7684go\u8bed\u8a00\u4ee3\u7801\u6587\u4ef6\uff1aprotoc –go_out=plugins=grpc:. book.proto\u00a0 \uff08\u5176\u4e2d\uff1aprotobuf\u6587\u4ef6\u540d\u4e3a\uff1abook.proto\uff09,\u751f\u6210\u7684\u4ee3\u7801\u5982\u4e0b\uff1a<\/p>\n
\n\n
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
<\/div><\/td>
1\/\/ Code generated by protoc-gen-go. DO NOT EDIT.
\n2\/\/ source: book.proto
\n3
\n4package book
\n5
\n6import (
\n7   context &quot;context&quot;
\n8   fmt &quot;fmt&quot;
\n9   proto &quot;github.com\/golang\/protobuf\/proto&quot;
\n10  grpc &quot;google.golang.org\/grpc&quot;
\n11  codes &quot;google.golang.org\/grpc\/codes&quot;
\n12  status &quot;google.golang.org\/grpc\/status&quot;
\n13  math &quot;math&quot;
\n14)
\n15
\n16\/\/ Reference imports to suppress errors if they are not otherwise used.
\n17var _ = proto.Marshal
\n18var _ = fmt.Errorf
\n19var _ = math.Inf
\n20
\n21\/\/ This is a compile-time assertion to ensure that this generated file
\n22\/\/ is compatible with the proto package it is being compiled against.
\n23\/\/ A compilation error at this line likely means your copy of the
\n24\/\/ proto package needs to be updated.
\n25const _ = proto.ProtoPackageIsVersion3 \/\/ please upgrade the proto package
\n26
\n27\/\/ \u8bf7\u6c42\u4e66\u8be6\u60c5\u7684\u53c2\u6570\u7ed3\u6784  book_id 32\u4f4d\u6574\u5f62
\n28type BookInfoParams struct {
\n29  BookId               int32    `protobuf:&quot;varint,1,opt,name=book_id,json=bookId,proto3&quot; json:&quot;book_id,omitempty&quot;`
\n30  XXX_NoUnkeyedLiteral struct{} `json:&quot;-&quot;`
\n31  XXX_unrecognized     []byte   `json:&quot;-&quot;`
\n32  XXX_sizecache        int32    `json:&quot;-&quot;`
\n33}
\n34
\n35func (m *BookInfoParams) Reset()         { *m = BookInfoParams{} }
\n36func (m *BookInfoParams) String() string { return proto.CompactTextString(m) }
\n37func (*BookInfoParams) ProtoMessage()    {}
\n38func (*BookInfoParams) Descriptor() ([]byte, []int) {
\n39  return fileDescriptor_1e89d0eaa98dc5d8, []int{0}
\n40}
\n41
\n42func (m *BookInfoParams) XXX_Unmarshal(b []byte) error {
\n43  return xxx_messageInfo_BookInfoParams.Unmarshal(m, b)
\n44}
\n45func (m *BookInfoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
\n46  return xxx_messageInfo_BookInfoParams.Marshal(b, m, deterministic)
\n47}
\n48func (m *BookInfoParams) XXX_Merge(src proto.Message) {
\n49  xxx_messageInfo_BookInfoParams.Merge(m, src)
\n50}
\n51func (m *BookInfoParams) XXX_Size() int {
\n52  return xxx_messageInfo_BookInfoParams.Size(m)
\n53}
\n54func (m *BookInfoParams) XXX_DiscardUnknown() {
\n55  xxx_messageInfo_BookInfoParams.DiscardUnknown(m)
\n56}
\n57
\n58var xxx_messageInfo_BookInfoParams proto.InternalMessageInfo
\n59
\n60func (m *BookInfoParams) GetBookId() int32 {
\n61  if m != nil {
\n62      return m.BookId
\n63  }
\n64  return 0
\n65}
\n66
\n67\/\/ \u4e66\u8be6\u60c5\u4fe1\u606f\u7684\u7ed3\u6784   book_name\u5b57\u7b26\u4e32\u7c7b\u578b
\n68type BookInfo struct {
\n69  BookId               int32    `protobuf:&quot;varint,1,opt,name=book_id,json=bookId,proto3&quot; json:&quot;book_id,omitempty&quot;`
\n70  BookName             string   `protobuf:&quot;bytes,2,opt,name=book_name,json=bookName,proto3&quot; json:&quot;book_name,omitempty&quot;`
\n71  XXX_NoUnkeyedLiteral struct{} `json:&quot;-&quot;`
\n72  XXX_unrecognized     []byte   `json:&quot;-&quot;`
\n73  XXX_sizecache        int32    `json:&quot;-&quot;`
\n74}
\n75
\n76func (m *BookInfo) Reset()         { *m = BookInfo{} }
\n77func (m *BookInfo) String() string { return proto.CompactTextString(m) }
\n78func (*BookInfo) ProtoMessage()    {}
\n79func (*BookInfo) Descriptor() ([]byte, []int) {
\n80  return fileDescriptor_1e89d0eaa98dc5d8, []int{1}
\n81}
\n82
\n83func (m *BookInfo) XXX_Unmarshal(b []byte) error {
\n84  return xxx_messageInfo_BookInfo.Unmarshal(m, b)
\n85}
\n86func (m *BookInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
\n87  return xxx_messageInfo_BookInfo.Marshal(b, m, deterministic)
\n88}
\n89func (m *BookInfo) XXX_Merge(src proto.Message) {
\n90  xxx_messageInfo_BookInfo.Merge(m, src)
\n91}
\n92func (m *BookInfo) XXX_Size() int {
\n93  return xxx_messageInfo_BookInfo.Size(m)
\n94}
\n95func (m *BookInfo) XXX_DiscardUnknown() {
\n96  xxx_messageInfo_BookInfo.DiscardUnknown(m)
\n97}
\n98
\n99var xxx_messageInfo_BookInfo proto.InternalMessageInfo
\n100
\n101func (m *BookInfo) GetBookId() int32 {
\n102 if m != nil {
\n103     return m.BookId
\n104 }
\n105 return 0
\n106}
\n107
\n108func (m *BookInfo) GetBookName() string {
\n109 if m != nil {
\n110     return m.BookName
\n111 }
\n112 return &quot;&quot;
\n113}
\n114
\n115\/\/ \u8bf7\u6c42\u4e66\u5217\u8868\u7684\u53c2\u6570\u7ed3\u6784  page\u3001limit   32\u4f4d\u6574\u5f62
\n116type BookListParams struct {
\n117 Page                 int32    `protobuf:&quot;varint,1,opt,name=page,proto3&quot; json:&quot;page,omitempty&quot;`
\n118 Limit                int32    `protobuf:&quot;varint,2,opt,name=limit,proto3&quot; json:&quot;limit,omitempty&quot;`
\n119 XXX_NoUnkeyedLiteral struct{} `json:&quot;-&quot;`
\n120 XXX_unrecognized     []byte   `json:&quot;-&quot;`
\n121 XXX_sizecache        int32    `json:&quot;-&quot;`
\n122}
\n123
\n124func (m *BookListParams) Reset()         { *m = BookListParams{} }
\n125func (m *BookListParams) String() string { return proto.CompactTextString(m) }
\n126func (*BookListParams) ProtoMessage()    {}
\n127func (*BookListParams) Descriptor() ([]byte, []int) {
\n128 return fileDescriptor_1e89d0eaa98dc5d8, []int{2}
\n129}
\n130
\n131func (m *BookListParams) XXX_Unmarshal(b []byte) error {
\n132 return xxx_messageInfo_BookListParams.Unmarshal(m, b)
\n133}
\n134func (m *BookListParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
\n135 return xxx_messageInfo_BookListParams.Marshal(b, m, deterministic)
\n136}
\n137func (m *BookListParams) XXX_Merge(src proto.Message) {
\n138 xxx_messageInfo_BookListParams.Merge(m, src)
\n139}
\n140func (m *BookListParams) XXX_Size() int {
\n141 return xxx_messageInfo_BookListParams.Size(m)
\n142}
\n143func (m *BookListParams) XXX_DiscardUnknown() {
\n144 xxx_messageInfo_BookListParams.DiscardUnknown(m)
\n145}
\n146
\n147var xxx_messageInfo_BookListParams proto.InternalMessageInfo
\n148
\n149func (m *BookListParams) GetPage() int32 {
\n150 if m != nil {
\n151     return m.Page
\n152 }
\n153 return 0
\n154}
\n155
\n156func (m *BookListParams) GetLimit() int32 {
\n157 if m != nil {
\n158     return m.Limit
\n159 }
\n160 return 0
\n161}
\n162
\n163\/\/ \u4e66\u5217\u8868\u7684\u7ed3\u6784    BookInfo\u7ed3\u6784\u6570\u7ec4
\n164type BookList struct {
\n165 BookList             []*BookInfo `protobuf:&quot;bytes,1,rep,name=book_list,json=bookList,proto3&quot; json:&quot;book_list,omitempty&quot;`
\n166 XXX_NoUnkeyedLiteral struct{}    `json:&quot;-&quot;`
\n167 XXX_unrecognized     []byte      `json:&quot;-&quot;`
\n168 XXX_sizecache        int32       `json:&quot;-&quot;`
\n169}
\n170
\n171func (m *BookList) Reset()         { *m = BookList{} }
\n172func (m *BookList) String() string { return proto.CompactTextString(m) }
\n173func (*BookList) ProtoMessage()    {}
\n174func (*BookList) Descriptor() ([]byte, []int) {
\n175 return fileDescriptor_1e89d0eaa98dc5d8, []int{3}
\n176}
\n177
\n178func (m *BookList) XXX_Unmarshal(b []byte) error {
\n179 return xxx_messageInfo_BookList.Unmarshal(m, b)
\n180}
\n181func (m *BookList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
\n182 return xxx_messageInfo_BookList.Marshal(b, m, deterministic)
\n183}
\n184func (m *BookList) XXX_Merge(src proto.Message) {
\n185 xxx_messageInfo_BookList.Merge(m, src)
\n186}
\n187func (m *BookList) XXX_Size() int {
\n188 return xxx_messageInfo_BookList.Size(m)
\n189}
\n190func (m *BookList) XXX_DiscardUnknown() {
\n191 xxx_messageInfo_BookList.DiscardUnknown(m)
\n192}
\n193
\n194var xxx_messageInfo_BookList proto.InternalMessageInfo
\n195
\n196func (m *BookList) GetBookList() []*BookInfo {
\n197 if m != nil {
\n198     return m.BookList
\n199 }
\n200 return nil
\n201}
\n202
\n203func init() {
\n204 proto.RegisterType((*BookInfoParams)(nil), &quot;BookInfoParams&quot;)
\n205 proto.RegisterType((*BookInfo)(nil), &quot;BookInfo&quot;)
\n206 proto.RegisterType((*BookListParams)(nil), &quot;BookListParams&quot;)
\n207 proto.RegisterType((*BookList)(nil), &quot;BookList&quot;)
\n208}
\n209
\n210func init() { proto.RegisterFile(&quot;book.proto&quot;, fileDescriptor_1e89d0eaa98dc5d8) }
\n211
\n212var fileDescriptor_1e89d0eaa98dc5d8 = []byte{
\n213 \/\/ 224 bytes of a gzipped FileDescriptorProto
\n214 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x4a, 0xca, 0xcf, 0xcf,
\n215 0xd6, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x57, 0xd2, 0xe4, 0xe2, 0x73, 0xca, 0xcf, 0xcf, 0xf6, 0xcc,
\n216 0x4b, 0xcb, 0x0f, 0x48, 0x2c, 0x4a, 0xcc, 0x2d, 0x16, 0x12, 0xe7, 0x62, 0x07, 0xc9, 0xc7, 0x67,
\n217 0xa6, 0x48, 0x30, 0x2a, 0x30, 0x6a, 0xb0, 0x06, 0xb1, 0x81, 0xb8, 0x9e, 0x29, 0x4a, 0x0e, 0x5c,
\n218 0x1c, 0x30, 0xa5, 0x38, 0x15, 0x09, 0x49, 0x73, 0x71, 0x82, 0x25, 0xf2, 0x12, 0x73, 0x53, 0x25,
\n219 0x98, 0x14, 0x18, 0x35, 0x38, 0x83, 0x38, 0x40, 0x02, 0x7e, 0x89, 0xb9, 0xa9, 0x4a, 0x56, 0x10,
\n220 0xcb, 0x7c, 0x32, 0x8b, 0x4b, 0xa0, 0x96, 0x09, 0x71, 0xb1, 0x14, 0x24, 0xa6, 0xa7, 0x42, 0x0d,
\n221 0x01, 0xb3, 0x85, 0x44, 0xb8, 0x58, 0x73, 0x32, 0x73, 0x33, 0x4b, 0xc0, 0xda, 0x59, 0x83, 0x20,
\n222 0x1c, 0x25, 0x23, 0x88, 0xed, 0x20, 0xbd, 0x42, 0x6a, 0x50, 0x4b, 0x72, 0x32, 0x8b, 0x4b, 0x24,
\n223 0x18, 0x15, 0x98, 0x35, 0xb8, 0x8d, 0x38, 0xf5, 0x60, 0x6e, 0x83, 0xd8, 0x07, 0x52, 0x67, 0x94,
\n224 0xce, 0xc5, 0x0d, 0x12, 0x0d, 0x4e, 0x2d, 0x2a, 0xcb, 0x4c, 0x4e, 0x15, 0xd2, 0xe6, 0xe2, 0x76,
\n225 0x4f, 0x2d, 0x81, 0xfb, 0x81, 0x5f, 0x0f, 0xd5, 0xe7, 0x52, 0x08, 0x33, 0x94, 0x18, 0x90, 0x14,
\n226 0x83, 0xad, 0x84, 0x28, 0x46, 0xb8, 0x1c, 0xaa, 0x18, 0x24, 0xa0, 0xc4, 0x90, 0xc4, 0x06, 0x0e,
\n227 0x4c, 0x63, 0x40, 0x00, 0x00, 0x00, 0xff, 0xff, 0x3e, 0x22, 0x2f, 0xab, 0x5a, 0x01, 0x00, 0x00,
\n228}
\n229
\n230\/\/ Reference imports to suppress errors if they are not otherwise used.
\n231var _ context.Context
\n232var _ grpc.ClientConn
\n233
\n234\/\/ This is a compile-time assertion to ensure that this generated file
\n235\/\/ is compatible with the grpc package it is being compiled against.
\n236const _ = grpc.SupportPackageIsVersion4
\n237
\n238\/\/ BookServiceClient is the client API for BookService service.
\n239\/\/
\n240\/\/ For semantics around ctx use and closing\/ending streaming RPCs, please refer to https:\/\/godoc.org\/google.golang.org\/grpc#ClientConn.NewStream.
\n241type BookServiceClient interface {
\n242 GetBookInfo(ctx context.Context, in *BookInfoParams, opts ...grpc.CallOption) (*BookInfo, error)
\n243 GetBookList(ctx context.Context, in *BookListParams, opts ...grpc.CallOption) (*BookList, error)
\n244}
\n245
\n246type bookServiceClient struct {
\n247 cc *grpc.ClientConn
\n248}
\n249
\n250func NewBookServiceClient(cc *grpc.ClientConn) BookServiceClient {
\n251 return &amp;bookServiceClient{cc}
\n252}
\n253
\n254func (c *bookServiceClient) GetBookInfo(ctx context.Context, in *BookInfoParams, opts ...grpc.CallOption) (*BookInfo, error) {
\n255 out := new(BookInfo)
\n256 err := c.cc.Invoke(ctx, &quot;\/BookService\/GetBookInfo&quot;, in, out, opts...)
\n257 if err != nil {
\n258     return nil, err
\n259 }
\n260 return out, nil
\n261}
\n262
\n263func (c *bookServiceClient) GetBookList(ctx context.Context, in *BookListParams, opts ...grpc.CallOption) (*BookList, error) {
\n264 out := new(BookList)
\n265 err := c.cc.Invoke(ctx, &quot;\/BookService\/GetBookList&quot;, in, out, opts...)
\n266 if err != nil {
\n267     return nil, err
\n268 }
\n269 return out, nil
\n270}
\n271
\n272\/\/ BookServiceServer is the server API for BookService service.
\n273type BookServiceServer interface {
\n274 GetBookInfo(context.Context, *BookInfoParams) (*BookInfo, error)
\n275 GetBookList(context.Context, *BookListParams) (*BookList, error)
\n276}
\n277
\n278\/\/ UnimplementedBookServiceServer can be embedded to have forward compatible implementations.
\n279type UnimplementedBookServiceServer struct {
\n280}
\n281
\n282func (*UnimplementedBookServiceServer) GetBookInfo(ctx context.Context, req *BookInfoParams) (*BookInfo, error) {
\n283 return nil, status.Errorf(codes.Unimplemented, &quot;method GetBookInfo not implemented&quot;)
\n284}
\n285func (*UnimplementedBookServiceServer) GetBookList(ctx context.Context, req *BookListParams) (*BookList, error) {
\n286 return nil, status.Errorf(codes.Unimplemented, &quot;method GetBookList not implemented&quot;)
\n287}
\n288
\n289func RegisterBookServiceServer(s *grpc.Server, srv BookServiceServer) {
\n290 s.RegisterService(&amp;_BookService_serviceDesc, srv)
\n291}
\n292
\n293func _BookService_GetBookInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
\n294 in := new(BookInfoParams)
\n295 if err := dec(in); err != nil {
\n296     return nil, err
\n297 }
\n298 if interceptor == nil {
\n299     return srv.(BookServiceServer).GetBookInfo(ctx, in)
\n300 }
\n301 info := &amp;grpc.UnaryServerInfo{
\n302     Server:     srv,
\n303     FullMethod: &quot;\/BookService\/GetBookInfo&quot;,
\n304 }
\n305 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
\n306     return srv.(BookServiceServer).GetBookInfo(ctx, req.(*BookInfoParams))
\n307 }
\n308 return interceptor(ctx, in, info, handler)
\n309}
\n310
\n311func _BookService_GetBookList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
\n312 in := new(BookListParams)
\n313 if err := dec(in); err != nil {
\n314     return nil, err
\n315 }
\n316 if interceptor == nil {
\n317     return srv.(BookServiceServer).GetBookList(ctx, in)
\n318 }
\n319 info := &amp;grpc.UnaryServerInfo{
\n320     Server:     srv,
\n321     FullMethod: &quot;\/BookService\/GetBookList&quot;,
\n322 }
\n323 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
\n324     return srv.(BookServiceServer).GetBookList(ctx, req.(*BookListParams))
\n325 }
\n326 return interceptor(ctx, in, info, handler)
\n327}
\n328
\n329var _BookService_serviceDesc = grpc.ServiceDesc{
\n330 ServiceName: &quot;BookService&quot;,
\n331 HandlerType: (*BookServiceServer)(nil),
\n332 Methods: []grpc.MethodDesc{
\n333     {
\n334         MethodName: &quot;GetBookInfo&quot;,
\n335         Handler:    _BookService_GetBookInfo_Handler,
\n336     },
\n337     {
\n338         MethodName: &quot;GetBookList&quot;,
\n339         Handler:    _BookService_GetBookList_Handler,
\n340     },
\n341 },
\n342 Streams:  []grpc.StreamDesc{},
\n343 Metadata: &quot;book.proto&quot;,
\n344}
\n345
\n346<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n\n<\/pre>\n
3\u3001\u670d\u52a1\u5668\u7aef\u4ee3\u7801<\/h3>\n
\n\n
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
<\/div><\/td>
1package main
\n2
\n3import (
\n4   &quot;MyKit&quot; \/\/import book.pb.go(protoc \u751f\u6210\u7684\u6587\u4ef6)
\n5   &quot;context&quot;
\n6   &quot;github.com\/go-kit\/kit\/endpoint&quot;
\n7   grpc_transport &quot;github.com\/go-kit\/kit\/transport\/grpc&quot;
\n8   &quot;google.golang.org\/grpc&quot;
\n9   &quot;net&quot;
\n10)
\n11
\n12type BookServer struct {
\n13  bookListHandler grpc_transport.Handler
\n14  bookInfoHandler grpc_transport.Handler
\n15}
\n16
\n17\/\/\u901a\u8fc7grpc\u8c03\u7528GetBookInfo\u65f6,GetBookInfo\u53ea\u505a\u6570\u636e\u900f\u4f20, \u8c03\u7528BookServer\u4e2d\u5bf9\u5e94Handler.ServeGRPC\u8f6c\u4ea4\u7ed9go-kit\u5904\u7406
\n18func (s *BookServer) GetBookInfo(ctx context.Context, in *book.BookInfoParams) (*book.BookInfo, error) {
\n19  _, rsp, err := s.bookInfoHandler.ServeGRPC(ctx, in)
\n20  if err != nil {
\n21      return nil, err
\n22  }
\n23  return rsp.(*book.BookInfo), err
\n24}
\n25
\n26\/\/\u901a\u8fc7grpc\u8c03\u7528GetBookList\u65f6,GetBookList\u53ea\u505a\u6570\u636e\u900f\u4f20, \u8c03\u7528BookServer\u4e2d\u5bf9\u5e94Handler.ServeGRPC\u8f6c\u4ea4\u7ed9go-kit\u5904\u7406
\n27func (s *BookServer) GetBookList(ctx context.Context, in *book.BookListParams) (*book.BookList, error) {
\n28  _, rsp, err := s.bookListHandler.ServeGRPC(ctx, in)
\n29  if err != nil {
\n30      return nil, err
\n31  }
\n32  return rsp.(*book.BookList), err
\n33}
\n34
\n35\/\/\u521b\u5efabookList\u7684EndPoint
\n36func makeGetBookListEndpoint() endpoint.Endpoint {
\n37  return func(ctx context.Context, request interface{}) (interface{}, error) {
\n38      \/\/\u8bf7\u6c42\u5217\u8868\u65f6\u8fd4\u56de \u4e66\u7c4d\u5217\u8868
\n39      bl := new(book.BookList)
\n40      bl.BookList = append(bl.BookList, &amp;book.BookInfo{BookId: 1, BookName: &quot;Go\u5165\u95e8\u5230\u7cbe\u901a&quot;})
\n41      bl.BookList = append(bl.BookList, &amp;book.BookInfo{BookId: 2, BookName: &quot;go-kit\u5165\u95e8\u5230\u7cbe\u901a&quot;})
\n42      bl.BookList = append(bl.BookList, &amp;book.BookInfo{BookId: 2, BookName: &quot;go-micro\u5165\u95e8\u5230\u7cbe\u901a&quot;})
\n43      return bl, nil
\n44  }
\n45}
\n46
\n47\/\/\u521b\u5efabookInfo\u7684EndPoint
\n48func makeGetBookInfoEndpoint() endpoint.Endpoint {
\n49  return func(ctx context.Context, request interface{}) (interface{}, error) {
\n50      \/\/\u8bf7\u6c42\u8be6\u60c5\u65f6\u8fd4\u56de \u4e66\u7c4d\u4fe1\u606f
\n51      req := request.(*book.BookInfoParams)
\n52      b := new(book.BookInfo)
\n53      b.BookId = req.BookId
\n54      b.BookName = &quot;Go\u4e0e\u5fae\u670d\u52a1&quot;
\n55      return b, nil
\n56  }
\n57}
\n58
\n59func decodeRequest(_ context.Context, req interface{}) (interface{}, error) {
\n60  return req, nil
\n61}
\n62
\n63func encodeResponse(_ context.Context, req interface{}) (interface{}, error) {
\n64  return req, nil
\n65}
\n66
\n67func main() {
\n68  \/\/\u5305\u88c5BookServer
\n69
\n70  bookServer := new(BookServer)
\n71  \/\/\u521b\u5efabookList\u7684Handler
\n72  bookListHandler := grpc_transport.NewServer(
\n73      makeGetBookListEndpoint(),
\n74      decodeRequest,
\n75      encodeResponse,
\n76  )
\n77  \/\/bookServer \u589e\u52a0 go-kit\u6d41\u7a0b\u7684 bookList\u5904\u7406\u903b\u8f91
\n78  bookServer.bookListHandler = bookListHandler
\n79
\n80  \/\/\u521b\u5efabookInfo\u7684Handler
\n81  bookInfoHandler := grpc_transport.NewServer(
\n82      makeGetBookInfoEndpoint(),
\n83      decodeRequest,
\n84      encodeResponse,
\n85  )
\n86  \/\/bookServer \u589e\u52a0 go-kit\u6d41\u7a0b\u7684 bookInfo\u5904\u7406\u903b\u8f91
\n87  bookServer.bookInfoHandler = bookInfoHandler
\n88
\n89  \/\/\u542f\u52a8grpc\u670d\u52a1
\n90  serviceAddress := &quot;:50052&quot;
\n91  ls, _ := net.Listen(&quot;tcp&quot;, serviceAddress)
\n92  gs := grpc.NewServer()
\n93  book.RegisterBookServiceServer(gs, bookServer)
\n94  gs.Serve(ls)
\n95}
\n96\/\/Todo go-kit\u53c2\u8003\uff1ahttps:\/\/blog.csdn.net\/lihao19910921\/article\/details\/80166399
\n97<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n\n<\/pre>\n
4\u3001\u5ba2\u6237\u7aef\u4ee3\u7801<\/h3>\n
\n\n
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
<\/div><\/td>
1package main
\n2
\n3import (
\n4   &quot;MyKit&quot;
\n5   &quot;context&quot;
\n6   &quot;fmt&quot;
\n7   &quot;google.golang.org\/grpc&quot;
\n8)
\n9
\n10func main() {
\n11  serviceAddress := &quot;127.0.0.1:50052&quot;
\n12  conn, err := grpc.Dial(serviceAddress, grpc.WithInsecure())
\n13  if err != nil {
\n14      panic(&quot;connect error&quot;)
\n15  }
\n16  defer conn.Close()
\n17  bookClient := book.NewBookServiceClient(conn)
\n18  bi, _ := bookClient.GetBookInfo(context.Background(), &amp;book.BookInfoParams{BookId: 1})
\n19  fmt.Print(&quot;\u83b7\u53d6\u4e66\u7c4d\u4fe1\u606f:\\t&quot;)
\n20  fmt.Println(&quot;bookInfo:&quot;, bi.BookName)
\n21
\n22  bl, _ := bookClient.GetBookList(context.Background(), &amp;book.BookListParams{Page: 1, Limit: 10})
\n23  fmt.Println(&quot;\u83b7\u53d6\u4e66\u7c4d\u5217\u8868:\\t&quot;)
\n24  for _, b := range bl.BookList {
\n25      fmt.Println(&quot;bookId:&quot;, b.BookId, &quot; =&gt; &quot;, &quot;bookName:&quot;, b.BookName)
\n26  }
\n27}
\n28
\n29<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n\n<\/pre>\n
5\u3001\u8fd0\u884c<\/h3>\n
\u9996\u5148\u542f\u52a8Server\u7aef\uff0c\u5904\u4e8e\u76d1\u542c\u963b\u585e\u72b6\u6001\u3002\u518d\u8fd0\u884cclient\u7aef\uff1a<\/p>\n
\"\"<\/p>\n
6\u3001\u8bf4\u660e<\/h3>\n
go-kit\u62bd\u8c61\u7684endpoint\uff1a<\/p>\n
\u4e00\u4e2aTransport\u7684Server \u5fc5\u987b\u8981\u62e5\u6709endPoint\u3001decodeRequestFunc\u3001encodeResponseFunc<\/p>\n
1\u3001 endPoint\u4e00\u4e2a\u7aef\u70b9\u4ee3\u8868\u4e00\u4e2aRPC\uff0c\u4e5f\u5c31\u662f\u6211\u4eec\u670d\u52a1\u63a5\u53e3\u4e2d\u7684\u4e00\u4e2a\u51fd\u6570<\/p>\n
2\u3001 decodeRequestFunc \u8bf7\u6c42\u53c2\u6570\u89e3\u7801\u51fd\u6570<\/p>\n
3\u3001 encodeResponseFunc \u8fd4\u56de\u53c2\u6570\u7f16\u7801\u51fd\u6570<\/p>\n
\u8bf7\u6c42\u6d41\u7a0b\uff1a<\/strong>\u00a0<\/p>\n
\u8bf7\u6c42->encodeResponseFunc -> endPoint -> decodeRequestFunc -> \u8fd4\u56de\u8f93\u51fa<\/p>\n
\u6ce8\uff1a\u5b89\u88c5go-kit\u73af\u5883\u4f9d\u8d56\u5185\u5bb9\u6bd4\u8f83\u591a\uff0c\u6709\u7684\u65f6\u5019\u56e0\u4e3a\u7f51\u7edc\u95ee\u9898\uff08\u4e00\u822c\u8981\u8bbf\u95ee\u5916\u7f51\uff09\uff0c\u56e0\u6b64\u9700\u8981\u5229\u7528GitHub\u4e0b\u8f7d\u4e4b\u540e\u79fb\u52a8\u5230\u5bf9\u5e94\u7684gopath\u4e2d\uff08\u5177\u4f53\u95ee\u9898\u53ea\u80fd\u7ed3\u5408\u81ea\u5df1\u7684\u7ecf\u9a8c\u4e0e\u767e\u5ea6\u4e86 O(\u2229_\u2229)O\uff09\u3002<\/strong><\/p>\n","protected":false},"excerpt":{"rendered":"
go-kit\u00a0\u662f\u4e00\u4e2a\u5fae\u670d\u52a1\u7684\u5f00\u53d1\u5de5\u5177\u96c6\uff0c\u5fae\u670d\u52a1\u7cfb\u7edf\u4e2d\u7684\u5927\u591a\u6570\u5e38\u89c1\u95ee\u9898\uff0c\u56e0\u6b64\uff0c\u4f7f\u7528\u8005\u53ef\u4ee5\u5c06\u7cbe\u529b\u96c6\u4e2d\u5728\u4e1a\u52a1\u903b\u8f91\u4e0a\u3002 grpc\u7f3a\u4e4f\u670d\u52a1\u6cbb\u7406\u7684\u529f\u80fd\uff0c\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7go-kit\u7ed3\u5408grpc\u6765\u5b9e\u73b0\u6211\u4eec\u7684\u5b8c\u6574\u9700\u6c42\u3002go-kit\u62bd\u8c61\u7684endpoint\u8bbe\u8ba1\u8ba9\u6211\u4eec\u53ef\u4ee5\u5f88\u5bb9\u6613\u5305\u88c5\u5176\u5b83\u5fae\u670d\u52a1\u6846\u67b6\u4f7f\u7528\u7684\u534f\u8bae\u3002 endpoint\u4e3aServers\u548cClients\u63d0\u4f9b\u4e86\u57fa\u4e8eRPC\u65b9\u6cd5\u7684\u6784\u5efa\u6a21\u5757\u3002 \u5148\u6765\u770b\u770bendpoint\u6e90\u7801\uff1a 1234567891011121314151617181920212223242526272829303132333435<\/p>\n","protected":false},"author":1,"featured_media":24708,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_bbp_topic_count":0,"_bbp_reply_count":0,"_bbp_total_topic_count":0,"_bbp_total_reply_count":0,"_bbp_voice_count":0,"_bbp_anonymous_reply_count":0,"_bbp_topic_count_hidden":0,"_bbp_reply_count_hidden":0,"_bbp_forum_subforum_count":0,"footnotes":""},"categories":[2],"tags":[292,348,390,26,25,21,10,500,190],"collection":[],"_links":{"self":[{"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/posts\/24710"}],"collection":[{"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/comments?post=24710"}],"version-history":[{"count":0,"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/posts\/24710\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/media\/24708"}],"wp:attachment":[{"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/media?parent=24710"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/categories?post=24710"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/tags?post=24710"},{"taxonomy":"collection","embeddable":true,"href":"https:\/\/aqzt.com\/wp-json\/wp\/v2\/collection?post=24710"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}