smart-socket 是一款国产开源的 Java AIO 框架，追求代码量、性能、稳定性、接口设计各方面都达到极致。如果 smart-socket 对您有一丝帮助，请 Star 一下我们的项目并持续关注；如果您对 smart-socket 并不满意，那请多一些耐心，smart-socket 一直在努力变得更好。

更新内容

1. bug修复：修复内存池特定场景下数组越界问题，影响范围：1.4.0+。
2. bug修复：修复WriteBuffer#write，WriteBuffer#writeByte并发条件下偶发异常问题，影响范围：1.4.0+。
3. 更新：重构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仓库。