| | |
|---|
| | | public void onOpen(Session session, @PathParam("username") String username) { |
|---|
| | | this.username = username; |
|---|
| | | this.session = session; |
|---|
| | | this.session.setMaxTextMessageBufferSize(12*1024*1024); |
|---|
| | | this.session.setMaxBinaryMessageBufferSize(12*1024*1024); |
|---|
| | | List<WebSocketServer> webSocketServers = sessionMap.get(username); |
|---|
| | | if (webSocketServers == null) { |
|---|
| | | ArrayList<WebSocketServer> arrayListwebserver = new ArrayList<WebSocketServer>(); |
|---|
| | |
|---|
| | | * |
|---|
| | | * @param message 客户端发送过来的消息 |
|---|
| | | */ |
|---|
| | | @OnMessage |
|---|
| | | @OnMessage(maxMessageSize = 5242880) |
|---|
| | | public void onMessage(String message, Session session, @PathParam("username") String username) { |
|---|
| | | log.info("服务端收到用户username={}的消息:{}", username, message); |
|---|
| | | JSONObject obj = JSONUtil.parseObj(message); |
|---|
