我正在学习 tyrus WebSocket 实现。但我不明白为什么以及何时在 websocket 端点中需要一个以上的编码器或解码器。例如:
@ServerEndpoint(value = "/subscribe", decoders = { TextStreamMessageDecoder.class }, encoders = { TextStreamMessageEncoder.class })
public class ChatServerEndPoint {
......
}
解码器和编码器列表中只有一个解码器和编码器。由于这些是解码器或编码器阵列,因此我可以一次使用多种类型的编码器或解码器。但是在随后提到的api描述中,
websocket 运行时将使用列表中能够解码消息的第一个解码器,而忽略剩余的解码器。
如果它总是使用列表的第一个元素,那么 WebSockets API 中多个编码器或解码器的用例是什么?
编辑后
public class TextStreamMessageDecoder implements Decoder.TextStream<JsonWrapper>{
public JsonWrapper decode(Reader reader) throws DecodeException,
IOException {
JsonReader jsonReader = Json.createReader(reader);
JsonObject jsonObject = jsonReader.readObject();
return new JsonWrapper(jsonObject);
}
}
public class TextStreamMessageEncoder implements Encoder.TextStream<JsonWrapper>{
public void encode(JsonWrapper object, Writer writer)
throws EncodeException, IOException {
JsonWriter jsonWriter = Json.createWriter(writer);
JsonObject jsonObject = object.getJson();
jsonWriter.write(jsonObject);
}
}
public class MessageDecoder implements Decoder.Text<JsonWrapper> {
public JsonWrapper decode(String s) throws DecodeException {
JsonObject json = Json.createReader(new StringReader(s)).readObject();
return new JsonWrapper(json);
}
public boolean willDecode(String s) {
// TODO Auto-generated method stub
try {
Json.createReader(new StringReader(s)).read();
return true;
} catch (JsonException ex) {
ex.printStackTrace();
return false;
}
}
}
public class MessageEncoder implements Encoder.Text<JsonWrapper> {
public String encode(JsonWrapper jsonWrapper) throws EncodeException {
return jsonWrapper.getJson().toString();
}
}
@ClientEndpoint(decoders = { MessageDecoder.class}, encoders = { MessageEncoder.class })
public class ChatClientEndPoint {
@OnMessage
public void onMessage(String message, Session session) {
logger.info("onMessage: " + session.getId());
if (this.messageHandler != null)
this.messageHandler.handleMessage(message);
}
}
@ServerEndpoint(value = "/subscribe", decoders = { TextStreamMessageDecoder.class, MessageDecoder.class}, encoders = { TextStreamMessageEncoder.class, MessageEncoder.class })
public class ChatServerEndPoint {
@OnMessage
public void onMessage(String message, Session session) {
logger.info("onMessage: " + session.getId());
// logger.info("onMessage: " + message.toString());
Gson gson = new Gson();
ClientMessage clientMessage = gson.fromJson(message,
ClientMessage.class);
System.out.println(clientMessage.toString());
}
}
服务器发送给客户端:
try {
Gson gson = new Gson();
session.getBasicRemote().sendObject(
gson.toJson(new ServerMessage(1, "connection accepted")));
} catch (EncodeException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
客户端发送到服务器:
try {
Gson gson = new Gson();
session.getBasicRemote().sendObject(
gson.toJson(new ClientMessage(1, "FirstName")));
} catch (EncodeException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
客户端使用 MessageEncoder 类发送消息,而服务器有两个编码器和解码器,包括 TextStreamMessageEncoder 或解码器和 MessageEncoder 或解码器。那么当客户端向服务器发送消息时将使用哪个解码器?