xSocket是一个易于使用的基于NIO库来构建高性能，可扩展的网络应用。 它支持写入以及服务器端的应用，以直观的方式客户端应用程序。 检测问题，如低水平NIO选择编程，连接池管理，连接超时被封装的xSocket。
我从它的官网上面下载了两个JAR一个是其核心JAR包xSocket (core)
另外一个JAR包是：xSocket multiplexed
先掌握其core部分然后再去学习其扩展部分的功能！
随着xSocket你可以编写高性能，可扩展的客户端和服务器组件的自定义协议如SMTP服务器，代理服务器或客户端和服务器组件是一个基于。
IDataHandler ：服务端或者客户端端数据处理类；
IConnectHandler 服务端或者客户端连接成功是处理操作。
IIdleTimeoutHandler 请求处理超时才操作。
IConnectionTimeoutHandler连接超时的操作
IDisconnectHandler 连接断开时的操作
IBlockingConnection 阻塞模式的连接
INonblockingConnection 非阻塞模式的连接
XSocket的ongoing实例：
服务端数据处理类：
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;
/**
* 服务端定义数据的处理类
* @author longgangbai
*
*/
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 "+remoteName +" has connected ！");
return true;
}
/**
* 即如果失去连接应当如何处理？
*需要实现 IDisconnectHandler 这个接口
* 连接断开时的操作
*/
@Override
public boolean onDisconnect(INonBlockingConnection nbc) throws IOException {
return false;
}
/**
* 即这个方法不光是说当接收到一个新的网络包的时候会调用而且如果有新的缓存存在的时候也会被调用。而且
*The onData will also be called, if the connection is closed当连接被关闭的时候也会被调用的!
*/
@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;
}
}
服务端类：
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;
/**
* 采用XSocket通讯的服务端
* @author longgangbai
*
*/
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);
}
}
}
客户端数据处理类：
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;
/**
* 客户端定义数据的处理类
* @author longgangbai
*
*/
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;
}
}
客户端类：
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;
/**
* 客户端接收服务端信息
* @author longgangbai
* IBlockingConnection：这个的话就是不支持事件回调处理机制的！
*INonBlockingConnection:这个连接支持回调机制
*
*非阻塞的客户端是能够支持事件处理的方法的。即如果从网络通道中没有取到想要的数据就会自动退出程序
*/
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();
}
}
代码如上，如有问题，欢迎商讨， 谢谢！
分享到：
相关推荐
总之，这个资源包为你提供了一个很好的学习平台，通过实践和研究源码，你将能够深入理解Socket和XSocket编程，进一步提升你的网络编程技能。记得要结合理论知识和实际操作，才能更好地消化和掌握这些内容。
xSocket api 2.6.6version
NIO网络框架 xSocket
xsocket NIO框架示例 resources 中有相关的 资料。telnet服务测试教程。和相关jar
总结来说，这个压缩包提供的示例可能包括了如何使用xsocket和xlightweb库在服务器端和客户端实现WebSocket通信的具体代码。通过学习这些示例，开发者可以更好地理解WebSocket的工作原理，以及如何在实际项目中应用这...
"tcp协议使用xsocket的demo"是一个实践性强、教学价值高的项目，它涵盖了SpringBoot、TCP通信和模块化开发等多个核心知识点，对于想要深入了解Java网络编程和SpringBoot集成的开发者来说，这是一个极好的学习资源。
xSocket-2.5.4-sources.jar ， 2.5.4版的源代码jar包，引入项目即可查看
总的来说，XSocket.rar文件提供了关于Socket编程、TCP/IP协议实现、客户端和服务器端交互以及多播功能的实战示例，对于学习和开发网络通信应用的程序员来说，这是一个宝贵的资源。通过研究这个项目，开发者可以深入...
socket通讯框架xsocket所需的jar包
下面是 xSocket 的一些核心功能和使用指南： 核心功能 xSocket 的核心功能支持面向流通信，主要抽象是 Connection 接口。通过 IBlockingConnection 或者 INonblockingConnection 对象进行数据的读写。在 record ...
xSocket是一个轻量级的基于nio的服务器框架用于开发高性能、可扩展、多线程的服务器。该框架封装了线程处理、异步读/写等方面。
轻量级JAVA scoket 服务器XSOCKET
Java NIO（New Input/Output）网络框架是一...通过学习和使用xSocket框架，开发者可以更好地理解和应用Java NIO，创建出高效、可靠的网络应用程序。在实际开发中，结合NIO的特性，可以显著提升网络应用的性能和稳定性。
常见NIO开源框架（MINA、xSocket）学习 基于io包的阻塞式socket通信代码简单，在连接数很少的情况下是一个不错的选择。不过实际应用中一个socket服务器采用传统的阻塞式socket方式通信可能会是一场灾难，一路...
它通过抽象出统一的API，隐藏了底层操作系统差异，降低了开发者的学习曲线和维护成本。 XSocket的核心特性在于其对Socket操作的封装。在C语言原生的Socket API中，开发者需要处理许多低级别的细节，如错误检查、套...
提到的三个文件分别代表了xSocket的不同版本：`xSocket-2.1.2-sources.jar` 包含的是2.1.2版本的源代码，这对于学习和调试非常有用；`xSocket-2.7.2.jar` 可能是一个更新的二进制版本，可能包含了更多的功能和优化...
3. 文档资料：包含了框架的使用指南、API文档以及设计原理等，帮助开发者更好地学习和使用xSocket。 4. 测试用例：验证框架功能的正确性，可作为开发过程中参考和调试的依据。 5. 配置文件：可能包含服务器配置、...
基于java的开发源码-NIO网络框架 xSocket.zip 基于java的开发源码-NIO网络框架 xSocket.zip 基于java的开发源码-NIO网络框架 xSocket.zip 基于java的开发源码-NIO网络框架 xSocket.zip 基于java的开发源码-NIO网络...
xSocket-multiplexed-2.1.5-sources.jarxSocket-multiplexed-2.1.5-sources.jarxSocket-multiplexed-2.1.5-sources.jarxSocket-multiplexed-2.1.5-sources.jarxSocket-multiplexed-2.1.5-sources.jarxSocket-...