Mina客户端连接-2
程序员文章站
2024-01-06 18:15:04
...
private NioSocketConnector connector = new NioSocketConnector();
ConnectFuture future1 = connector.connect(address);
AbstractIoConnector 中
public final ConnectFuture connect(SocketAddress remoteAddress,
SocketAddress localAddress, IoSessionInitializer<? extends ConnectFuture> sessionInitializer) 方法
到 AbstractPollingIoConnector
protected final ConnectFuture connect0(
SocketAddress remoteAddress, SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
方法
protected final ConnectFuture connect0( SocketAddress remoteAddress, SocketAddress localAddress, IoSessionInitializer<? extends ConnectFuture> sessionInitializer) { H handle = null; boolean success = false; try { //获取管道 handle = newHandle(localAddress); //建立连接 if (connect(handle, remoteAddress)) { ConnectFuture future = new DefaultConnectFuture(); T session = newSession(processor, handle); initSession(session, future, sessionInitializer); // Forward the remaining process to the IoProcessor. session.getProcessor().add(session); success = true; return future; } success = true; } catch (Exception e) { return DefaultConnectFuture.newFailedFuture(e); } finally { if (!success && handle != null) { try { close(handle); } catch (Exception e) { ExceptionMonitor.getInstance().exceptionCaught(e); } } } ConnectionRequest request = new ConnectionRequest(handle, sessionInitializer); connectQueue.add(request); //建立连接 startupWorker(); wakeup(); return request; }
startupWorker 中 启动一个 Connector 连接 服务器
推荐阅读
-
用连接池提高Servlet访问数据库的效率(2)
-
JDBCTM 指南:入门2 - 连接
-
如何使用JSP连接DB2数据库
-
AndroidPN客户端的阻塞读写(2) 博客分类: android androidpn
-
AndroidPN客户端的阻塞读写(2) 博客分类: android androidpn
-
Windows Server 2008 R2和2012中PHP连接MySQL过慢的解决方法
-
ubuntu 10.10使用adb连接g2 博客分类: android UbuntuAndroid
-
ubuntu 10.10使用adb连接g2 博客分类: android UbuntuAndroid
-
redis之安全&性能&客户端连接 博客分类: redis redisredis安全redis性能测试
-
redis之安全&性能&客户端连接 博客分类: redis redisredis安全redis性能测试