`
cuisuqiang
  • 浏览: 3962336 次
  • 性别: Icon_minigender_1
  • 来自: 北京
博客专栏
3feb66c0-2fb6-35ff-968a-5f5ec10ada43
Java研发技术指南
浏览量：3671777
社区版块
存档分类
最新评论

一个Socket连接管理器

socketgooglejava连接池网络编程 
阅读更多

为了方便开发人员使用，我在闲暇之余写了一个简单的Socket连接管理的处理程序，程序简单仅供参考！

其他更多精彩，请你访问我的博客：http://cuisuqiang.iteye.com/

 

处理机说明：

读取配置文件，根据配置文件信息保持一个连接配置变量集合。

根据连接变量集合初始化相应的连接。

启动一个线程，处理检查连接的有效性，处理方法是发送心跳包，如发现不能使用的连接，则设置该连接为占用，并启动一个线程去不断的初始化该连接。

用户使用接口根据名称去获得连接，如果是保持的连接则直接从连接集合获取，并检查有效性。如果是不用保持的，则去创建一个连接返回。

备注：如果返回了空的信息，则说明没有正常的连接可以返回，你可以尝试不断的获取。

点击连接到我的博客查看更多内容 ！

 

下面来看看代码：

首先创建一个实体对象，对应配置信息

package com.socket;
/**
 * @说明 连接的公共属性
 * @author cuisuqiang
 * @version 1.0
 * @since
 */
public class SocketEntity {
	/**
	 * 连接的名字，以名字作为Key
	 */
	private String name;
	/**
	 * 连接的IP
	 */
	private String ip;
	/**
	 * 连接的端口
	 */
	private int port;
	/**
	 * 是否保持连接
	 */
	private boolean keepConn;

	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getIp() {
		return ip;
	}
	public void setIp(String ip) {
		this.ip = ip;
	}	
	public int getPort() {
		return port;
	}
	public void setPort(int port) {
		this.port = port;
	}
	public boolean isKeepConn() {
		return keepConn;
	}
	public void setKeepConn(boolean keepConn) {
		this.keepConn = keepConn;
	}
}

 

创建配置文件socket.properties

socket1_isKeep属性相当于Spring中的单例还是每次创建

 

 

# @author cuisuqiang

socket1=socket1
socket1_ip=127.0.0.1
socket1_port=8001
socket1_isKeep=1

socket2=socket2
socket2_ip=127.0.0.1
socket2_port=8001
socket2_isKeep=0

# 连接的数量，一定要和实际配置的数量匹配
socketConnCount=2
# 公共的检测间隔 秒
commonCheckTime=5

 

然后初始化配置信息和连接，同时该类中有静态变量来保持连接对象

package com.socket;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
 * @说明 变量保持
 * @author cuisuqiang
 * @version 1.0
 * @since
 */
public class SocketKeep {
	private static Log logger = LogFactory.getLog(SocketKeep.class);
	/**
	 * 配置信息加载
	 */
	public static List<SocketEntity> socketEntityList = new ArrayList<SocketEntity>();
	/**
	 * 连接对象保持，只保持需要系统保持的连接
	 */
	public static Map<String, SocketCui> socketMap = new LinkedHashMap<String, SocketCui>();
	/**
	 * 连接对象是否锁定 1：锁定，其他未锁定
	 */
	public static Map<String, String> socketIsLock = new LinkedHashMap<String, String>();
	/**
	 * 共用连接检测间隔
	 */
	public static int commonCheckTime = 2;
	/**
	 * 连接的数量，一定要和实际配置的数量匹配
	 */
	public static int socketConnCount = 0;	
	public static ExecutorService executorService = null;// 线程池
	/**
	 * 初始化所有连接信息
	 */
	public static void initSocketKeep() {
		Properties properties = null;
		try {
			properties = new Properties();
			properties.load(SocketKeep.class.getClassLoader().getResourceAsStream("socket.properties"));
			logger.warn("加载socket.properties文件成功！");
		} catch (Exception e) {
			logger.error("加载socket.properties文件失败！", e);
			properties = null;
		}
		if (null != properties) {
			try {
				commonCheckTime = Integer.parseInt(properties.getProperty("commonCheckTime"));
				socketConnCount = Integer.parseInt(properties.getProperty("socketConnCount"));
				executorService = Executors.newFixedThreadPool(socketConnCount + 1);
			} catch (Exception e) {
				executorService = Executors.newFixedThreadPool(1);
				logger.error("解析共用信息时错误！", e);
				// 系统忽略这两个属性的加载异常
			}
			SocketEntity socketEntity = null;
			for (int i = 1; i <= socketConnCount; i++) {
				String name = properties.getProperty("socket" + i);
				if(null != name){
					socketEntity = new SocketEntity();
					String ip = properties.getProperty("socket" + i + "_ip");
					String port = properties.getProperty("socket" + i + "_port");
					String isKeep = properties.getProperty("socket" + i + "_isKeep");
					
					socketEntity.setName(name);
					socketEntity.setIp(ip);
					socketEntity.setPort(Integer.parseInt(port));
					boolean keepConn = false;
					if(null != isKeep && "1".equals(isKeep)){
						keepConn = true;
					}
					socketEntity.setKeepConn(keepConn);	
					socketEntityList.add(socketEntity);
				}
			}
		}
		logger.warn("加载Socket连接配置信息结束！");		
		logger.warn("开始初始化Socket连接！");
		SocketCui socket = null;
		for(SocketEntity socketEntity : socketEntityList){
			if(null != socketEntity && socketEntity.isKeepConn()){
				try {
					socket = new SocketCui(socketEntity.getIp(),socketEntity.getPort());
					socket.setSoTimeout(0);
					socket.setKeepAlive(true);
					socket.setName(socketEntity.getName());
				} catch (Exception e) {
					logger.error("初始化某个连接时错误！错误的连接将放弃！资源名称：" + socketEntity.getName(), e);
					socket = null;
				}
				if(null != socket){
					socketMap.put(socketEntity.getName(), socket);
				}else{
					socketMap.put(socketEntity.getName(), new SocketCui());					
				}
				socketIsLock.put(socketEntity.getName(), "0");
			}
		}		
		// 开始执行检查
		executorService.execute(new CheckThread());
		logger.warn("初始化Socket连接结束！");
	}
}

 

启动的线程是用于检查连接的

package com.socket;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
 * @说明 轮询检测某个连接当前是否可用
 * @author cuisuqiang
 * @version 1.0
 * @since 当遇到一个错误的连接，将会启动重连，同时挂起该连接的使用
 */
public class CheckThread  implements Runnable {
	private static Log logger = LogFactory.getLog(CheckThread.class);	
	public void run() {
		while(true){
			SocketCui socket = null;
			for(SocketEntity socketEntity : SocketKeep.socketEntityList){
				if(null != socketEntity && socketEntity.isKeepConn()){
					String isLock = SocketKeep.socketIsLock.get(socketEntity.getName());
					// 如果当前未被使用
					if(!"1".equals(isLock)){
						// 锁定引用
						SocketKeep.socketIsLock.put(socketEntity.getName(), "1");
						socket = SocketKeep.socketMap.get(socketEntity.getName());
						try {
							// 发送一个心跳包
							socket.sendUrgentData(0xFF);
							// 释放资源
							SocketKeep.socketIsLock.put(socketEntity.getName(), "0");
						} catch (Exception e) {
							logger.error("检查连接时异常！启动重连！资源名称：" + socketEntity.getName(), e);
							// 如果异常，应该建立一个线程去初始化该连接
							InitSocket initS = new InitSocket(socketEntity.getName());
							new Thread(initS).start();
						}
					}
				}
			}
			// 执行间隔
			try {
				logger.error("本次检测结束！");
				Thread.sleep(SocketKeep.commonCheckTime * 1000);
			} catch (Exception e) {
			}			
		}
	}
}

 

当检查线程发现无效的连接时会启动新的线程初始化该连接

package com.socket;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
 * @说明 负责初始化失效的连接
 * @author cuisuqiang
 * @version 1.0
 * @since
 */
public class InitSocket implements Runnable{	
	private static Log logger = LogFactory.getLog(InitSocket.class);	
	/**
	 * 是否有某个连接的配置信息，只有有配置信息才能建立连接
	 */
	private static boolean isHave = false;	
	private SocketEntity socketEntity = null;	
	private String name;	
	public InitSocket(String name){
		this.name = name;
		// 检测是否有某个连接的配置信息
		for(SocketEntity socketEntity : SocketKeep.socketEntityList){
			if(null != socketEntity && socketEntity.isKeepConn()){
				if(socketEntity.getName().equals(name)){
					this.setSocketEntity(socketEntity);
					isHave = true;
				}
			}
		}
	}
	public void run() {
		boolean isError = true;
		SocketCui socket = null;
		if(isHave){
			while(isError){
				try {
					socket = new SocketCui(this.getSocketEntity().getIp(),this.getSocketEntity().getPort());
					socket.setSoTimeout(0);
					socket.setKeepAlive(true);
					socket.setName(this.name);
					// 发送一个心跳包
					socket.sendUrgentData(0xFF);						
				} catch (Exception e) {
					logger.error("建立资源连接时错误！资源：" + this.name, e);
					socket = null;
				}
				if(null != socket){
					SocketKeep.socketMap.put(this.getSocketEntity().getName(), socket);
					// 设置连接当前可用
					SocketKeep.socketIsLock.put(this.getSocketEntity().getName(), "0");
					logger.warn("建立资源连接成功！资源名称：" + this.name);
					isError = false;
				}
				try {
					Thread.sleep(2 * 1000);
				} catch (Exception e) {
				}
				
			}
		}else{
			logger.error("没有发现指定资源的配置信息！资源名称：" + this.name);
		}
		logger.warn("初始化资源执行结束！资源名称：" + this.name);
	}
	public SocketEntity getSocketEntity() {
		return socketEntity;
	}
	public void setSocketEntity(SocketEntity socketEntity) {
		this.socketEntity = socketEntity;
	}
}

 

同时注意，用户在使用连接后会调用关闭方法。我们是不能让连接关闭的，要保持常连接。所以如果用户指定的是保持这个连接，那么返回的连接对象就不是原来的Socket对象了，我们要重写这个对象

package com.socket;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
/**
 * @说明 被重新定义的连接对象，增加了名字这个属性，重写了关闭的方法
 * @author cuisuqiang
 * @version 1.0
 * @since
 */
public class SocketCui extends Socket{	
	/**
	 * 为对象增加名称属性
	 */
	private String name;	
	public SocketCui() {
	}	
	public SocketCui(String ip,int port) throws UnknownHostException, IOException{
		super(ip, port);
	}	
	/**
	 * 覆盖关闭的方法
	 */
	@Override
	public synchronized void close() throws IOException {
		SocketKeep.socketIsLock.put(this.name, "0");
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
}

 这样，关闭时只会解除其占用，而不会真正关闭该连接。

 

我们来写一个服务端，这个服务端一直接受连接，并检查连接的有效性，当失效时不处理

同时打印接收到的连接信息

package com.test;
import java.net.*;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
 * @说明 服务端，始终接受连接
 * @author cuisuqiang
 * @version 1.0
 * @since 
 */
public class ServiceTest {
	public static void main(String[] args) {
		try {
			ServerSocket ss1 = new ServerSocket(8001);
			Runnable accumelatora1 = new Accumulatort(ss1);
			Thread threada = new Thread(accumelatora1, "ThreadA");
			threada.start();
			System.out.println("服务启动完毕！");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}
class Accumulatort implements Runnable {
	ServerSocket ss = null;
	public Accumulatort(ServerSocket s) {
		this.ss = s;
	}
	@SuppressWarnings("unchecked")
	public void run() {
		try {
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			while (true) {
				Socket s = ss.accept();
				System.out.println(format.format(new Date()) + " " + "---------收到请求！");
				new Thread(new ServiceImpl(s)).start();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

 服务端处理连接的实现类

package com.test;
import java.net.Socket;
/**
 * @说明 循环发送心跳包保持连接属性
 * @author cuisuqiang
 * @version 1.0
 * @since 
 */
public class ServiceImpl implements Runnable {
	Socket socket = null;
	public ServiceImpl(Socket s) {
		this.socket = s;
	}
	public void run() {
		boolean isKeep = true;
		try {
			while (isKeep) {
				socket.sendUrgentData(0xFF);
				Thread.sleep(1 * 1000);
			}
		} catch (Exception e) {
			isKeep = false;
		}
	}
}

 

先启动服务端，然后我们再写一个测试端，这个测试类会不断去管理器中获取相应的连接，同时打印连接信息

通过打印的连接信息，我们可以知道获取的是不是同一个对象

同时如果你一直获取单例的对象，那么可能出现该连接被检查线程占用的情况

package com.test;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;
import com.socket.CommonSocket;
import com.socket.SocketKeep;
/**
 * @说明 循环去请求获得相应的连接然后打印连接地址
 * @author cuisuqiang
 * @version 1.0
 * @since 
 */
public class GetSocketTest {
	public static void main(String[] args) {
		SocketKeep.initSocketKeep();
		while(true){			
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			try {				
				Socket socket1 = CommonSocket.getSocketByName("socket1");
				if(null != socket1){
					System.out.println(format.format(new Date()) + " " + socket1.toString());
					socket1.close();	
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
			try {
				Socket socket2 = CommonSocket.getSocketByName("socket2");
				if(null != socket2){
					System.out.println(format.format(new Date()) + " " + socket2.toString());
					socket2.close();
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
			try {
				Thread.sleep(1000);
			} catch (Exception e) {
				
			}
		}
	}
}

 

当然别忘了加日志的包！

 

我们来看一下服务端的打印信息

服务启动完毕！
2012-04-18 16:59:48 ---------收到请求！
2012-04-18 16:59:48 ---------收到请求！
2012-04-18 16:59:49 ---------收到请求！
2012-04-18 16:59:50 ---------收到请求！
2012-04-18 16:59:51 ---------收到请求！
2012-04-18 16:59:52 ---------收到请求！
2012-04-18 16:59:53 ---------收到请求！
2012-04-18 16:59:54 ---------收到请求！
2012-04-18 16:59:55 ---------收到请求！
2012-04-18 16:59:56 ---------收到请求！
2012-04-18 16:59:57 ---------收到请求！
2012-04-18 16:59:58 ---------收到请求！
2012-04-18 16:59:59 ---------收到请求！

 

我们可以看到，除刚开始外，会一直收到连接，因为我们一直在获取一个非单例的连接对象

我们再看一下客户端打印信息

2012-04-18 16:59:48 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:48 Socket[addr=/127.0.0.1,port=8001,localport=4390]
2012-04-18 16:59:49 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:49 Socket[addr=/127.0.0.1,port=8001,localport=4391]
2012-04-18 16:59:50 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:50 Socket[addr=/127.0.0.1,port=8001,localport=4392]
2012-04-18 16:59:51 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:51 Socket[addr=/127.0.0.1,port=8001,localport=4393]
2012-04-18 16:59:52 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:52 Socket[addr=/127.0.0.1,port=8001,localport=4394]
2012-04-18 16:59:53 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:53 Socket[addr=/127.0.0.1,port=8001,localport=4395]
2012-04-18 16:59:54 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:54 Socket[addr=/127.0.0.1,port=8001,localport=4396]
2012-04-18 16:59:55 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:55 Socket[addr=/127.0.0.1,port=8001,localport=4397]
2012-04-18 16:59:56 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:56 Socket[addr=/127.0.0.1,port=8001,localport=4398]
2012-04-18 16:59:57 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:57 Socket[addr=/127.0.0.1,port=8001,localport=4399]
2012-04-18 16:59:58 Socket[addr=/127.0.0.1,port=8001,localport=4400]
2012-04-18 16:59:59 Socket[addr=/127.0.0.1,port=8001,localport=4389]
2012-04-18 16:59:59 Socket[addr=/127.0.0.1,port=8001,localport=4401]

 

可以看到，socket1是一直被保持的，而socket2每次创建一个

再看一下日志

2012-04-18 16:59:48 [com.socket.SocketKeep]-[WARN] 加载socket.properties文件成功！
2012-04-18 16:59:48 [com.socket.SocketKeep]-[WARN] 加载Socket连接配置信息结束！
2012-04-18 16:59:48 [com.socket.SocketKeep]-[WARN] 开始初始化Socket连接！
2012-04-18 16:59:48 [com.socket.SocketKeep]-[WARN] 初始化Socket连接结束！
2012-04-18 16:59:48 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:48 [com.socket.CheckThread]-[ERROR] 本次检测结束！
2012-04-18 16:59:49 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:50 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:51 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:52 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:53 [com.socket.CheckThread]-[ERROR] 本次检测结束！
2012-04-18 16:59:53 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:54 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:55 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:56 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:57 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:58 [com.socket.CommonSocket]-[WARN] 当前连接正被占用，请稍候尝试！资源名称：socket1
2012-04-18 16:59:58 [com.socket.CheckThread]-[ERROR] 本次检测结束！
2012-04-18 16:59:58 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2
2012-04-18 16:59:59 [com.socket.CommonSocket]-[WARN] 为用户建立请求连接！资源名称：socket2

 

可以看到，socket2会一直被重新创建，而且socket1会发现被占用的情况。

你也可以中断服务端然后再重启服务端试试，看看效果。

 

源码下面可以下载，仅供参考！转载说明出处，谢谢合作！

 

请您到ITEYE看我的原创：http://cuisuqiang.iteye.com

或支持我的个人博客，地址：http://www.javacui.com

 

15
顶
1
踩
分享到：
| 动态绘图时VML内存累计增加导致崩溃
评论
4 楼 Javac_bean 2017-11-30  
貌似少了一个java文件哈
package com.socket;
import java.net.*;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
* @说明 对外提供的方法
* @author cuisuqiang
* @version 1.0
* @since 得到某个资源使用后必须释放，否则造成霸占使用
*/
public class CommonSocket {
private static Log logger = LogFactory.getLog(CommonSocket.class);
/**
* @说明 通过名字来获得某个连接对象
* @since 如果返回为空，你应该尝试反复调用，因为该对象可能被检测机制占用，或当前不可用
* @since 如果你通过该方法获得了连接对象，那么你应该在使用后显示的关闭该对象的使用，否则该对象会死锁
* @since 如果你尝试获得一个没有被定义的连接，那么会返回NULL
*/
public static Socket getSocketByName(String name) {
SocketCui socket = null;
boolean isHave = false;// 是否有对象的定义
boolean isKeep = false;// 该对象是否为单例
// 检测是否有某个连接的配置信息
for (SocketEntity socketEntity : SocketKeep.socketEntityList) {
if (null != socketEntity) {
if (socketEntity.getName().equals(name)) {
isHave = true;
if (socketEntity.isKeepConn()) {
isKeep = true;
}
break;
}
}
}
// 是否有该名字的配置
if (isHave) {
if (isKeep) {
String isLock = SocketKeep.socketIsLock.get(name);
// 如果当前未锁定
if (null != isLock && !"1".equals(isLock)) {
// 设置占用
SocketKeep.socketIsLock.put(name, "1");
socket = SocketKeep.socketMap.get(name);
try {
// 发送一个心跳包
socket.sendUrgentData(0xFF);
} catch (Exception e) {
logger.error("得到资源后发现资源不可用！资源名称：" + name);
socket = null;
}
} else {
logger.warn("当前连接正被占用，请稍候尝试！资源名称：" + name);
}
} else {
logger.warn("为用户建立请求连接！资源名称：" + name);
// 建立一次性连接
return initSocketByName(name);
}
} else {
logger.error("没有关于该名称的配置信息！资源名称：" + name);
}
return socket;
}
/**
* @说明 根据名称建立一个连接
* @since 需要被创建的连接必须已经加载了配置的信息
*/
private static Socket initSocketByName(String name) {
Socket socket = null;
for (SocketEntity socketEntity : SocketKeep.socketEntityList) {
if (null != socketEntity) {
if (socketEntity.getName().equals(name)) {
try {
socket = new SocketCui(socketEntity.getIp(), socketEntity.getPort());
socket.setSoTimeout(0);
socket.setKeepAlive(true);
// 发送一个心跳包
socket.sendUrgentData(0xFF);
} catch (Exception e) {
logger.error("方法initSocketByName建立连接时错误！", e);
socket = null;
}
}
}
}
return socket;
}
}
3 楼 happycoolyp 2013-11-15  
写的不错。
但是有个疑问，这个是否能保持线程安全呢？

一旦线程运行到判断socketIsLock里的某个socket是可用的的地方 与 设置socket被占用 之间的时候cpu被切换，这个时候是否会出现问题？
2 楼 cuisuqiang 2012-11-28  
a_lee 写道
顶一个
打算将客户端移植到android上不知道要注意什么问题呢
连接数量上有什么问题呢

连接的线程使用连接池管理
1 楼 a_lee 2012-11-28  
顶一个
打算将客户端移植到android上不知道要注意什么问题呢
连接数量上有什么问题呢
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    一个Socket连接管理器(心跳机制)

    以上就是关于"一个Socket连接管理器(心跳机制)"的相关知识点，涵盖了Socket的基本概念、TCP连接原理、心跳包的设计与实现、异常处理、线程管理以及性能优化等多个方面。理解并掌握这些知识点，对于构建稳定、高效的...

    java socket连接池 实现

    连接池是在应用程序启动时创建一定数量的Socket连接，并将它们保存在一个集合中，当需要建立新的网络连接时，从池中获取一个已经建立好的连接，使用完毕后归还给池，而不是立即关闭。这样可以避免频繁的创建和销毁...

    C# Socket连接池

    Socket连接池是网络编程中一个重要的优化手段，它在C#中主要应用于提高网络通信的效率和稳定性。本文将深入探讨“C# Socket连接池”的实现原理、优势以及如何利用线程池技术来构建和优化它。同时，我们也会提及...

    Java实现Socket长连接和短连接

    在短连接中，每个请求-响应对都建立一个新的Socket连接，处理完后立即关闭。这种模式的优点是资源利用率高，避免了长时间占用系统资源。但缺点是频繁的连接和断开会增加网络开销，对于高并发场景可能不是最优选择。 ...

    [VB]一个Socket连接类，封装了Winsock API

    这个名为"一个Socket连接类，封装了Winsock API"的VB类，可能包含以下核心功能： 1. 初始化与配置：类的初始化通常涉及设置Winsock控件的基本属性，如本地主机地址、端口号等。这一步确保Socket正确绑定到特定的...

    socket自动连接和多客户端管理

    在实际应用中，`ServerSocketManager`可能是一个设计良好的类，负责创建、管理和关闭服务器端的`ServerSocket`实例，以及为每个客户端连接创建并管理对应的`Socket`实例。它会维护一个客户端连接列表，以便于跟踪...

    java socket连接池

    3. 获取Socket连接：通过调用连接池的borrowObject()方法获取一个可用的Socket连接。 4. 使用Socket连接：进行实际的网络通信，处理客户端请求。 5. 归还Socket连接：使用完后，调用returnObject()方法将Socket返回...

    Socket连接控制打印机输出

    在本场景中，“Socket连接控制打印机输出”指的是利用Socket连接远程打印机，仅需知道打印机的IP地址，即可实现对打印机的打印控制。这种方式通常适用于局域网或互联网环境中的设备管理，比如远程办公或分布式打印...

    socket线程连接池实例

    通过这种方式，我们可以有效地管理和复用Socket连接，降低系统的资源消耗，提高系统的吞吐量。在大型分布式系统中，这样的设计是必不可少的，它能够帮助系统更好地应对高并发访问和网络延迟等问题。 总的来说，这个...

    socket 客户端连接池实现

    2. 连接管理：连接池需要维护一个空闲连接列表，当有新的请求时，从列表中取出一个可用连接。如果列表为空，且未达到最大连接数限制，可以创建新的连接。反之，如果达到最大连接数，请求可能会被阻塞或抛出异常。 3...

    socket客户端，可连接多个服务器

    TCP Socket连接的建立遵循三次握手的过程，客户端首先发起连接请求（SYN），服务器响应确认并发送自己的SYN（SYN+ACK），客户端再回应服务器的确认（ACK）。当这三步交互完成，连接便建立成功。而断线后的重连机制，...

    Socket连接示例代码

    以下是一个简单的Socket连接流程： 1. **服务器端**： - 创建ServerSocket实例，如`ServerSocket server = new ServerSocket(8888);`，这里的8888是服务器监听的端口号。 - 通过`server.accept()`方法阻塞等待...

    Socket连接池的简单应用

    - **连接容器**：用于存储和管理多个Socket连接。 - **空闲标记**：每个连接都有一个状态标识符，用于表明当前连接是否处于空闲状态。 - **获取和释放机制**：提供接口供外部获取空闲连接及释放已使用的连接。 ####...

    C# socket异步长连接

    在C#中，System.Net.Sockets命名空间提供了Socket类，用于创建和管理socket连接。 在“异步”方面，C#的Socket支持异步操作模式，这意味着你可以启动一个网络操作（如连接、接收或发送数据），然后继续执行其他任务...

    socket短连接和长连接 多线程的应用

    学习这个框架可以帮助理解如何在实际应用中有效地管理和使用Socket连接，以及如何通过多线程和线程池优化并发性能。通过阅读和分析源码，可以深入理解这些概念，并提升网络编程和并发处理的能力。

    iOS下的Socket连接demo

    5. **连接管理**：连接建立后，需要管理好Socket的状态，包括连接状态、数据传输状态、错误处理等。在iOS应用中，可能需要处理网络断开、应用进入后台等情况，确保Socket连接的稳定性和可靠性。 6. **安全考虑**：...

    一个简单的maven-socket连接demo

    这个简单的`maven-socket连接demo`为你提供了一个基础的起点，你可以在此基础上扩展出更复杂的实时通信应用，例如聊天应用、实时数据监控或多人在线游戏等。理解并掌握`Maven`的构建流程、`Socket.IO`的事件驱动机制...

    Socket长连接demo

    本示例可能是一个关于如何实现和管理Socket长连接的代码演示。 在TCP/IP协议族中，Socket分为两种类型：短连接（Short-lived Connection）和长连接（Long-lived Connection）。短连接通常用于一次性传输数据，如...

    Socket连接池的经典实例

    一个java socket连接池的典型实例 SocketClient,客户端测试类 SocketAdapter继承Socket类,重新封装socket类 SocketConnectionPool,连接池管理类 StartupSocketServer,socket服务器端的主线程,负责监听端口,当有...

Magicbox
Global site tag (gtag.js) - Google Analytics