Java NIO实战篇:使用Socket实现报文交互

简介: Java NIO实战篇:使用Socket实现报文交互

文章导航

前言

最近有个对接渠道需求,对方提供文档中要求使用Socket短链接的方式进行报文交互,所以这边采用NIO方式编写Socket。

正文

概念介绍

Java共支持3种网络编程模型/IO模式:BIO、NIO、AIO。

什么是JAVA BIO?

同步并阻塞(传统阻塞型),服务器实现模式为 一个连接对应一个线程,即客户端有连接请求时服务器端就需要启动一个线程进行处理,如果这个连接不做任何事情会造成不必要的线程开销。

什么是JAVA NIO?

同步非阻塞,服务器实现模式为 一个线程处理多个请求(连接),即客户端发送的连接请求都会注册到多路复用器上,多路复用器轮询到连接有I/O请求就进行处理。

什么是JAVA AIO

异步非阻塞,AIO 引入 异步通道 的概念,采用了 Proactor 模式,简化了程序编写,有效的请求才启动线程,它的特点是:先由操作系统完成后才通知服务端程序启动线程去处理,一般适用于连接数较多且连接时间较长的应用。

代码编写

package nio;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class SocketServer extends Thread {
    private int port = 9999;
    private String ip = "127.0.0.1";
    private Boolean startListener = true;
    private int threadPoolSize = 10;
    @Override
    public void run() {
        Selector selector = null;
        ServerSocketChannel socketChannel = null;
        int nKeys = 0;
        try {
            selector = Selector.open();
            socketChannel = ServerSocketChannel.open();
            InetSocketAddress inetSocketAddress = new InetSocketAddress(ip, port);
            //信道绑定IP、端口
            socketChannel.socket().bind(inetSocketAddress);
            //设置非阻塞
            socketChannel.configureBlocking(false);
            //注册选择器
            socketChannel.register(selector, SelectionKey.OP_ACCEPT);
            //开始监听
            System.out.println("开启监听");
            while (startListener) {
                //设置超时时间,多久返回一次选择器key
                nKeys = selector.select(100);
                if (nKeys > 0) {
                    Set<SelectionKey> selectedKeys = selector.selectedKeys();
                    Iterator<SelectionKey> it = selectedKeys.iterator();
                    while (it.hasNext()) {
                        SelectionKey key = it.next();
                        Socket socket = null;
                        it.remove();
                        if (key.isAcceptable()) {  //处理连接事件
                            SocketChannel channel = socketChannel.accept();
                            channel.configureBlocking(false);  //设置为非阻塞
                            System.out.println("client:" + channel.getLocalAddress() + " is connect");
                            channel.register(selector, SelectionKey.OP_READ); //注册客户端读取事件到selector
                        } else if (key.isReadable()) {  //处理读取事件
                            ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
                            SocketChannel channel = (SocketChannel) key.channel();
                            channel.read(byteBuffer);
                            //获取请求报文
                            String requestInfo = new String(byteBuffer.array(),"GBK");
                            System.out.println("请求报文:"+requestInfo+"--"+requestInfo.length());
                            try {
                                if (requestInfo!=null&&!requestInfo.equals("")) {
                                    //响应报文
                                    String newData="ZhuDaChang";
                                    ByteBuffer buf = ByteBuffer.allocate(newData.getBytes().length);
                                    buf.clear();
                                    buf.put(newData.getBytes());
                                    buf.flip();
                                    while (buf.hasRemaining()) {
                                        channel.write(buf);
                                    }
                                    buf.clear();
                                }
                            }catch (Exception e){
                                e.printStackTrace();
                            }
                        }
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (socketChannel != null) {
                    socketChannel.close();
                }
            } catch (Exception e) {
                e.printStackTrace();
                System.out.println("关闭ServerSocketChannel异常" + e.getMessage());
            }
        }
    }
}

ByteBuffer.allocate()方法,指定一个大小的缓存空间,这个缓存空间需要我们去判断请求报文的大概长度范围,定义适量的空间大小,如果空间太小则会丢失报文,太大浪费空间。

测试

编写代码入口

package nio;
public class SocketMain {
    public static void main(String[] args) {
        SocketServer socketServer=new SocketServer();
        Thread thread=new Thread(socketServer);
        thread.start();
    }
}

862012541ed6477b2fdaca00146f28be_07faea84a4db4ca6aab4aa3ace73f65e.png

telnet测试

连接命令:telnet 127.0.0.1 9999

返回响应信息:

踩坑点

客户端窗口按快捷键:ctrl + ] 进入窗口模式

c    - close                    关闭当前连接
d    - display                  显示操作参数
o    - open hostname [port]     连接到主机(默认端口 23)。
q    - quit                     退出 telnet
set  - set                      设置选项(键入 'set ?' 获得列表)
sen  - send                     将字符串发送到服务器
st   - status                   打印状态信息
u    - unset                    解除设置选项(键入 'set ?' 获得列表)
?/h  - help                     打印帮助信息

30abeb1bde5506ba1f131878c4dbfa45_38297877eedf44d9a1cac575b98b7fde.png

客户端主动断开

我们按c关闭连接,发现后台报错了,这是因为当前读取内容读不到值了。

解决方法

查询是否读取到值,如果客户端可能端口了连接,此时会返回-1

总结

本篇文章介绍了常见IO的基本概念,及其编写NIO实现Socket案例。

目录
相关文章
|
2月前
|
Java 流计算
Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
44 1
Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
|
2月前
|
Java
[Java]Socket套接字(网络编程入门)
本文介绍了基于Java Socket实现的一对一和多对多聊天模式。一对一模式通过Server和Client类实现简单的消息收发;多对多模式则通过Server类维护客户端集合,并使用多线程实现实时消息广播。文章旨在帮助读者理解Socket的基本原理和应用。
29 1
|
2月前
|
网络协议 安全 Java
Java Socket原理
Java Socket原理是指在Java中通过Socket实现的网络通信的基础理论与机制。Socket是网络中不同设备间通信的一种标准方式,它允许应用程序之间通过TCP/IP等协议进行数据交换。在Java中,利用Socket编程可以方便地创建客户端与服务器端应用,实现跨网络的数据传输功能,是互联网软件开发中的重要技术之一。它支持多种通信模式,如可靠的流式套接字(TCP)和数据报式套接字(UDP)。
57 10
|
2月前
|
人工智能 缓存 Java
深入解析Spring AI框架:在Java应用中实现智能化交互的关键
【10月更文挑战第12天】Spring AI 是 Spring 框架家族的新成员,旨在满足 Java 应用程序对人工智能集成的需求。它支持自然语言处理、图像识别等多种 AI 技术,并提供与云服务(如 OpenAI、Azure Cognitive Services)及本地模型的无缝集成。通过简单的配置和编码,开发者可轻松实现 AI 功能,同时应对模型切换、数据安全及性能优化等挑战。
158 3
|
3月前
NIO-编程实战(二)
NIO-编程实战(二)
|
3月前
|
网络协议 Python
告别网络编程迷雾!Python Socket编程基础与实战,让你秒变网络达人!
在网络编程的世界里,Socket编程是连接数据与服务的关键桥梁。对于初学者,这往往是最棘手的部分。本文将用Python带你轻松入门Socket编程,从创建TCP服务器与客户端的基础搭建,到处理并发连接的实战技巧,逐步揭开网络编程的神秘面纱。通过具体的代码示例,我们将掌握Socket的基本概念与操作,让你成为网络编程的高手。无论是简单的数据传输还是复杂的并发处理,Python都能助你一臂之力。希望这篇文章成为你网络编程旅程的良好开端。
63 3
|
3月前
|
缓存 Java Linux
NIO-编程实战(一)
NIO-编程实战(一)
|
4月前
|
前端开发 JavaScript Java
Ajax进行异步交互:提升Java Web应用的用户体验
Ajax 技术允许在不重载整个页面的情况下与服务器异步交换数据,通过局部更新页面内容,极大提升了 Java Web 应用的响应速度和用户体验。本文介绍 Ajax 的基本原理及其实现方式,包括使用 XMLHttpRequest 对象发送请求、处理响应数据,并在 Java Web 应用中集成 Ajax。此外,还探讨了 Ajax 如何通过减少页面刷新、实时数据更新等功能改善用户体验。
76 3
|
5月前
|
网络协议 程序员 视频直播
|
5月前
|
Java
如何在Java中实现多线程的Socket服务器?
在Java中,多线程Socket服务器能同时处理多个客户端连接以提升并发性能。示例代码展示了如何创建此类服务器:监听指定端口,并为每个新连接启动一个`ClientHandler`线程进行通信处理。使用线程池管理这些线程,提高了效率。`ClientHandler`读取客户端消息并响应,支持简单的文本交互,如发送欢迎信息及处理退出命令。