学习 java nio ,自己建立一个 nio的聊天室程序。
服务器采用单一线程 轮训,accept的所有端口。
首先定义一个接口,处理 SelectionKey 上的事件。
static interface NioHandler {
/**
* 处理{@link SelectionKey#OP_ACCEPT}事件
*
* @param key
* @throws IOException
*/
void handleAccept(SelectionKey key) throws IOException;
/**
* 处理{@link SelectionKey#OP_READ}事件
*
* @param key
* @throws IOException
*/
void handleRead(SelectionKey key) throws IOException;
/**
* 处理{@link SelectionKey#OP_WRITE}事件
*
* @param key
* @throws IOException
*/
void handleWrite(SelectionKey key) throws IOException;
/**
* 处理IO 异常事件
* @param key
* @throws IOException
*/
void handleIoError(SelectionKey key) throws IOException;
}
服务器的run方法中处理io事件
@Override
public void run() {
InetSocketAddress address = new InetSocketAddress(mConfig.port);
try {
mSSC = ServerSocketChannel.open();
Selector selector = Selector.open();
mSSC.socket().bind(address);
mSSC.configureBlocking(false);
mSSCKey = mSSC.register(selector, SelectionKey.OP_ACCEPT);
while (true) {
int events = selector.select();
if (events == 0) {
continue; //忽略
}
Iterator<SelectionKey> it = selector.selectedKeys().iterator();
while(it.hasNext()) {
SelectionKey key = it.next();
it.remove();
if (key.isAcceptable()) {
mIoHandler.handleAccept(key);
} else if (key.isReadable()) {
mIoHandler.handleRead(key);
} else if (key.isWritable()) {
mIoHandler.handleWrite(key);
}else {
break;
}
}
Thread.yield();// 让出执行空间
}
} catch (IOException e) {
e.printStackTrace();
throw new ChatServerException(e);
}
}
IoHandler的实现类: ChatIoHandler
class ChatIoHandler implements NioHandler {
StringBuffer sb = new StringBuffer();
@Override
public void handleAccept(SelectionKey key) throws IOException {
ServerSocketChannel ssc = (ServerSocketChannel) key.channel();
SocketChannel client = ssc.accept();
if (client != null) {
client.configureBlocking(false);
System.out.println("Accept:"
+ client.socket().getRemoteSocketAddress().toString());
client.register(key.selector(), SelectionKey.OP_READ);
String address = client.socket().getRemoteSocketAddress()
.toString();
ChatServer.this.mChannelMap.put(address, client); // 加入map中
}
}
@Override
public void handleRead(SelectionKey key) throws IOException {
SocketChannel sc = (SocketChannel) key.channel();
System.out.println("Read from"
+ sc.socket().getRemoteSocketAddress() + " ");
ByteBuffer buffer = ByteBuffer.allocate(1024);
buffer.clear();
int len = 0;
StringBuffer sBuffer = new StringBuffer();
while ((len = sc.read(buffer)) > 0) {
buffer.flip();
sBuffer.append(new String(buffer.array(), 0, len));
}
//handle socket error;
if (len < 0) {
handleIoError(key);
}
String msg = sBuffer.toString();
if (sBuffer.length() > 0) {
System.out.println("Server receive:" + sBuffer.toString());
}
//command 设计模式
String[] args = msg.split(" ");
Command cmd = CommandFactory.getInstance().createCommand(args[0]);
cmd.handleCmd(key, ChatServer.this,args);
}
@Override
public void handleWrite(SelectionKey key) throws IOException {
// TODO Auto-generated method stub
SocketChannel sc = (SocketChannel) key.channel();
String address = sc.socket().getRemoteSocketAddress().toString();
System.out.println("handleWrite: " + address);
String msg = (String) key.attachment();
if (msg != null) {
int len = sc.write(ByteBuffer.wrap(msg.getBytes()));
if (len < 0) {
//handle error;
handleIoError(key);
}
key.attach(null);
key.interestOps(SelectionKey.OP_READ);
}
}
accept 一个 channel 后,向channel注册server端的 selector ,将感兴趣的事件设为OP_READ
并 将该channel 以socket address 为key 保存在Server端的一个map中。
handleRead中 使用 command 设计模式,将client端穿来的参数 args 解析为命令,调用具体的命令处理方法。
command 抽象类:
package com.tcl.chat.command;
import java.io.IOException;
import java.nio.channels.SelectionKey;
import com.tcl.chat.ChatServer;
public abstract class Command {
public abstract void handleCmd(SelectionKey key , ChatServer server,String[] args) throws IOException;
}
分享到:
相关推荐
NULL 博文链接:https://tmdpzc.iteye.com/blog/1737928
用java nio写的一个完整的、可运行的聊天室程序;复制代码到项目后可直接运行。
1,运行server.bat启动服务器,可以打开编辑,修改端口号 2,运行client.bat启动客户端,可以打开编辑,ip,和端口号 3,自己发送的信息,自己是看不到的,运行多个客户端,其他的客户端可以看得到的 4,修改封装...
1.学习时的一个聊天室程序,将服务端改为NIO机制 2.支持多人同时在线局域网聊天 3.知识面:JSwing,NIO,消息包加密,解密,单列模式的线程安全机制等.
服务端程序基于javaNIO,客户端程序基于旧IO,读完<<javaNIO>>后,导入eclipse即可运行,支持多人在线聊天,上下线通知.PS:非GUI程序,毕竟javaSwing用的少,不懂的地方大家可以一起讨论,评论必回!
基于java tcp socket通信的拆包和装包源码 功能 1)编写一个 NIO 群聊系统,实现服务器端和客户端之间的数据简单通讯(非阻塞) 2)实现多人群聊 3)服务器端:可以监测用户上线,离线,并实现消息转发功能 4)客户端:...
基于Java实现的端到端加密的聊天室系统完整源码+项目说明 【模块】 Netty实现的聊天客户端和服务器 NIO实现的聊天客户端和服务器 日志解密工具 【打包文件】 netty-chat-server.jar: Netty实现的服务器 netty-chat-...
ctrl + f5利用在http请求头中加入缓存控制:no-cache与Pargma:no-cache确保请求到前端缓存如Varnish代理缓存服务器。且ctrl + f5会避免请求浏览器自身缓存直接向目标网址发起请求DNS域名解析过程a)浏览器缓存b)...
java聊天室 2个目标文件,简单。 java模拟掷骰子2个 1个目标文件,输出演示。 java凭图游戏 一个目标文件,简单。 java求一个整数的因子 如题。 Java生成密钥的实例 1个目标文件 摘要:Java源码,算法相关,密钥 ...
1. NIO完成网络编程 1.1 Selector选择器老大 Selector 选择器,网络编程使用NIO的大哥!!! 服务器可以执行一个线程,运行Selector程序,进行监听操作。 新连接, 已经连接, 读取数据,写入数据 Selector常用...
java聊天室 2个目标文件,简单。 java模拟掷骰子2个 1个目标文件,输出演示。 java凭图游戏 一个目标文件,简单。 java求一个整数的因子 如题。 Java生成密钥的实例 1个目标文件 摘要:Java源码,算法相关,密钥 ...
提供了本书第13章的JSP聊天室实例的源程序; \char15\15-1\ Java Applet HelloWorld 提供了本书第15章的Java Applet HelloWorld的源程序; \char15\15-2\ 双缓冲图像技术例子 提供了本书第15章的双缓冲图像...
NaiveNet它是基于NIO网络模型设计完成的网络通信组件,这套组件可以让我们HTML5,类别小程序/小游戏以长连接(Web Socket)通信模式开发应用,面向需求的高度封装开发者如果您想做一个实时交互应用程序一个实时的小...