smart-socket 是一款国产开源的 Java AIO 框架，追求代码量、性能、稳定性、接口设计各方面都达到极致。如果 smart-socket 对您有一丝帮助，请 Star 一下我们的项目并持续关注；如果您对 smart-socket 并不满意，那请多一些耐心，smart-socket 一直在努力变得更好。
更新内容
- bug修复：修复内存池特定场景下数组越界问题，影响范围：1.4.0+。
- bug修复：修复WriteBuffer#write，WriteBuffer#writeByte并发条件下偶发异常问题，影响范围：1.4.0+。
- 更新：重构UDP代码。
smart-socket自 v1.4.4 版本开始提供UDP的支持，不过代码设计的比较复杂，有违 smart-socket 一贯强调极简、易用、高性能的原则。故此次大刀阔斧进行了一番重构，其中参考了部分 Java AIO 的内核设计思路，仅用 5 个Java 源文件便达到了预期的效果。
原先熟悉 smart-socket TCP 开发的用户可以比较快的上手 UDP 开发，都是基于 Protocol、MessageProcessor 两个接口进行开发。同时也意味着如果你是采用 smart-socket 进行通信开发，只需少量的调整便可在 TCP 和 UDP 之间进行切换。
Maven
<dependency>
<groupId>org.smartboot.socket</groupId>
<artifactId>aio-pro</artifactId>
<version>1.4.9</version>
</dependency>
示例demo
public class UdpDemo {
public static void main(String[] args) throws IOException {
AbstractMessageProcessor<String> processor = new AbstractMessageProcessor<String>() {
@Override
public void process0(AioSession channel, String msg) {
try {
InetSocketAddress remoteAddress = channel.getRemoteAddress();
if (remoteAddress.getPort() == 9999) {
System.out.println(channel + " receive response:" + msg);
} else {
System.out.println("server receive request:" + msg);
WriteBuffer buffer = channel.writeBuffer();
byte[] bytes = msg.getBytes();
buffer.writeInt(bytes.length);
buffer.write(bytes);
}
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void stateEvent0(AioSession session, StateMachineEnum stateMachineEnum, Throwable throwable) {
if (throwable != null) {
throwable.printStackTrace();
}
}
};
//服务端
final UdpBootstrap<String> bootstrap = new UdpBootstrap<String>(new StringProtocol(), processor);
bootstrap.setThreadNum(Runtime.getRuntime().availableProcessors());
bootstrap.setReadBufferSize(1024);
bootstrap.open(9999);
System.out.println("启动成功");
//客户端
int i = 10;
final SocketAddress remote = new InetSocketAddress("localhost", 9999);
while (i-- > 0) {
new Thread(() -> {
try {
int count = 100;
UdpChannel<String> channel = bootstrap.open();
AioSession<String> aioSession = channel.connect(remote);
WriteBuffer writeBuffer = aioSession.writeBuffer();
while (count-- > 0) {
byte[] msg = ("HelloWorld" + count).getBytes();
writeBuffer.writeInt(msg.length);
writeBuffer.write(msg);
writeBuffer.flush();
}
System.out.println("发送完毕");
} catch (Exception e) {
e.printStackTrace();
}
}).start();
}
}
}
当然，还是要负责任的提醒各位，现阶段不保证 UDP 功能无 bug，但一旦发现 bug 保证会在第一时间解决。
最后
无论你是从事物联网还是互联网，需要采用TCP或者UDP进行通信框架，smart-socket 都会是比较不错的选择。另外，一款基于 smart-socket 开发的首款商业化产品即将面世，请关注 smart-socket gitee仓库。
