FilesExpand file tree

master

/

websocket-消息分片.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

41 lines (35 loc) · 1.19 KB

master

/

websocket-消息分片.java

Copy path

Top

File metadata and controls

• Code
• Blame

41 lines (35 loc) · 1.19 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

-----------------------------------

WebSocket-消息分片,注解式 |

-----------------------------------

# 当消息过大的时候,我们选择拆分消息为多个消息.

# 二进制消息与文本消息都一样

# 代码

@OnMessage

public void onMessage(String message,boolean isLast){

//balabalabal

}

@OnMessage

public void onMessage(byte[] message,boolean isLast){

//balabalabal

}

@OnMessage

public void onMessage(ByteBuffer[] message,boolean isLast){

//balabalabal

}

# 如果当前消息是消息体中的最后一部分消息,isLast = true,反之,则为 false

-----------------------------------

WebSocket-消息分片,编程式 |

-----------------------------------

# MessageHandler

# 处理客户端(发送给服务端)的消息,可以有一个或者多个.由session维护

# 该接口定义了编程式端点,接收入站消息时,注册其兴趣的所有方式.

# 可以使用该接口来选择是接收文本信息,还是二进制信息

# 也可以接收整个消息,或者是当消息到达时接收较小的片段(消息特别大的时候)

# 该接口,内部是两个接口(都实现了MessageHandler),我们需要实现该接口中,的接口实例

interface Whole<T> extends MessageHandler {

void onMessage(T message);

}

//该接口就是分片消息,编程式的接口

interface Partial<T> extends MessageHandler {

void onMessage(T partialMessage, boolean last);

}