一个自己倒腾的简单的通信框架（目前只是基于请求响应模式），集成底层的API，目的在于提高通信层的开发效率。该通信框架包括如下几个功能：
1.服务端采用NIO模式，提高通信速率
2.内部提供可选连接池方式，尽可能的将连接重用，提高开发效率。
3.提供过滤器自定义
4.业务处理层自定义
5.提供负载均衡
6.连接选择器与消息选择器分离
7.客户端采用连接池模式，具有自动识别服务端是否存活的功能。
因为环境受限，自己在自己的机子上测试了一下，16分钟，8个客户端，一共640万次简单请求，错误率基本为0
机子的配置是：CPU：2.93G双核，内存：2G内存，操作系统：ununtu10.10
写的还不是很好，如果大家对java写通信方面的东西比较感兴趣的可以私信交流^_^
下个写一个小Demo，首先我们定义个服务端的业务对象ServerHandler实现框架的FPHandler接口，，主要是从客户端接收消息以后，将当前时间和客户端发送过来的消息一并发给客户端，代码如下：
package com.foolfish.Zfocomint.test;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.text.SimpleDateFormat;
import java.util.Date;
import com.foolfish.comint.handler.FPHandler;
import com.foolfish.comint.session.FPSession;
/**
* 服务端业务处理对象，实现自自FPHandler接口
* messRecv，接收消息时候触发的方法
* messSend，发送消息时候出发的方法
* sessionClosed,链接关闭触发的方法
* sessionCreated,链接创建出发的方法
* @author foolfish
*
*/
public class ServerHandler implements FPHandler{
@Override
public void messRecv(FPSession session, byte[] mess) {
try {
// 处理接收客户端的消息
String m = new String(mess,"utf-8");
/*************************************
* 此处可以做具体的业务处理，demo当中就省略了，
* 只是简单的将客户端的信息返回
*************************************/
// 向客户端回写信息
String date = new SimpleDateFormat("yyyyMMdd HH:mm:ss").format(new Date());
session.write(("服务端返回消息"+ date +m).getBytes("utf-8"));
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void messSend(FPSession session, byte[] mess) {
// TODO Auto-generated method stub
}
@Override
public void sessionClosed(FPSession session) {
// TODO Auto-generated method stub
}
@Override
public void sessionCreated(FPSession session) {
// TODO Auto-generated method stub
}
}
定义服务端的启动方法，ServerStart
public class ServerStart {
public static void main(String[] args) throws Exception{
// 启动服务端,采用NIO模式
FPAcceptor acceptor = new FPNIOAcceptor();
// 绑定业务处理类
acceptor.setHandlerClass(ServerHandler.class);
// 设置连接池大小
acceptor.setPoolSize(10);
// 设置是否采用连接池（默认使用单链接方式）
acceptor.setIsPool(true);
// 设置负载均衡器（该功能未做性能测试，功能已经完成）
//acceptor.setLbServer(new InetSocketAddress("127.0.0.1", 4320));
// 设置服务端口
acceptor.setPort(4331);
// 启动服务
acceptor.startServer();
}
}
下面定义个客户端：客户端使用一个while循环，不断向服务端发送消息（模拟不断的请求）
/**
* @param args
* @throws IOException
* @throws FPComException
*/
public static void main(String[] args){
String line = "Hello";
int i = 0;
int j = 0;
while(true){
try {
// 设置服务端的地址和端口号
FPIOConnector conn = new FPIOConnector(true, new FPInetAddress("127.0.0.1", 4331));
// 设定自动重发次数（对于延迟等错误情况可以选择自动重发）
conn.setRetryCount(2);
// 发送并接收返回的结果信息，并统计错误率
System.out.println(new String(conn.request(line.getBytes("utf-8")),"utf-8")+"共请求"+(i++)+"次，错误"+(j)+"次");
}catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (FPComException e) {
j++;
continue;
}
}
}
运行服务端启动方法，ServerStart.java，然后运行客户端Client.java，就可以看到运行结果如下
服务端返回消息20110226 20:53:33Hello共请求5445次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5446次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5447次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5448次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5449次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5450次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5451次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5452次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5453次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5454次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5455次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5456次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5457次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5458次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5459次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5460次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5461次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5462次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5463次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5464次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5465次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5466次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5467次，错误0次
服务端返回消息20110226 20:53:33Hello共请求5468次，错误0次
分享到：
相关推荐
很好的一个关于C# socket通信的一个框架，这个是我朋友写的，我想肯定能够给你带来惊喜！
Java中的TCP和UDP Socket通信是网络编程的基础，用于在不同设备之间建立可靠的数据传输通道。TCP（Transmission Control Protocol）...对于初学者，通过研究这个框架，也能深入理解TCP和UDP Socket通信的原理和实践。
本框架提供了一个简单的起点，帮助开发者快速搭建自己的TCP服务。以下是对该框架的详细解析： 一、TCP基础 TCP是一种面向连接的、可靠的、基于字节流的传输层通信协议。它通过三次握手建立连接，确保数据的无丢失、...
.net 稳定 高效 易用 可同步 TCP 通信框架 使用平台： WinXP,WIN7,WIN8,WINCE,WINPHONE。 使用.net 2.0 框架。 主要功能介绍： 1、可以代替 Oracle，Mysql客户端 在不安装Oracle，MySql客户端的情况下访问， ...
TCP通信框架是网络通信中的重要组成部分，特别是在云通信、音频和视频传输等领域有着广泛的应用。本文将详细解析TCP通信框架的各个层面，包括其概述、整体结构、通信方式以及通信安全。 1. 概述 TCP（Transmission ...
Mina，全称为“Apache MINA (Multipurpose Infrastructure for Network Applications)”，是由Apache软件基金会开发的开源项目，它为Java开发者提供了一个高级的网络通信框架。Mina不仅支持TCP/IP协议，还支持UDP/IP...
本资源“MFC-TCP.rar”聚焦于如何在Microsoft Foundation Classes (MFC)框架下实现TCP通信，这对于理解和实践Windows环境下C++编程的网络通信具有很高的价值。 MFC是微软提供的一个C++类库，它封装了Windows API，...
本项目是基于C++信号槽框架xsignalslot的TCP...该项目适用于基于C++信号槽框架xsignalslot设计的TCP通信框架的开发和设计，为用户提供了一个丰富的资源库，包含多种文件类型，方便进行TCP通信相关的开发和设计工作。
本示例中，我们有一个使用C++编写的简单TCP通信程序，包含两个文件：sever.cpp（服务器端）和client.cpp（客户端）。这个程序提供了一个基本的框架，便于初学者理解TCP通信的工作原理。 1. **TCP协议**： - TCP...
首先，TCP通信是一种面向连接的通信方式，它在数据传输前先建立连接，然后在连接上进行双向通信。这确保了数据的有序性和无丢失性，适用于需要高可靠性的应用，如文件传输、网页浏览等。 其次，套接字（SOCKET）是...
以上就是Unity个人TCP简单信息通信案例所涵盖的关键技术点，通过理解和实践这些知识点，你可以构建起一个基本的TCP通信框架，进一步实现复杂的游戏网络功能。这个案例是一个很好的起点，可以帮助开发者掌握TCP通信的...
基于CocoaAsyncSocket的tcp通信框架 文件内容和下面博文一致，可以先看文章，确认有用后再下载。 当然最好是自己实践一遍了。 http://blog.csdn.net/zhu410289616/article/details/46731605 ...
自己写的TCP异步通讯框架，对原来的进行封装，使得收发消息方便。
TCP通信的一个关键特性是它提供了数据的顺序传递和错误检查，确保数据无损、有序地到达目的地。 UDP（User Datagram Protocol）则是一种无连接的、不可靠的传输协议，它不保证数据的顺序或完整性，但相比TCP，其...
2. `packages` 可能是一个文件夹，包含了框架的不同模块或组件，每个子目录代表一个特定的功能或服务。 3. `architecture.pdf` 应该是一份文档，详细解释了框架的设计架构，包括服务器和客户端的组件结构、通信流程...
在Qt框架下实现多线程TCP通信是一种常见且高效的方法，尤其在处理实时性要求高、数据量大的网络应用中。以下将详细讲解Qt中如何进行多线程TCP通信，以及涉及的关键知识点。 首先，标题"qt 中 多线程tcp通信"表明...
SocketTcp_TcpSocket服务端框架是一个专为开发者设计的简单且通用性强的TCP服务器实现。这个框架旨在简化网络编程过程，让开发者能够快速构建自己的TCP服务应用，只需要对原有代码进行少量修改，即可轻松地将其集成...
而"libs"目录则包含了项目所依赖的外部库文件，这些库可能包含了实现TCP通信、加密算法、日志管理等功能的类库。 总的来说，这个TCP服务器框架是一个集成了多线程处理、加密通信和日志管理的完整系统，旨在提供安全...
Go语言，也被称为Golang，是由Google开发的一种静态类型的、编译式的、并发型的、垃圾回收的、C风格的编程语言。...结合`DxTcpServer-master`中的实例，你将能深入理解Go语言在TCP网络通信框架中的实践应用。
总的来说，这个项目提供了一个基础的TCP通信框架，对于初学者来说，可以通过它学习TCP通信的基本流程、数据交换方式以及简单的命令控制机制。进一步深入，可以在此基础上添加加密、身份验证等高级特性，或者优化...