| | |
|---|
| | | 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(maxMessageSize = 5242880) |
|---|
| | | @OnMessage |
|---|
| | | public void onMessage(String message, Session session, @PathParam("username") String username) { |
|---|
| | | log.info("服务端收到用户username={}的消息:{}", username, message); |
|---|
| | | JSONObject obj = JSONUtil.parseObj(message); |
|---|
| | |
|---|
| | | public void sendMessage(String message) { |
|---|
| | | try { |
|---|
| | | // log.info("服务端给客户端[{}]发送消息{}", this.session.getId(), message); |
|---|
| | | this.session.getBasicRemote().sendText(message); |
|---|
| | | if(this.session.isOpen()){ |
|---|
| | | int maxChunkSize = 50000; // 定义最大的分块大小 |
|---|
| | | int length = message.length(); |
|---|
| | | int chunks = (int) Math.ceil((double) length / maxChunkSize); |
|---|
| | | //分块发送消息 |
|---|
| | | for (int i = 0; i < chunks; i++) { |
|---|
| | | int startIndex = i * maxChunkSize; |
|---|
| | | int endIndex = Math.min(startIndex + maxChunkSize, length); |
|---|
| | | String chunk = message.substring(startIndex, endIndex); |
|---|
| | | |
|---|
| | | // 判断是否是最后一块消息 |
|---|
| | | boolean isLastChunk = (i == chunks - 1); |
|---|
| | | if(isLastChunk==true){ |
|---|
| | | chunk+="<END>"; |
|---|
| | | } |
|---|
| | | // 发送分块消息，并传递是否是最后一块消息的标识 |
|---|
| | | this.session.getBasicRemote().sendText(chunk); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("服务端发送消息给客户端失败", e); |
|---|
| | | log.error("发送消息给客户端失败：{}", e.getMessage(), e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
