smart-socket,一款面向万物互联的 Java 通信框架。
产品特色:
极简:于2017年开源至今发布了数十次版本,核心代码量始终控制在2500行以内,总代码量不足5000行。
易用:5分钟上手(前提:未曾遭受网上错误编解码知识的毒害)
高性能:以算法之力充分驱动硬件算力之势,基于smart-socket的服务在通信性能方面可轻松超过其他计算机语言开发的程序,包括且不限于:C/C++、Golang、Rust、Erlang。
推荐理由:
国产化,源码 100% 自研,信创首选产品。
轻量化,生成 jar 包仅 62KB。
插件化,多款实用插件辅助高效通信编程。
人性化,低至分钟级的学习成本。
舒适的编程体验;高效的运行表现;极少的资源开销。 smart-socket 在多方面都遥遥领先 netty,除了知名度。
舒适的编程体验;高效的运行表现;极少的资源开销。
smart-socket 在多方面都遥遥领先 netty,除了知名度。
拆解底层 write 线程模型。
提升进程运行期间动态启停通信服务的资源管理可靠性。
新增 IdleStatePlugin 插件
内置线程调整为守护线程,实现优雅停机。
新增示例代码
这个版本主要带来了 IdleStatePlugin 插件,这是一款对通信链路闲置状态检测的插件。适用于弱网环境下,解决通信双方因无法感知链路异常,导致通信质量受损等问题。
按照 smart-socket 一贯的设计风格,此插件依旧开箱即用,用户可根据自身需求选择以下合适的集成模式。
// 读、写通道闲置时长超过5秒,则断开连接 processor.addPlugin(new IdleStatePlugin<>(5000)); // 读通道闲置时长超过5秒,则断开连接 processor.addPlugin(new IdleStatePlugin<>(5000,true,false)); // 写通道闲置时长超过5秒,则断开连接 processor.addPlugin(new IdleStatePlugin<>(5000,false,true));
Maven
<!-- JDK1.8 --> <dependencies> <dependency> <groupId>org.smartboot.socket</groupId> <artifactId>aio-core</artifactId> <version>1.5.36</version> </dependency> </dependencies>
<dependencies> <dependency> <groupId>org.smartboot.socket</groupId> <artifactId>aio-core</artifactId> <version>${version}</version> </dependency> </dependencies>
这里提供的示例是一种简单的字符串通信协议,仅作效果演示。实际场景中还需根据通信双方约定的协议实现编解码算法。
import org.smartboot.socket.Protocol; import org.smartboot.socket.transport.AioSession; import java.nio.ByteBuffer; publicclass StringProtocol implements Protocol<String> { @Override public String decode(ByteBuffer readBuffer, AioSession session) { int remaining = readBuffer.remaining(); if (remaining < Integer.BYTES) { returnnull; } readBuffer.mark(); int length = readBuffer.getInt(); if (length > readBuffer.remaining()) { readBuffer.reset(); returnnull; } byte[] b = newbyte[length]; readBuffer.get(b); readBuffer.mark(); returnnew String(b); } }
服务端通过System.out打印客户端传输过来的字符串内容,并将该内容原样传回至客户端。
System.out
import org.smartboot.socket.MessageProcessor; import org.smartboot.socket.transport.AioQuickServer; import org.smartboot.socket.transport.WriteBuffer; import java.io.IOException; publicclass StringServer { public static void main(String[] args) throws IOException { MessageProcessor<String> processor = (session, msg) -> { System.out.println("receive from client: " + msg); WriteBuffer outputStream = session.writeBuffer(); try { byte[] bytes = msg.getBytes(); outputStream.writeInt(bytes.length); outputStream.write(bytes); } catch (IOException e) { e.printStackTrace(); } }; AioQuickServer server = new AioQuickServer(8888, new StringProtocol(), processor); server.start(); } }
try-catch中先后调用writeInt、write是一种协议编码手法,也是从事通信开发必须要理解和掌握的技能。
try-catch中
writeInt
write
客户端与服务端建立TCP连接后,便向其发送hello smart-socket,当收到服务端的响应消息时,通过MessageProcessor的实现类进行控制台打印。
hello smart-socket
MessageProcessor
import org.smartboot.socket.MessageProcessor; import org.smartboot.socket.transport.AioQuickClient; import org.smartboot.socket.transport.AioSession; import org.smartboot.socket.transport.WriteBuffer; import java.io.IOException; publicclass StringClient { public static void main(String[] args) throws IOException { MessageProcessor<String> processor = (session, msg) -> System.out.println("receive from server: " + msg); AioQuickClient client = new AioQuickClient("localhost", 8888, new StringProtocol(), processor); AioSession session = client.start(); WriteBuffer writeBuffer = session.writeBuffer(); byte[] data = "hello smart-socket".getBytes(); writeBuffer.writeInt(data.length); writeBuffer.write(data); writeBuffer.flush(); } }
篇幅有限,仅展示部分...
smartboot开源组织,一个容易被误认为是在“重复造轮子”的低调组织。曾获得 2020 年度 OSC 中国开源项目「优秀 Gitee 组织 」荣誉。 该组织内的明星项目包括: smart-socket 历时5年精炼出2千多行代码,轻松实现百万级长连接的 AIO 通信框架。 smart-http 基于 smart-socket 实现的 HTTP/1.1 web服务。 smart-servlet 基于 smart-http 实现的 Servlet 3.1 容器服务。 smart-mqtt 基于 smart-socket 实现的 MQTT 3.1.1/5.0 Broker&Client 服务。 smart-flow 一款具备可观测性的轻量级业务编排框架。 组织地址:https://smartboot.tech/ 代码仓库:https://gitee.com/smartboot
smartboot开源组织,一个容易被误认为是在“重复造轮子”的低调组织。曾获得 2020 年度 OSC 中国开源项目「优秀 Gitee 组织 」荣誉。
该组织内的明星项目包括:
smart-socket 历时5年精炼出2千多行代码,轻松实现百万级长连接的 AIO 通信框架。
smart-http 基于 smart-socket 实现的 HTTP/1.1 web服务。
smart-servlet 基于 smart-http 实现的 Servlet 3.1 容器服务。
smart-mqtt 基于 smart-socket 实现的 MQTT 3.1.1/5.0 Broker&Client 服务。
smart-flow 一款具备可观测性的轻量级业务编排框架。
组织地址:https://smartboot.tech/ 代码仓库:https://gitee.com/smartboot
教程篇:
通信框架 smart-socket 设计概览
五分钟上手 smart-socket
smart-socket系列教程:工程结构
smart-socket系列教程:通信协议
插件篇:
smart-socket 插件化设计
smart-socket 监控插件,性能分析的一柄利刃
smart-socket 码流监控插件,让通信数据无所遁形
杂篇
smart-socket 单机百万长连接背后的故事
揭秘百万长连接背后的黑科技
图解通信框架的调度模型
评论删除后,数据将无法恢复
🎉smart-socket v1.5.36 发布,物联时代的弄潮儿
1、smart-socket 简介
smart-socket,一款面向万物互联的 Java 通信框架。
产品特色:
极简:于2017年开源至今发布了数十次版本,核心代码量始终控制在2500行以内,总代码量不足5000行。
易用:5分钟上手(前提:未曾遭受网上错误编解码知识的毒害)
高性能:以算法之力充分驱动硬件算力之势,基于smart-socket的服务在通信性能方面可轻松超过其他计算机语言开发的程序,包括且不限于:C/C++、Golang、Rust、Erlang。
推荐理由:
国产化,源码 100% 自研,信创首选产品。
轻量化,生成 jar 包仅 62KB。
插件化,多款实用插件辅助高效通信编程。
人性化,低至分钟级的学习成本。
2、 版本更新
拆解底层 write 线程模型。
提升进程运行期间动态启停通信服务的资源管理可靠性。
新增 IdleStatePlugin 插件
内置线程调整为守护线程,实现优雅停机。
新增示例代码
这个版本主要带来了 IdleStatePlugin 插件,这是一款对通信链路闲置状态检测的插件。适用于弱网环境下,解决通信双方因无法感知链路异常,导致通信质量受损等问题。
按照 smart-socket 一贯的设计风格,此插件依旧开箱即用,用户可根据自身需求选择以下合适的集成模式。
Maven
3、快速上手
3.1 引入Maven依赖
3.2 定义协议
这里提供的示例是一种简单的字符串通信协议,仅作效果演示。实际场景中还需根据通信双方约定的协议实现编解码算法。
3.3 启动服务端
服务端通过
System.out
打印客户端传输过来的字符串内容,并将该内容原样传回至客户端。try-catch中
先后调用writeInt
、write
是一种协议编码手法,也是从事通信开发必须要理解和掌握的技能。3.4 启动客户端
客户端与服务端建立TCP连接后,便向其发送
hello smart-socket
,当收到服务端的响应消息时,通过MessageProcessor
的实现类进行控制台打印。4、我们的用户
篇幅有限,仅展示部分...
5、关于组织
教程篇:
通信框架 smart-socket 设计概览
五分钟上手 smart-socket
smart-socket系列教程:工程结构
smart-socket系列教程:通信协议
插件篇:
smart-socket 插件化设计
smart-socket 监控插件,性能分析的一柄利刃
smart-socket 码流监控插件,让通信数据无所遁形
杂篇
smart-socket 单机百万长连接背后的故事
揭秘百万长连接背后的黑科技
图解通信框架的调度模型