用JavaEE7、Websockets和GlassFish4打造聊天室（一）(1)(2)

面分析下上面的代码：

使用@ ServerEndpoint定义一个新的endpoint，其中的值指定了URL并且可以使用PathParams参数，就象在JAX-RS中的用法一样。

所以值“/chat/{room}”允许用户通过如下形式的URL去连接某个聊天室：ws://0.0.0.0:8080/hascode/chat/java

在大括号中的值即room），可以通过使用javax.websocket.server.PathParam，在endpoint的生命周期回调方法中以参数的方式注入。

此外，我们要使用一个编码和解码的类，因为我们使用的是一个DTO形式的类，用于在服务端和客户端传送数据。

当用户第一次连接到服务端，输入要进入聊天室的房号，则这个房号以参数的方式注入提交，并且使用session.getUserProperties将值保存在用户的属性map中。

当一个聊天参与者通过tcp连接发送信息到服务端,则循环遍历所有已打开的session,每个session被绑定到指定的聊天室中,并且接收编码和解码的信息。

如果我们想发送简单的文本信息或和二进制格式的信息，则可以使用session.getBasicRemote().sendBinary() 或session.getBasicRemote().sendText()

接下来我们看下用于代表信息传递实体(DTO:Data Transfer Object)的代码，如下：

package com.hascode.tutorial; 
  
import java.util.Date; 
  
public class ChatMessage { 
    private String message; 
    private String sender; 
    private Date received; 
  
    // 其他getter,setter方法 
} 

聊天消息的转换

在这个应用中，将编写一个编码和解码类，用于在聊天信息和JSON格式间进行转换。

先来看下解码类的实现，这将会把传递到服务端的聊天信息转换为ChatMessage实体类。在这里，使用的是Java API for JSON Processing(JSR353)参考：

http://jcp.org/en/jsr/detail?id=353）规范去将JSON格式的信息转换为实体类，代码如下，其中重写的willDecode方法，这里默认返回为true。

package com.hascode.tutorial; 
  
import java.io.StringReader; 
import java.util.Date; 
  
import javax.json.Json; 
import javax.json.JsonObject; 
import javax.websocket.DecodeException; 
import javax.websocket.Decoder; 
import javax.websocket.EndpointConfig; 
  
public class ChatMessageDecoder implements Decoder.Text<ChatMessage> { 
    @Override 
    public void init(final EndpointConfig config) { 
    } 
  
    @Override 
    public void destroy() { 
    } 
  
    @Override 
    public ChatMessage decode(final String textMessage) throws DecodeException { 
        ChatMessage chatMessage = new ChatMessage(); 
        JsonObject obj = Json.createReader(new StringReader(textMessage)) 
                .readObject(); 
        chatMessage.setMessage(obj.getString("message")); 
        chatMessage.setSender(obj.getString("sender")); 
        chatMessage.setReceived(new Date()); 
        return chatMessage; 
    } 
  
    @Override 
    public boolean willDecode(final String s) { 
        return true; 
    } 
} 

同样再看下编码类的代码，这个类相反，是将ChatMessage类转换为Json格式，代码如下：

package com.hascode.tutorial; 
  
import javax.json.Json; 
import javax.websocket.EncodeException; 
import javax.websocket.Encoder; 
import javax.websocket.EndpointConfig; 
  
public class ChatMessageEncoder implements Encoder.Text<ChatMessage> { 
    @Override 
    public void init(final EndpointConfig config) { 
    } 
  
    @Override 
    public void destroy() { 
    } 
  
    @Override 
    public String encode(final ChatMessage chatMessage) throws EncodeException { 
        return Json.createObjectBuilder() 
                .add("message", chatMessage.getMessage()) 
                .add("sender", chatMessage.getSender()) 
                .add("received", chatMessage.getReceived().toString()).build() 
                .toString(); 
    } 
} 

这里可以看到JSR-353的强大威力，只需要调用Json.createObjectBuilder就可以轻易把一个DTO对象转化为JSON了。