1
1
## TCP协议文档
2
2
3
- #### 数据流层
3
+ #### 1. 协议格式
4
4
5
5
![ dataFlow] ( ../../images/protocol/eventmesh-tcp-dataFlow.png )
6
6
22
22
23
23
24
24
25
- #### 业务逻辑层
25
+ #### 2. 业务逻辑层
26
26
27
- ** 消息组成: **
27
+ + 消息组成
28
28
29
29
消息头(header)+ 消息体(body)
30
30
@@ -47,7 +47,7 @@ public class Header {
47
47
48
48
49
49
50
- ** 详解: **
50
+ + 详解
51
51
52
52
消息头(header):类型为Header,Header中有Command字段,用于区分不同的消息类型
53
53
@@ -63,7 +63,7 @@ public class Header {
63
63
64
64
65
65
66
- #### Client 与 Eventmesh-Runtime ( Server) 交互场景详解
66
+ #### 3. Client 与 Eventmesh-Runtime( Server) 交互场景详解
67
67
68
68
``` java
69
69
public enum Command {
@@ -119,7 +119,7 @@ public enum Command {
119
119
120
120
121
121
122
- #### Client发起交互
122
+ #### 4. Client发起交互
123
123
124
124
| 场景 | Client向Server发送消息命令字 | Server回复Client消息的命令字 | 说明 |
125
125
| -------------- | ---------------------------- | ------------------------------- | ---- |
@@ -136,7 +136,7 @@ public enum Command {
136
136
137
137
138
138
139
- #### Server发起交互
139
+ #### 5. Server发起交互
140
140
141
141
| 场景 | Server向Client发送消息命令字 | Client回复Server消息命令字 | 说明 |
142
142
| ------------------ | ---------------------------- | ------------------------------- | ---- |
@@ -149,7 +149,7 @@ public enum Command {
149
149
| | | | |
150
150
151
151
152
-
152
+ #### 6. 消息类型
153
153
+ 发送RR消息
154
154
155
155
![ rr-msg] ( ../../images/protocol/eventmesh-rr-msg.png )
@@ -191,7 +191,7 @@ public class LiteMessage {
191
191
192
192
193
193
194
- #### 消息发送方式与组成
194
+ #### 1. 消息发送方式与组成
195
195
196
196
197
197
@@ -201,7 +201,7 @@ public class LiteMessage {
201
201
202
202
203
203
204
- ##### 心跳消息:
204
+ + 心跳消息
205
205
206
206
** RequestHeader**
207
207
@@ -229,7 +229,7 @@ public class LiteMessage {
229
229
230
230
231
231
232
- ##### 订阅消息:
232
+ + 订阅消息:
233
233
234
234
** RequestHeader**
235
235
@@ -244,7 +244,7 @@ public class LiteMessage {
244
244
245
245
246
246
247
- ##### 取消订阅消息:
247
+ + 取消订阅消息:
248
248
249
249
** RequestHeader**
250
250
@@ -256,7 +256,7 @@ public class LiteMessage {
256
256
257
257
258
258
259
- ##### 发送异步事件:
259
+ + 发送异步事件:
260
260
261
261
** RequestHeader**
262
262
@@ -274,7 +274,7 @@ public class LiteMessage {
274
274
275
275
276
276
277
- #### Client发起交互
277
+ #### 2. Client发起交互
278
278
279
279
| 场景 | Client向Server发送消息请求码 | Server回复Client消息的响应码 | 说明 |
280
280
| ------------ | ---------------------------- | --------------------------------------- | ---- |
@@ -285,7 +285,7 @@ public class LiteMessage {
285
285
286
286
287
287
288
- #### Server发起交互
288
+ #### 3. Server发起交互
289
289
290
290
| 场景 | Server向Client发送消息请求码 | Client回复Server消息响应码 | 说明 |
291
291
| ------------------ | ---------------------------- | -------------------------- | ---------------------- |
0 commit comments