基于TCP／UDP的NIO服务端／客户端代码实现damo（java）
1.TCP的NIO服务端代码实现DAMO（java）
package cgz.nio;
import java.io.IOException;
import java.net.InetSocketAddress;
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.Date;
import java.util.Iterator;
/**
* 基于tcp的nio服务端实现Damo
* @author chris
*
*/
public class TcpNioServer {
//通道管理器
private Selector selector;
/**
* 获得一个ServerSocket通道，并对该通道做一些初始化的工作
* @param port 绑定的端口号
* @throws IOException
*/
public void initServer(intport) throws IOException {
// 获得一个ServerSocket通道
ServerSocketChannel serverChannel = ServerSocketChannel.open();
// 设置通道为非阻塞
serverChannel.configureBlocking(false);
// 将该通道对应的ServerSocket绑定到port端口
serverChannel.socket().bind(new InetSocketAddress(port));
// 获得一个通道管理器
this.selector = Selector.open();
//将通道管理器和该通道绑定，并为该通道注册SelectionKey.OP_ACCEPT事件,注册该事件后，
//当该事件到达时，selector.select()会返回，如果该事件没到达selector.select()会一直阻塞。
serverChannel.register(selector, SelectionKey.OP_ACCEPT);
}
/**
* 采用轮询的方式监听selector上是否有需要处理的事件，如果有，则进行处理
* @throws IOException
*/
public void listen()throws IOException {
System.out.println("服务端启动成功！");
// 轮询访问selector
while (true) {
//当注册的事件到达时，方法返回；否则,该方法会一直阻塞
selector.select();
// 获得selector中选中的项的迭代器，选中的项为注册的事件
Iterator<SelectionKey> ite = this.selector.selectedKeys().iterator();
while (ite.hasNext()) {
SelectionKey key = (SelectionKey)ite.next();
// 删除已选的key,以防重复处理
ite.remove();
// 客户端请求连接事件
if (key.isAcceptable()) {
ServerSocketChannel server = (ServerSocketChannel)key
.channel();
// 获得和客户端连接的通道
SocketChannel channel =server.accept();
// 设置成非阻塞
channel.configureBlocking(false);
//在这里可以给客户端发送信息哦
channel.write(ByteBuffer.wrap(new String("向客户端发送了一条信息").getBytes()));
//在和客户端连接成功之后，为了可以接收到客户端的信息，需要给通道设置读的权限。
channel.register(this.selector, SelectionKey.OP_READ);
// 获得了可读的事件
} else if (key.isReadable()) {
read(key);
}
}
}
}
/**
* 处理读取客户端发来的信息 的事件
* @param key
* @throws IOException
*/
public void read(SelectionKeykey) throws IOException{
// 服务器可读取消息:得到事件发生的Socket通道
SocketChannel channel = (SocketChannel)key.channel();
// 创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate(10);
channel.read(buffer);
byte[] data =buffer.array();
String msg = new String(data).trim();
System.out.println(new Date().toString() +" 服务端收到信息："+msg);
ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());
channel.write(outBuffer);// 将消息回送给客户端
}
/**
* 启动服务端测试
* @throws IOException
*/
public static void main(String[] args) throws IOException {
TcpNioServer server = new TcpNioServer();
server.initServer(8000);
server.listen();
}
}
2.TCP的NIO客户端代码实现DAMO（java）
package cgz.nio;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.Date;
import java.util.Iterator;
/**
* 基于tcp的nio客户端实现Damo
* @author chris
*
*/
public class TcpNioClient {
//通道管理器
private Selector selector;
/**
* 获得一个Socket通道，并对该通道做一些初始化的工作
* @param ip 连接的服务器的ip
* @param port 连接的服务器的端口号
* @throws IOException
*/
public void initClient(Stringip,intport)throws IOException {
// 获得一个Socket通道
SocketChannel channel = SocketChannel.open();
// 设置通道为非阻塞
channel.configureBlocking(false);
// 获得一个通道管理器
this.selector = Selector.open();
// 客户端连接服务器,其实方法执行并没有实现连接，需要在listen（）方法中调
//用channel.finishConnect();才能完成连接
channel.connect(new InetSocketAddress(ip,port));
//将通道管理器和该通道绑定，并为该通道注册SelectionKey.OP_CONNECT事件。
channel.register(selector, SelectionKey.OP_CONNECT);
}
/**
* 采用轮询的方式监听selector上是否有需要处理的事件，如果有，则进行处理
* @throws IOException
*/
public void listen()throws IOException {
// 轮询访问selector
while (true) {
// 选择一组可以进行I/O操作的事件，放在selector中,客户端的该方法不会阻塞，
//这里和服务端的方法不一样，查看api注释可以知道，当至少一个通道被选中时，
//selector的wakeup方法被调用，方法返回，而对于客户端来说，通道一直是被选中的
selector.select();
// 获得selector中选中的项的迭代器
Iterator<SelectionKey> iter = this.selector.selectedKeys().iterator();
while (iter.hasNext()) {
SelectionKey key = (SelectionKey)iter.next();
// 删除已选的key,以防重复处理
iter.remove();
// 连接事件发生
if (key.isConnectable()) {
SocketChannel channel = (SocketChannel)key
.channel();
// 如果正在连接，则完成连接
if(channel.isConnectionPending()){
channel.finishConnect();
}
// 设置成非阻塞
channel.configureBlocking(false);
//在这里可以给服务端发送信息哦
channel.write(ByteBuffer.wrap(new String("向服务端发送了一条信息").getBytes()));
//在和服务端连接成功之后，为了可以接收到服务端的信息，需要给通道设置读的权限。
channel.register(this.selector, SelectionKey.OP_READ);
// 获得了可读的事件
} else if (key.isReadable()) {
read(key);
}
}
}
}
/**
* 处理读取服务端发来的信息 的事件
* @param key
* @throws IOException
* @throws InterruptedException
*/
public void read(SelectionKeykey)throws IOException{
// 服务器可读取消息:得到事件发生的Socket通道
SocketChannel channel = (SocketChannel)key.channel();
// 创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate(10);
channel.read(buffer);
byte[] data =buffer.array();
String msg = new String(data).trim();
System.out.println(new Date().toString() +" 客户端收到信息："+msg);
ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());
channel.write(outBuffer);// 将消息回送给客户端
try {
Thread.sleep(1000);
} catch (InterruptedExceptione) {
e.printStackTrace();
}
}
/**
* 启动客户端测试
* @throws IOException
*/
public static void main(String[] args) throws IOException {
TcpNioClient client = new TcpNioClient();
client.initClient("localhost",8000);
client.listen();
}
}
3.UDP的NIO服务端代码实现DAMO（java）
package cgz.nio;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.Date;
import java.util.Iterator;
/**
* 基于udp的nio服务端实现Damo
* @author chris
*
*/
public class UdpNioServer {
//通道管理器
private Selector selector;
/**
* 获得一个ServerSocket通道，并对该通道做一些初始化的工作
* @param port 绑定的端口号
* @throws IOException
*/
public void initServer(intport)throws IOException {
// 获得一个ServerSocket通道
DatagramChannel serverChannel = DatagramChannel.open();
// 设置通道为非阻塞
serverChannel.configureBlocking(false);
// 将该通道对应的ServerSocket绑定到port端口
serverChannel.socket().bind(new InetSocketAddress(port));
// 获得一个通道管理器
this.selector = Selector.open();
serverChannel.register(selector, SelectionKey.OP_READ);
}
/**
* 采用轮询的方式监听selector上是否有需要处理的事件，如果有，则进行处理
* @throws IOException
*/
public void listen()throws IOException {
System.out.println("服务端启动成功！");
// 轮询访问selector
while (true) {
//当注册的事件到达时，方法返回；否则,该方法会一直阻塞
selector.select();
// 获得selector中选中的项的迭代器，选中的项为注册的事件
Iterator<SelectionKey> ite = this.selector.selectedKeys().iterator();
while (ite.hasNext()) {
SelectionKey key = (SelectionKey)ite.next();
// 删除已选的key,以防重复处理
ite.remove();
// 获得了可读的事件
if (key.isReadable()) {
read(key);
}
}
}
}
/**
* 处理读取客户端发来的信息 的事件
* @param key
* @throws IOException
*/
public void read(SelectionKeykey)throws IOException{
// 服务器可读取消息:得到事件发生的Socket通道
DatagramChannel channel = (DatagramChannel)key.channel();
// 设置成非阻塞
channel.configureBlocking(false);
// 创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate(10);
SocketAddress client = channel.receive(buffer);
byte[] data =buffer.array();
String msg = new String(data).trim();
System.out.println(new Date().toString() +" 服务端收到信息："+msg);
ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());
channel.send(outBuffer,client);// 将消息回送给客户端
}
/**
* 启动服务端测试
* @throws IOException
*/
public static void main(String[] args) throws IOException {
UdpNioServer server = new UdpNioServer();
server.initServer(9000);
server.listen();
}
}
4.UDP的NIO客户端代码实现DAMO（java）
package cgz.nio;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.Date;
import java.util.Iterator;
/**
* 基于udp的nio客户端实现Damo
* @author chris
*
*/
public class UdpNioClient {
//通道管理器
private Selector selector;
/**
* 获得一个Socket通道，并对该通道做一些初始化的工作
* @param ip 连接的服务器的ip
* @param port 连接的服务器的端口号
* @throws IOException
*/
public void initClient(Stringip,intport)throws IOException {
// 获得一个Socket通道
DatagramChannel channel = DatagramChannel.open();
// 设置通道为非阻塞
channel.configureBlocking(false);
// 获得一个通道管理器
this.selector = Selector.open();
channel.connect(new InetSocketAddress(ip,port));
//在这里可以给服务端发送信息哦
channel.write(ByteBuffer.wrap(new String("向服务端发送了一条信息").getBytes()));
//将通道管理器和该通道绑定，并为该通道注册SelectionKey.OP_READ事件。
channel.register(selector, SelectionKey.OP_READ);
}
/**
* 采用轮询的方式监听selector上是否有需要处理的事件，如果有，则进行处理
* @throws IOException
*/
public void listen()throws IOException {
// 轮询访问selector
while (true) {
selector.select();
// 获得selector中选中的项的迭代器
Iterator<SelectionKey> iter = this.selector.selectedKeys().iterator();
while (iter.hasNext()) {
SelectionKey key = (SelectionKey)iter.next();
// 删除已选的key,以防重复处理
iter.remove();
// 获得了可读的事件
if (key.isReadable()) {
read(key);
}
}
}
}
/**
* 处理读取服务端发来的信息的事件
* @param key
* @throws IOException
*/
public void read(SelectionKeykey)throws IOException{
// 服务器可读取消息:得到事件发生的Socket通道
DatagramChannel channel = (DatagramChannel)key.channel();
// 创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate(10);
channel.read(buffer);
byte[] data =buffer.array();
String msg = new String(data).trim();
System.out.println(new Date().toString() +" 客户端收到信息："+msg);
ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());
channel.write(outBuffer);// 将消息回送给客户端
try {
Thread.sleep(1000);
} catch (InterruptedExceptione) {
e.printStackTrace();
}
}
/**
* 启动客户端测试
* @throws IOException
*/
public static void main(String[] args) throws IOException {
UdpNioClient client = new UdpNioClient();
client.initClient("localhost",9000);
client.listen();
}
}
基于TCP／UDP的NIO服务端／客户端代码实现damo（java）相关推荐
- 网络云盘项目——HTTP接口介绍、功能介绍、服务端/客户端代码解析
一.本文目的 本项目分为6篇博客文章完成: 1.项目总体介绍:https://blog.csdn.net/qq_41453285/article/details/107871393. 2.Redis部 ...
- Linux C语言：用零拷贝技术实现TCP代理（源代码+测试服务端客户端代码）
目录 test-server-client Makefile eproxy-original.c eproxy.c list.h https://github.com/Rtoax/test/tree/ ...
- netty java_GitHub - leihuazhe/Java11-Netty-Demo: 基于Java11 构建的 netty 服务端客户端 模块化例子...
Java11-Netty-Demo Java11 基于maven构建的简单的服务端客户端分离模块调用的例子 Java 11 从 Java9 开始引入了模块化的概念.使用Java11 也需要以模块化的方 ...
- tcp服务器 中转,TCP中转站TCP端口中转工具(服务端+客户端)
软件简介 Soft Introduction 服务端软件使用说明 TCP中转站服务端软件在压缩包的Tra nsferServer文件夹中,将压缩包解压后,首先编辑TransferServer．ini文 ...
- Python Django断点下载(服务端/客户端)
断点下载 背景 断点续传/断点下载一直是每个系统最实用的功能,最近公司在复杂的网络环境(国外vps)下载东西遇到问题,有些文件下载的时候很慢,并且可能会下不下来,这种情况对一个系统的稳定性构成 ...
- TCP/IP网络编程之基于TCP的服务端/客户端（一）
TCP/IP网络编程之基于TCP的服务端/客户端(一) 理解TCP和UDP 根据数据传输方式的不同,基于网络协议的套接字一般分为TCP套接字和UDP套接字.因为TCP套接字是面向连接的,因此又称为基于 ...
- TCP/IP网络编程之基于TCP的服务端/客户端（二）
回声客户端问题 上一章TCP/IP网络编程之基于TCP的服务端/客户端(一)中,我们解释了回声客户端所存在的问题,那么单单是客户端的问题,服务端没有任何问题?是的,服务端没有问题,现在先让我们回顾下服 ...
- java nio非阻塞式网络通信入门案例 （nio服务端与bio多线程客户端(java/python）
nio服务端: 改进服务端 java客户端 python版本客户端: python客户端改进版(多线程执行) 注意:如果想把服务端程序放在自己的服务器上,要记得开放相应的端口,否则客户端会显示连接超时 ...
- MFC 基于SOCKET 实现服务端客户端一对多
注意:本篇文章源代码贴得很多,所以有点长,如果觉得阅读不方便,可以直接复制源代码到你的程序里去,也可以直接下载源码.后面整合了socket方法写了一个类,源码下载里没有. 源码下载:https://d ...
- TCP聊天文件服务器v2.2 - 服务端客户端套接字解决分包/粘包问题 - SocketQueue继承以及减少冗余
TCP聊天+传输文件服务器服务器套接字v2.2 整个图当封面吧 所有版本记录: v1.0 : TCP聊天服务器套接字|PyQt5+socket(TCP端口映射+端口放行)+logging+Thread ...
最新文章
- SP-1. 五月学习计划（study plan）
- 使用特殊的技术更新数据库（ABAP）
- Hive hang without response
- qpushbutton里面的文字怎么换行_ipad读PDF必备，OCR局部识别文字并快速提取，免费的buff你要不要？...
- 在linux里如何建立一个快捷方式，连接到另一个目录
- Python-序列常用方法 + * += extend append方法区别
- js去除字符串空格(空白符)
- pytorch accuracy和Loss 的计算
- java 倒计时_Java倒计时实现的三种简单方式
- python深拷贝与浅拷贝
- 育碧遭黑客攻击：用户账号被窃
- 【苦练基本功】代码整洁之道 pt1（第1章-第3章）
- 李永乐（八）齐次线性方程组——笔记
- 软件需求分析——需求的理论基础
- 61850 中变电站的配置进行了研究和设计
- 微信小程序CSS Flexbox(弹性盒子)布局模块
- 招标文件和竞争性谈判文件区别
- USB充电智能识别及自动转换芯片
- Honeywell霍尼韦尔EDA61K扫码App适配 、 广播协议适配（uniapp版）安卓可参考
- 提供NEC电子全球首推支持USB3.0主控系统芯片