当前位置:首页-文章-行业新闻-正文

Solon 也是 SSE(Server Send Events)后端开发的优选

Solon 2.3.6 在开发异步接口时,顺带也为 Solon Web 提供了 SSE (Server-Sent Events) 协议的支持插件: <dependency> <groupId>org.noear</groupId> <artifactId&g

Solon 2.3.6 在开发异步接口时,顺带也为 Solon Web 提供了 SSE (Server-Sent Events) 协议的支持插件:

<dependency>
    <groupId>org.noear</groupId>
    <artifactId>solon.web.sse</artifactId>
</dependency>

如果不熟 SSE 的,可以通过搜索引擎查询了解下。//个人还是感觉 ws 更方便用:)

使用示例

按群里用户的要求,体验方式尽量采用大家熟悉的命名与风格。

@Controller
public class SseDemoController {
    static Map<String, SseEmitter> emitterMap = new HashMap<>();

    @Mapping("/sse/{id}")
    public SseEmitter sse(String id) {
         //3000L 是后端异步超时
         return new SseEmitter(3000L)
                .onCompletion(() -> emitterMap.remove(id))
                .onError(e -> e.printStackTrace())
                .onInited(s -> emitterMap.put(id, s)); //在 onInited 里,可以发消息(初始化完成之前,是不能发消息的)
    }

    @Mapping("/sse/put/{id}")
    public String ssePut(String id) {
        SseEmitter emitter = emitterMap.get(id);
        if (emitter == null) {
            return "No user: " + id;
        }

        String msg = "test msg -> " + System.currentTimeMillis();
        emitter.send(new SseEvent().id(Utils.guid()).data(msg).reconnectTime(1000L));

        return "Ok";
    }

    @Mapping("/sse/del/{id}")
    public String sseDel(String id) {
        SseEmitter emitter = emitterMap.get(id);
        if (emitter != null) {
            emitter.complete();
        }

        return "Ok";
    }
}

注意事项

  • 这个插件可能需要把线程数调大些
#服务 http 最小线程数(默认:0表示自动,支持固定值 2 或 内核倍数 x2)
server.http.coreThreads: 0 
#服务 http 最大线程数(默认:0表示自动,支持固定值 32 或 内核倍数 x32)
server.http.maxThreads: 0

更多配置可参考:《应用常用配置说明》

  • 关于超时的说明

超时是指服务端的异步超时,默认为 30000L(即30秒)。其中,0L 代表默认,-1L代表不超时。

  • 提高连接数

要用好,后端超时、前端重连时间以及线程数配置。

Solon 是什么开源项目?

一个,Java 新的生态型应用开发框架。它从零开始构建,有自己的标准规范与开放生态(历时五年,已有全球第二级别的生态)。与其他框架相比,它解决了两个重要的痛点:启动慢,费资源

解决痛点?

由于Solon Bean容器的独特设计,不会因为扩展依赖变多而启动很慢(开发调试时,省时、爽快)!以知名开源项目“小诺”为例:

所谓:“时间就是生命,效率就是金钱”,“天下武功,唯快不破”。

相对于 Spring Boot 和 Spring Cloud 的项目,有什么特点?

  • 启动快 5 ~ 10 倍。 (更快)
  • qps 高 2~ 3 倍。 (更高)
  • 运行时内存节省 1/3 ~ 1/2。 (更少)
  • 打包可以缩小到 1/2 ~ 1/10;比如,300Mb 的变成了 23Mb。 (更小)
  • 同时支持 jdk8, jdk11, jdk17, jdk20, graalvm native

项目仓库地址?

本文原创,作者:admin,其版权均为一念悟道所有。
如需转载,请注明出处:https://www.jiayezz.com/6442.html