XSocket的学习和总结

xSocket是一个易于使用的基于NIO库来构建高性能，可扩展的网络应用。它支持写入以及服务器端的应用，以直观的方式客户端应用程序。检测问题，如低水平NIO选择编程，连接池管理，连接超时被封装的xSocket。

我从它的官网上面下载了两个JAR一个是其核心JAR包 xSocket (core) 下载地址是：http://sourceforge.net/projects/xsocket/files/xsocket%202.x/2.7.2/xSocket-2.7.2.jar/download

另外一个JAR包是：xSocket multiplexed 下载地址是http://sourceforge.net/projects/xsocket/files/xsocket%202.x%20-%20multiplexed/2.1.5/xSocket-multiplexed-2.1.5.jar/download （这个JAR包比较小）

先掌握其core部分然后再去学习其扩展部分的功能！

随着xSocket你可以编写高性能，可扩展的客户端和服务器组件的自定义协议如SMTP服务器，代理服务器或客户端和服务器组件是一个基于。

IDataHandler ：服务端或者客户端端数据处理类；

IConnectHandler 服务端或者客户端连接成功是处理操作。

IIdleTimeoutHandler 请求处理超时才操作。

IConnectionTimeoutHandler连接超时的操作

IDisconnectHandler 连接断开时的操作

IBlockingConnection 阻塞模式的连接

INonblockingConnection 非阻塞模式的连接

XSocket的ongoing实例：

服务端数据处理类：

Java代码

XSocket的学习和总结

package com.easyway.space.sockets.xsocket;
import java.io.IOException;
import java.nio.BufferUnderflowException;
import java.nio.channels.ClosedChannelException;
import org.xsocket.MaxReadSizeExceededException;
import org.xsocket.connection.IConnectHandler;
import org.xsocket.connection.IConnectionTimeoutHandler;
import org.xsocket.connection.IDataHandler;
import org.xsocket.connection.IDisconnectHandler;
import org.xsocket.connection.IIdleTimeoutHandler;
import org.xsocket.connection.INonBlockingConnection;
public class ServerHandler implements IDataHandler ,IConnectHandler ,IIdleTimeoutHandler ,IConnectionTimeoutHandler,IDisconnectHandler {
@Override
public boolean onConnect(INonBlockingConnection nbc) throws IOException,
BufferUnderflowException, MaxReadSizeExceededException {
String remoteName=nbc.getRemoteAddress().getHostName();
System.out.println("服务器信息 : 客户端 " + remoteName + " 已经连接...");
return true;
}
@Override
public boolean onDisconnect(INonBlockingConnection nbc) throws IOException {
// String remoteName=nbc.getRemoteAddress().getHostName();

// System.out.println("服务器信息:客户端 "+remoteName+" 已经断开.");
return false;
}
@Override
public boolean onData(INonBlockingConnection nbc) throws IOException,
BufferUnderflowException, ClosedChannelException,
MaxReadSizeExceededException {
String data=nbc.readStringByDelimiter("|");
nbc.write("--|server:receive data from client sucessful| -----");
nbc.flush();
System.out.println(data);
return true;
}
@Override
public boolean onIdleTimeout(INonBlockingConnection connection) throws IOException {
// TODO Auto-generated method stub
return false;
}
@Override
public boolean onConnectionTimeout(INonBlockingConnection connection) throws IOException {
// TODO Auto-generated method stub
return false;
}
}

服务端类：

Java代码

XSocket的学习和总结

package com.easyway.space.sockets.xsocket;
import java.net.InetAddress;
import java.util.Map;
import java.util.Map.Entry;
import org.xsocket.connection.IServer;
import org.xsocket.connection.Server;
import org.xsocket.connection.IConnection.FlushMode;
public class XSocketServer {
private static final int PORT = 8014;
public static void main(String[] args) throws Exception {
//注意其构造方法有多个。一般是使用这种构造方法出来的！
//不过要注意一下java.net.InetAddress这个类的使用在初始化的时候需要捕获异常
//可能是这个绑定的主机可能不存在之类的异常即UnknowHostNameException
InetAddress address=InetAddress.getByName("localhost");
//创建一个服务端的对象
IServer srv = new Server(address,PORT,new ServerHandler());
//设置当前的采用的异步模式
srv.setFlushmode(FlushMode.ASYNC);
try{
// srv.run();
// the call will not return
// ... or start it by using a dedicated thread
srv.start(); // returns after the server has been started
System.out.println("服务器" + srv.getLocalAddress() +":"+PORT);
Map<String, Class> maps=srv.getOptions();
if(maps!=null){
for (Entry<String, Class> entry : maps.entrySet()) {
System.out.println("key= "+entry.getKey()+" value ="+entry.getValue().getName());
}
}
System.out.println("日志: " + srv.getStartUpLogMessage());
}catch(Exception e){
System.out.println(e);
}
}
}

客户端数据处理类：

Java代码

XSocket的学习和总结

package com.easyway.space.sockets.xsocket;
import java.io.IOException;
import java.nio.BufferUnderflowException;
import java.nio.channels.ClosedChannelException;
import org.xsocket.MaxReadSizeExceededException;
import org.xsocket.connection.IConnectHandler;
import org.xsocket.connection.IDataHandler;
import org.xsocket.connection.IDisconnectHandler;
import org.xsocket.connection.INonBlockingConnection;
public class ClientHandler implements IDataHandler ,IConnectHandler ,IDisconnectHandler {
@Override
public boolean onConnect(INonBlockingConnection nbc) throws IOException,
BufferUnderflowException, MaxReadSizeExceededException {
String remoteName=nbc.getRemoteAddress().getHostName();
System.out.println("remoteName "+remoteName +" has connected ！");
return true;
}
@Override
public boolean onDisconnect(INonBlockingConnection nbc) throws IOException {
// TODO Auto-generated method stub
return false;
}
@Override
public boolean onData(INonBlockingConnection nbc) throws IOException,
BufferUnderflowException, ClosedChannelException,
MaxReadSizeExceededException {
String data=nbc.readStringByDelimiter("|");
nbc.write("--|Client:receive data from server sucessful| -----");
nbc.flush();
System.out.println(data);
return true;
}
}

客户端类：

Java代码

XSocket的学习和总结

package com.easyway.space.sockets.xsocket;
import java.io.IOException;
import org.xsocket.connection.BlockingConnection;
import org.xsocket.connection.IBlockingConnection;
import org.xsocket.connection.INonBlockingConnection;
import org.xsocket.connection.NonBlockingConnection;
public class XSocketClient {
private static final int PORT = 8014;
public static void main(String[] args) throws IOException {
//采用非阻塞式的连接
INonBlockingConnection nbc = new NonBlockingConnection("localhost", PORT, new ClientHandler());
//采用阻塞式的连接
//IBlockingConnection bc = new BlockingConnection("localhost", PORT);
//一个非阻塞的连接是很容易就变成一个阻塞连接
IBlockingConnection bc = new BlockingConnection(nbc);
//设置编码格式
bc.setEncoding("UTF-8");
//设置是否自动清空缓存
bc.setAutoflush(true);
//向服务端写数据信息
for (int i = 0; i < 100; i++) {
bc.write(" client | i |love |china !..." +i);
}
//向客户端读取数据的信息
byte[] byteBuffers= bc.readBytesByDelimiter("|", "UTF-8");
//打印服务器端信息
System.out.println(new String(byteBuffers));
//将信息清除缓存，写入服务器端
bc.flush();
bc.close();
}
}

XSocket的学习和总结

继续阅读

Java网络编程TCP 、建立Socket连接，客户端和服务端基本数据传输

Java网络爬虫之Jsoup解析

接口API设计的注意事项

java ServerSocket 用法详解(一) java ServerSocket 用法详解(一)

Netty-实现RPC框架Netty实现RPC

Netty网络编程二：Netty概述以及入门案例目录一：概述二：入门案例

Java网络编程学习复习总结（二）-2021-05-31

使用isReachable方法探测主机是否可以连通

java 在netbeans平台中中文乱码问题

什么情况下适合用UDP协议，什么情况下适合用TCP协议

java网络编程(三)----同步非阻塞nio及reactor模型

Java网络编程（9）NIO - 群聊系统

Java网络编程（5）NIO - Buffer详解

Netty组件-ByteBuf

http 协议和 https 协议的原理http 通信协议的基本原理Http 协议的特点Https 协议基本分析逆向推导 https 的设计过程Https 原理分析https 应用实战

定制accept方法