Я изучаю реализацию Tyrus WebSocket. Но я не понимаю, почему и когда нам нужно более одного кодировщика или декодера в конечных точках веб-сокета. Например:
@ServerEndpoint(value = "/subscribe", decoders = { TextStreamMessageDecoder.class }, encoders = { TextStreamMessageEncoder.class })
public class ChatServerEndPoint {
......
}
В списке декодеров и кодировщиков есть только один декодер и кодер. Поскольку это массив декодеров или кодировщиков, я могу одновременно использовать несколько типов кодировщиков или декодеров. Но в описании API тогда упоминалось,
Среда выполнения websocket будет использовать первый декодер в списке, способный декодировать сообщение, игнорируя остальные декодеры.
Если он всегда использует первые элементы списка, то каковы варианты использования нескольких кодировщиков или декодеров в API WebSockets?
После редактирования
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 или декодер. Итак, какой декодер будет использоваться, когда клиент отправляет сообщение на сервер?
