Java实现websocket时，每次发送的文本长度默认限制在8k范围内，原因是 org.apache.tomcat.websocket.WsSession进行了设置
  
 // Buffers
    static final int DEFAULT_BUFFER_SIZE = Integer.getInteger(
            "org.apache.tomcat.websocket.DEFAULT_BUFFER_SIZE", 8 * 1024)
            .intValue();
    private volatile int maxBinaryMessageBufferSize = Constants.DEFAULT_BUFFER_SIZE;
    private volatile int maxTextMessageBufferSize = Constants.DEFAULT_BUFFER_SIZE;

如果发送超过8k的消息，就会报错：

No async message support and buffer too small Buffer size: [8,192], Message size: [10,240]
那么要实现类似发送文件的base64，网上有两种方式实现，第一种是实现ServletContextInitializer接口，对onStartup进行重载，大体代码如下：
  
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.web.servlet.ServletContextInitializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
import org.springframework.web.util.WebAppRootListener;


import javax.servlet.ServletContext;
import javax.servlet.ServletException;


/**
* 设置websocket 传输内容的字节大小。 默认8k  当前设置50M
*/
@EnableWebSocket
@Configuration
@EnableAutoConfiguration
@ComponentScan
public class WebSocketConfig  implements ServletContextInitializer {


    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }


    @Override
    public void onStartup(ServletContext servletContext) throws ServletException {
        servletContext.addListener(WebAppRootListener.class);
        servletContext.setInitParameter("org.apache.tomcat.websocket.textBufferSize","52428800");
        servletContext.setInitParameter("org.apache.tomcat.websocket.binaryBufferSize","52428800");
   }
}
这个方法会出现问题就是，每个websocket会话初始化就会占用设置的内存，如上代码是50M，这样连接达到一定数量就会内存溢出。
我们通常会使用另外一种方式，就是在注解@OnMessage设置消息大小，代码如下：
 @OnMessage(maxMessageSize=5242880)
    public void onMessage(String message,  Session session, @PathParam("deviceNo")String  deviceNo) {
        log.info("message："+message +"   ;deviceNo"+deviceNo);
        try {
            JSONObject obj =  JSONObject.parseObject(message);
            String funid  =  (String)obj.get("funid");
            JSONObject contentObj  =  (JSONObject)obj.get("content");
       }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

第二种方式在500个连接情况下经过测试不会造成内存溢出

# java # websocket # 开发语言
Logo
天工造物局

北京人形旗下天工造物具身智能开源社区，聚焦具身天工与慧思开物两大平台

更多推荐

deck.gl TripsLayer 出租车轨迹动画示例实战：从示例运行到着色器原理

TripsLayer 是 deck.gl 中用于渲染**随时间流动的轨迹动画**（如出租车行程、物流路径、迁徙路线）的核心图层。本文以仓库中的最小独立示例 [examples/website/trips](https://link.gitcode.com/i/1442af8f442f4cff39ff546e050fceb5) 为骨架，带你完成从安装依赖、启动应用、理解曼哈顿出租车数据格式，到深入

avatar 天工造物局

Foundry Anvil 中 eth_simulateV1 的 Blob 交易与 Blob Gas 字段规范化：原理、实现与测试验证

本篇技术指南以 [anvil-simulate-blob-transactions.md](https://link.gitcode.com/i/3d2ebe227262de169335eb290af80da8) 这条 changelog 条目为起点，深入剖析 Foundry Anvil 对 `eth_simulateV1` RPC 返回结果中 blob（EIP-4844）交易与 blob gas

avatar 天工造物局

LMCache CLI 实战：用 `lmcache kvcache clear` 管理运行中服务的 KV Cache 状态

本文是一份针对 LMCache 官方 CLI 命令 `lmcache kvcache` 的完整技术指南。该命令用于在**运行中的 LMCache 服务（MP HTTP server）**上管理 KV cache 状态，当前提供 `clear` 子命令，用于清空 L1（CPU 内存）层中缓存的全部 KV 数据。读完本文，你将掌握该命令的完整参数体系、退出码语义、终端/JSON/静默三种输出模式，并能

avatar 天工造物局