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案例。

目录
相关文章
|
9天前
|
消息中间件 Java Kafka
"Kafka快速上手:从环境搭建到Java Producer与Consumer实战,轻松掌握分布式流处理平台"
【8月更文挑战第10天】Apache Kafka作为分布式流处理平台的领头羊,凭借其高吞吐量、可扩展性和容错性,在大数据处理、实时日志收集及消息队列领域表现卓越。初学者需掌握Kafka基本概念与操作。Kafka的核心组件包括Producer(生产者)、Broker(服务器)和Consumer(消费者)。Producer发送消息到Topic,Broker负责存储与转发,Consumer则读取这些消息。首先确保已安装Java和Kafka,并启动服务。接着可通过命令行创建Topic,并使用提供的Java API实现Producer发送消息和Consumer读取消息的功能。
30 8
|
10天前
|
jenkins Java 持续交付
【一键搞定!】Jenkins 自动发布 Java 代码的神奇之旅 —— 从零到英雄的持续集成/部署实战秘籍!
【8月更文挑战第9天】随着软件开发自动化的发展,持续集成(CI)与持续部署(CD)已成为现代流程的核心。Jenkins 作为一款灵活且功能丰富的开源 CI/CD 工具,在业界应用广泛。以一家电商公司的 Java 后端服务为例,通过搭建 Jenkins 自动化发布流程,包括创建 Jenkins 项目、配置 Git 仓库、设置构建触发器以及编写构建脚本等步骤,可以实现代码的快速可靠部署。
33 2
|
19天前
|
安全 Java Linux
(七)Java网络编程-IO模型篇之从BIO、NIO、AIO到内核select、epoll剖析!
IO(Input/Output)方面的基本知识,相信大家都不陌生,毕竟这也是在学习编程基础时就已经接触过的内容,但最初的IO教学大多数是停留在最基本的BIO,而并未对于NIO、AIO、多路复用等的高级内容进行详细讲述,但这些却是大部分高性能技术的底层核心,因此本文则准备围绕着IO知识进行展开。
|
22天前
|
Java Android开发 C++
🚀Android NDK开发实战!Java与C++混合编程,打造极致性能体验!📊
【7月更文挑战第28天】在 Android 开发中, NDK 让 Java 与 C++ 混合编程成为可能, 从而提升应用性能。**为何选 NDK?** C++ 在执行效率与内存管理上优于 Java, 特别适合高性能需求场景。**环境搭建** 需 Android Studio 和 NDK, 工具如 CMake。**JNI** 构建 Java-C++ 交互, 通过声明 `native` 方法并在 C++ 中实现。**实战** 示例: 使用 C++ 计算斐波那契数列以提高效率。**总结** 混合编程增强性能, 但增加复杂性, 使用前需谨慎评估。
58 4
|
24天前
|
网络协议 程序员 视频直播
|
25天前
|
Java
如何在Java中实现多线程的Socket服务器?
在Java中,多线程Socket服务器能同时处理多个客户端连接以提升并发性能。示例代码展示了如何创建此类服务器:监听指定端口,并为每个新连接启动一个`ClientHandler`线程进行通信处理。使用线程池管理这些线程,提高了效率。`ClientHandler`读取客户端消息并响应,支持简单的文本交互,如发送欢迎信息及处理退出命令。
|
3天前
|
设计模式 存储 Java
掌握Java设计模式的23种武器(全):深入解析与实战示例
掌握Java设计模式的23种武器(全):深入解析与实战示例
|
1月前
|
缓存 监控 Java
Java虚拟机(JVM)性能调优实战指南
在追求软件开发卓越的征途中,Java虚拟机(JVM)性能调优是一个不可或缺的环节。本文将通过具体的数据和案例,深入探讨JVM性能调优的理论基础与实践技巧,旨在为广大Java开发者提供一套系统化的性能优化方案。文章首先剖析了JVM内存管理机制的工作原理,然后通过对比分析不同垃圾收集器的适用场景及性能表现,为读者揭示了选择合适垃圾回收策略的数据支持。接下来,结合线程管理和JIT编译优化等高级话题,文章详细阐述了如何利用现代JVM提供的丰富工具进行问题诊断和性能监控。最后,通过实际案例分析,展示了性能调优过程中可能遇到的挑战及应对策略,确保读者能够将理论运用于实践,有效提升Java应用的性能。 【
125 10
|
29天前
|
缓存 Java 编译器
Java演进问题之JVMCI JIT编译器与JVM的交互如何解决
Java演进问题之JVMCI JIT编译器与JVM的交互如何解决
|
23天前
|
网络协议 Python
告别网络编程迷雾!Python Socket编程基础与实战,让你秒变网络达人!
【7月更文挑战第27天】在网络编程的广阔天地中,Socket编程常被视为一道难关。但用Python这把钥匙,我们可以轻松入门。Socket作为网络通信的基石,在Python中通过`socket`模块封装了底层细节,简化了开发过程。以下是一个基本的TCP服务器与客户端的示例,展示了如何建立连接、收发数据及关闭连接。为了应对实际场景中的并发需求,我们还可以借助多线程技术来提升服务器处理能力。掌握了这些基础知识后,你将逐步揭开网络编程的神秘面纱,踏上编程高手之路!
23 0