- 浏览: 276842 次
- 性别:
- 来自: 杭州
文章分类
- 全部博客 (153)
- unix (2)
- sql (3)
- pl/sql (1)
- cvs (1)
- core java (36)
- OOAD UML (1)
- XML (4)
- JDBC (5)
- Hibernate (1)
- HTML (1)
- javascript (2)
- servlet (2)
- jsp (1)
- AJAX (1)
- Struts1.x (0)
- Struts2.x (5)
- Spring (6)
- EJB (2)
- WebService (2)
- 生活 (2)
- 感情 (0)
- 其他 (9)
- jbuilder2005 (1)
- db2 (1)
- groovy (1)
- 银行业务 (1)
- Android (9)
- java设计模式 (8)
- J2SE (2)
- DataBase (4)
- lucene (2)
- java卡 (1)
- flex (3)
- 烹饪 (1)
- 测试 (1)
- java硬件 (2)
- upnp (3)
- S2SH lib (1)
- nio CshBBrain (1)
- socket (1)
- 二维码 (1)
- 热加载 (1)
- hadoop (3)
- NIO (1)
- 新银行前置机预研 (1)
- springmvc3 (1)
- jvm (1)
- sf (0)
最新评论
-
niwowl:
可以!
gson使用在android使用例子 -
smallbee:
xin_jmail 写道首先感谢楼主的文章,让我知道了lock ...
java ReentrantLock Condition调试记录 -
xin_jmail:
首先感谢楼主的文章,让我知道了lock.newConditio ...
java ReentrantLock Condition调试记录 -
smallbee:
brad2309 写道lz 你的两个messageReceiv ...
基于Apache Mina实现的TCP长连接和短连接实例 -
brad2309:
lz 你的两个messageReceived方法是不是错乱了
基于Apache Mina实现的TCP长连接和短连接实例
socket 客户端连接池实现
- 博客分类:
- core java
并对此文代码稍作修改,未经测试,只作参考。
自定义socket连接:
import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; import org.apache.log4j.Logger; /** * <p> * Title: socket连接的简单实现 * </p> * * <p> * Description: * </p> * * <p> * Copyright: 融博技术有限公司 2012 * </p> * * @author 袁泉锋HO174959 * @version 1.0 * @date Oct 15, 2012 * */ public class SocketConnection extends Socket { private static final Logger logger = Logger.getLogger("FrameLog"); /** * status false 繁忙 true 空闲 */ private boolean status = true; /** * 默认的构造函数 */ public SocketConnection() { super(); } /** * ConnectionAdapter constructor */ public SocketConnection(String host, int port) throws UnknownHostException, IOException { super(host, port); } /** * <Description>判断此连接是否空闲 * * @since Oct 15, 2012 * @return <Description>空闲返回ture,否则false * */ public boolean isFree() { return status; } /** * <Description> 当使用此连接的时候设置状态为false(忙碌) * * @since Oct 15, 2012 <Description> * */ public void setBusy() { this.status = false; } /** * <Description>当客户端关闭连接的时候状态设置为true(空闲),放回连接池 * * @since Oct 15, 2012 <Description> * */ public void close() { logger.info("ConnectionAdapter Close : set the status is free"); status = true; } /** * <Description>销毁连接 * @throws IOException * * @since Oct 15, 2012 <Description> * */ public void destroy() throws IOException { //Close socket connection super.close(); logger.info("ConnectionAdapter destroy!"); // System.out.println( "Close success " ); } }
连接池接口:
import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; /** * <p> * Title: 定义的抽象类,所有的子类必须单子模式去实现 * </p> * 统一方法为public ConnectionProvider newInstance(); * 连接提供器的抽象接口,每一个实现它的子类最好都是JAVABEAN, * 这样它的方法就可以是被外界控制 * <p> * Description: * </p> * * <p> * Copyright: 融博技术有限公司 2012 * </p> * * @author 袁泉锋HO174959 * @version 1.0 * @date Oct 15, 2012 * */ public interface SocketConnectionPoolInterface { public static final String SERVER_IP = "SERVER_IP_ADDRESS"; public static final String SERVER_PORT = "SERVER_IP_PORT"; public static final String MAX_SIZE = "MAX_SIZE"; public static final String MIN_SIZE = "MIN_SIZE"; /** *判断连接池内是否有连接 * @return true 有连接返回true,否则返回false */ public boolean isPooled(); /** * 当此方法被调用的时候提供一个 socket * @see Socket * @return Socket a Connection object. */ public SocketConnection getConnection() throws java.net.SocketException; /** * 连接池初始化 */ public void init() throws UnknownHostException, IOException; /** * 连接池重新启动 */ public void restart() throws UnknownHostException, IOException; /** * 注销连接池 */ public void destroy(); }
连接池接口实现:
import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; import java.util.Properties; import org.apache.log4j.Logger; /** * <p> * Title: 这是一个连接管理器的简单实现 * </p> * * <p> * Description: * </p> * * <p> * Copyright: 融博技术有限公司 2012 * </p> * * @author 袁泉锋HO174959 * @version 1.0 * @date Oct 15, 2012 * */ public class SocketConnectionPool implements SocketConnectionPoolInterface { private static final Logger logger = Logger.getLogger("FrameLog"); private Properties pro = null; private static SocketConnectionPoolInterface provider = null; private static Object object_lock = new Object(); private String ip; private String port; /** * 默认的最大连接数 */ private int max_size = 20; /** * 默认的最小连接数 */ private int min_size = 10; /** * Socket connection池数组 */ private SocketConnection[] socketpool = null; /** * 构造对象的时候初始化连接池 * @throws UnknownHostException 未知的主机异常 * @throws IOException */ private SocketConnectionPool(Properties pro) throws UnknownHostException, IOException { ip = pro.getProperty(SERVER_IP); port = pro.getProperty(SERVER_PORT); String max_size_s = pro.getProperty(MAX_SIZE); String min_size_s = pro.getProperty(MIN_SIZE); if (max_size_s != null) { max_size = Integer.parseInt(max_size_s); } if (min_size_s != null) { min_size = Integer.parseInt(min_size_s); } init(); //构造对象的时候初始化连接池 } /** * 判断是否已经池化 * @return boolean 如果池化返回ture,反之返回false */ public boolean isPooled() { if (socketpool != null) { return true; } else { return false; } } /** *返回一个连接 * @return a Connection object. */ public SocketConnection getConnection() { SocketConnection s = null; for (int i = 0; i < socketpool.length; i++) { if (socketpool[i] != null) { //如果有空闲的连接,返回一个空闲连接,如果没有,继续循环 if (socketpool[i].isFree()) { s = socketpool[i]; } else { continue; } } else { //如果连接为空,证明小于最小连接数,重新生成连接 try { s = socketpool[i] = new SocketConnection(ip, Integer .parseInt(port)); } catch (Exception e) { logger.error(e.getMessage()); //never throw } } } /*//TODO 如果连接仍旧为空的话,则超过了最大连接数 if (s == null) { try { //生成普通连接,由客户端自行关闭,释放资源,不再由连接池管理 s = new Socket(ip, Integer.parseInt(port)); } catch (Exception e) { //此异常永远不会抛出 } }*/ //TODO 如果连接仍旧为空的话,等待一会继续获取 while(s == null){ try { Thread.sleep(1000); s = this.getConnection(); } catch (InterruptedException e) { e.printStackTrace(); logger.error(e.getMessage()); } } s.setBusy(); return s; } /** * 初始化连接池 * @throws UnknownHostException 主机ip找不到 * @throws IOException 此端口号上无server监听 */ public void init() throws UnknownHostException, IOException { socketpool = new SocketConnection[max_size]; for (int i = 0; i < min_size; i++) { socketpool[i] = new SocketConnection(ip, Integer.parseInt(port)); logger.info(" . "); } logger.info("socketPool init success!"); } /** * 重新启动连接池 * @throws UnknownHostException * @throws IOException */ public void restart() throws UnknownHostException, IOException { destroy(); init(); } /** * 注销此连接池 */ public void destroy() { for (int i = 0; i < socketpool.length; i++) { if (socketpool[i] != null) { SocketConnection adapter = (SocketConnection) socketpool[i]; try { adapter.destroy(); } catch (IOException e) { logger.error(e.getMessage()); e.printStackTrace(); } logger.info(" . "); socketpool[i] = null; } } logger.info("SocketPool Destory success!"); } /** * 静态方法,生成此连接池实现的对象 * @param pro Properties 此连接池所需要的所有参数的封装 * @throws UnknownHostException 主机无法找到 * @throws IOException 与服务器无法建立连接 * @return ConnectionProvider 返回父类ConnectionProvider */ public static SocketConnectionPoolInterface newInstance(java.util.Properties pro) throws UnknownHostException, IOException { if (provider == null) { synchronized (object_lock) { if (provider == null) { provider = new SocketConnectionPool(pro); } } } return provider; } /** *设置系统属性 通过封装系统properties对象来封装所需要的不同值 * SERVER_IP,SERVER_PORT,MAX_SIZE,MIN_SIZE等父类定义的不同的参数 * @param pro Properties 传进来的系统属性 */ public void setProperties(Properties pro) { this.pro = pro; } }
连接池管理器:
import java.lang.reflect.*; import java.util.Properties; import org.apache.log4j.Logger; /** * <p> * Title: 连接管理器 * </p> * * <p> * Description: * </p> * * <p> * Copyright: 融博技术有限公司 2012 * </p> * * @author 袁泉锋HO174959 * @version 1.0 * @date Oct 15, 2012 * */ public class SocketConnectionManager { private static final Logger logger = Logger.getLogger("FrameLog"); //测试程序默认的连接池实现类 public static final String PROVIDER_CLASS = "com.rb.socketpool.MyConnectionProvider"; //测试程序的默认ip public static final String HOST = "127.0.0.1"; //测试程序的默认端口号 public static final String PORT = "9880"; /** * 注册钩子程序的静态匿名块,jvm退出的前一刻,调用ShutdownThread线程 */ static { Runtime runtime = Runtime.getRuntime(); Class c = runtime.getClass(); try { Method m = c.getMethod("addShutdownHook", new Class[] { Thread.class }); m.invoke(runtime, new Object[] { new ShutdownThread() }); } catch (NoSuchMethodException e) { logger.error(e.getMessage()); e.fillInStackTrace(); } catch (Exception e) { logger.error(e.getMessage()); e.printStackTrace(); } } /** * 默认的构造函数 */ public SocketConnectionManager() { } /** * <Description> 得到并初始化一个连接池 * 连接池的实现类通过系统参数来传递进来,通过命令行-DConnectionProvider=YourImplClass * 如果没有指定的实现的话,则采用系统默认的实现类 * 通过命令行传入的参数列表如下 * 对方主机名-DHost=192.168.0.200 * 对方端口号 -DPort=9880 * 最小连接数 -DMax_size=10 * 最大连结数 -DMin_size=20 * 以上的值可以改变,但是参数不能改变, * 最大连结数和最小连接数可以省略,默认值分别为20和10 * * @since Oct 15, 2012 * @return * @throws Exception <Description> * */ public static SocketConnectionPoolInterface getConnectionProvider() throws Exception { String provider_class = System.getProperty("ConnectionProvider"); if (provider_class == null){ provider_class = PROVIDER_CLASS; } String host = System.getProperty("Host"); if (host == null){ host = HOST; } String port = System.getProperty("port"); if (port == null){ port = PORT; } String max_size = System.getProperty("Max_size"); String min_size = System.getProperty("Min_size"); Properties pro = new Properties(); pro.setProperty(SocketConnectionPoolInterface.SERVER_IP, host); pro.setProperty(SocketConnectionPoolInterface.SERVER_PORT, port); if (max_size != null) { pro.setProperty(SocketConnectionPoolInterface.MAX_SIZE, max_size); } if (min_size != null) { pro.setProperty(SocketConnectionPoolInterface.MIN_SIZE, min_size); } //通过反射得到实现类 logger.info("Provider_class:" + provider_class); Class provider_impl = Class.forName(provider_class); //由于是单子模式,采用静态方法回调 Method m = provider_impl.getMethod("newInstance", new Class[] { java.util.Properties.class }); SocketConnectionPoolInterface provider = null; try { provider = (SocketConnectionPoolInterface) m.invoke(provider_impl, new Object[] { pro }); } catch (Exception e) { logger.error(e.getMessage()); e.printStackTrace(); } return provider; } /** * * <p> 一个钩子的线程: 在程序结束的时候调用注销连接池 </p> * <p> Description: </p> * <p> Copyright: Copyright Tarena(c) 2005 </p> * <p> Company: Tarena </p> * @author chengxing * @version 1.0 */ private static class ShutdownThread extends Thread { public void run() { try { SocketConnectionPoolInterface provider = SocketConnectionManager .getConnectionProvider(); if (provider != null) { provider.destroy(); } } catch (Exception e) { logger.error(e.getMessage()); e.printStackTrace(); } } } }
- SocketPool.rar (319 KB)
- 下载次数: 116
发表评论
-
bike1
2015-12-07 17:10 0rt -
GPRS打印机的原理
2015-07-31 09:09 712一、什么是GPRS无线打印 ... -
关于 expression="execution(* com.xy.service.*.*(..))"
2015-05-21 09:22 2599先来看看这个spring的配 ... -
md5 sha1 java和javascript实现
2015-05-21 08:11 845<%@ page language="ja ... -
RSA帮助类
2014-11-21 09:36 891package com.cmb.fmserver.passp ... -
src2014-2-17
2014-02-17 21:55 0rt -
springmvc例子
2014-02-11 11:09 0rt -
qhdescjyw
2014-02-11 10:33 0rt -
按字节截取含有中文汉字的字符串
2013-05-07 18:55 3057要求实现一个按字节截取字符串的方法,比如对于字符串&quo ... -
SSL多线程安全问题
2013-04-23 15:44 1701项目原因,代码实现 ... -
wait notify 对象锁
2013-03-14 15:21 1126通常,多线程之间需要协调工作。例如,浏览器的一个显示图片的 ... -
eclipse下配置hadoop环境
2012-12-05 11:44 1382按照http://smallbee.iteye.com ... -
centos虚拟机上安装运行hadoop(伪分布)
2012-11-15 15:28 19291、先在确认能否不输入口令就用ssh登录localhost: ... -
nio 远程主机强迫关闭了一个现有的连接 解决方案
2012-10-17 12:37 4543nio编程过程中会出现: Exception in thre ... -
java nio过程
2012-10-17 11:32 12071、服务端:ServerSocketChannel进行监听,注 ... -
java dom 解析xml例子
2012-08-02 14:09 1508XML格式如下: <?xml version=&quo ... -
DM5 java 例子
2012-08-02 10:38 1203package com.cmb.fbcbcserver; ... -
HTTP短连接模拟长连接 连接数不能超过2个
2012-08-01 15:47 1988项目中有用到服务器推技术,也是由于环境因素,银行系统,行内机房 ... -
java注解使用例子
2012-07-30 11:50 11431、注解定义: import java.lang.annot ... -
SSL通俗易懂说法
2012-07-30 11:18 1131Bob,Alice和数字证书 网络安全中最知名的人物大概就是 ...
相关推荐
一个socket池 模拟处理并发服务器
此文档简单介绍了Socket连接池的简单应用,以及客户端和服务端的代码实现
一个java socket连接池的典型实例 SocketClient,客户端测试类 SocketAdapter继承Socket类,重新封装socket类 SocketConnectionPool,连接池管理类 StartupSocketServer,socket服务器端的主线程,负责监听端口,当有...
NULL 博文链接:https://c2045875.iteye.com/blog/1186064
主线程阻塞接受客户端socket, 每接收一个socket连接就分发一个线程处理,通过全局变量保存所有客户socket 连接,在每个处理线程中通过客户socket 连接池中每个客户连接发送信息实现消息广播通知。
1、连接池始终无法连接Mysql?。答:x86系统,可以安装5.34或者3.51版本的驱动;x64系统,推荐安装3.51版本的驱动。=======================================================================。2、为什么安装了驱动...
sockerl:Sockerl是用于TCP协议的高级ErlangElixir套接字框架,并提供了快速,有用和易于使用的API,用于实现服务器,客户端和客户端连接池
此版为MFC的客户端版本,此版将主要运算放在了MFC的服务器上,java client只发送socket请求和接收计算结果,此版能够承受的负载极高,200个并发,PC机服务器端基本只占用15%的cpu。java服务器版请下载alex-word-...
花生酱使用golang socket实现的redis客户端,遵循redis标准协议,本项目主要想通过自己实现redis客户端来学习redigo,io,bufio,strconv,sync源码,学习为主,源码阅读将放在项目阅读...查询客户端连接池 认证认证
Java tcp通讯,运用多线程,一个服务端与多个客户端进行交互
C# Socket文件传输源码使用socket实现文件传输同时使用了多线程,首先服务端选择文件,开始监听启动客户端,选择连接就实现了文件的传输。
node-socket-imNode+Express+Socket.IO+ioredis 服务端多实例消息共享及时通信项目应用:实时数据接收IM消息群聊客户端浏览器信息采集、用户在线情况、浏览记录跟踪程序打点远程调试,类似开源项目socketlog后台项目...
服务器基于IOCP / EPOLL通信模型,结合内存池,私有堆等技术,实现了高效的内存管理,以支持大规模和高并发通信场景。 代理代理组件本质上是一个多客户端组件,它使用与服务器组件相同的技术体系结构。 Agent组件...
C#实现Socket通讯有同步模式与异步模式,异步模式的效率比同步模式高。在异步模式中,SocketAsyncEventArgs 类提供了增强功能。...通过创建一个SocketAsyncEventArgsPool 池来提高客户端连接速率。
考虑到服务器端如果每接收到一个请求fork一个进程处理方式的效率低,服务器端采用进程池方式,结合libevent网络库,可以处理并发的TCP连接请求,另外实现了一个基于mysqlclient接口的连接池。 希望对你的 C++ 学习有...
套接字-Apache-公共-Pool2 这是一个有关如何使用套接字服务器和客户端的演示。 套接字客户端使用Apache公共pool2来管理套接字。 因此,我们可以在多线程的情况下使用共享套接字。 我使用bernardvai的示例创建了套接...
该类没有引入池的概念,因为我的程序用不池,所以没有必要花时间在上面,不过,实现池不难 重要的是该类支持connect函数,这个在网上不好找,我没有找到,是自己写的一个, 用这个类来做一个CC攻击器,效果应该不错,connect...
1、连接池始终无法连接Mysql? 答:x86系统,可以安装5.34或者3.51版本的驱动;x64系统,推荐安装3.51版本的驱动。 ======================================================================= 2、为什么安装了驱动...
连接池减少请求延时 透明的GZIP压缩减少响应数据的大小 缓存响应内容,避免一些完全重复的请求 当网络出现问题的时候OkHttp依然坚守自己的职责,它会自动恢复一般的连接问题,如果你的服务有多个IP地址,当第一个IP...