springboot整合websocket（二）聊天室补充篇

springboot整合websocket（一）简单聊天室
springboot整合websocket（二）聊天室补充篇

springboot整合websocket（三）上传文件（引导篇）
springboot整合websocket（四）上传文件（终篇）

这篇呢对上一篇聊天室做一个简单的补充，为下一篇文件上传做个铺垫

约定一个数据交换，对不同的字符串加以区分

因为我们的消息可能分很多种类型，比如说聊天、发送文件名给服务器（下一章会说到的）、或者其他业务需求的消息等等。

这里我还用了lombok

    com.alibaba
    fastjson
    1.2.76




    org.projectlombok
    lombok
    true

1. operation 是用来标识类型的
2. msg 则是消息

@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class Message
{
    private String operation;
    private String msg;

    public Message setOperation(String operation)
    {
        this.operation = operation;
        return this;
    }

    public Message setMsg(String msg)
    {
        this.msg = msg;
        return this;
    }
}

1. 我这里去掉了OnOpen方法里面原有的东西
2. tip 是用来进入聊天室后保存用户名
3. msg是用来发送消息

@Log4j2
@Controller
@ServerEndpoint("/websocket")
public class baseWebsocketController
{
    //onopen 在连接创建(用户进入聊天室)时触发
    @OnOpen
    public void openSession(Session session, EndpointConfig config)
    {
		//原来的东西去掉了
    }

    //响应字符串
    @OnMessage
    public void onMessage(Session session, String message)
    {
        //使用 fastjson 解析 json 字符串
        final Message data = JSONObject.parseObject(message, Message.class);
        //响应的信息
        final Message response = Message.builder()
                .operation(data.getOperation())         //将请求的 operation 放入
                .build();
        //根据不同的 operation 执行不同的操作
        switch (data.getOperation()) {
            //进入聊天室后保存用户名
            case "tip":
                session.getUserProperties().put("username", data.getMsg());
                sessions.put(session.getId(), session);
                response.setMsg("[" + data.getMsg() + "]进入房间");
                sendAll(JSONObject.toJSONString(response));
                break;
            //发送消息
            case "msg":
                final String username = (String) session.getUserProperties().get("username");
                response.setMsg("[" + username + "]" + data.getMsg());
                sendAll(JSONObject.toJSONString(response));
                break;
        }
    }
}

html不变，我这里就只放script的东西了

1. 修改了 webSocket.onopen
2. 修改了 webSocket.onMessage
3. 修改了 $(’#sendBtn’).click()
4. 添加了 function sendMessage(operation, msg){}

End

springboot整合websocket（一）简单聊天室
springboot整合websocket（二）聊天室补充篇

springboot整合websocket（三）上传文件（引导篇）
springboot整合websocket（四）上传文件（终篇）