By the way, the mina version we used is 2.0.5. JDK1.7.0_06
-----Original Message----- From: Wang, Susan [mailto:wang...@navcanada.ca] Sent: November 9, 2012 11:17 AM To: users@mina.apache.org Subject: mina client connected without mina server running. Hi there, This problem happens in our project. I wrote a small mina client application to show this problem. There are 10 mina clients trying to connect to a server. When I start mina clients, after while, about 20 minutes or longer, one or two client connectFuture.isConnected() return true, show being connected to a server even no server running at all. Below is my code: package ca.navcanada.xio.interfaces; import java.net.InetSocketAddress; import org.apache.log4j.Logger; import org.apache.mina.core.future.CloseFuture; import org.apache.mina.core.future.ConnectFuture; import org.apache.mina.core.future.IoFutureListener; import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.session.IdleStatus; import org.apache.mina.core.session.IoSession; import org.apache.mina.transport.socket.SocketConnector; import org.apache.mina.transport.socket.nio.NioSocketConnector; /** * */ public class MiniTcpClient extends IoHandlerAdapter { private static final Logger log = Logger.getLogger(MiniTcpClient.class); private final ConnectFutureListener connectFutureListener; private volatile ConnectFuture connectFuture; protected SocketConnector connector; private InetSocketAddress inetAddress; public MiniTcpClient(InetSocketAddress inetAddress) { super(); this.inetAddress = inetAddress; connector = new NioSocketConnector(); //connector.addListener(ioServiceListener); connector.getFilterChain().addLast("logging", new MessageLoggingFilter("MiniTCP")); connectFutureListener = new ConnectFutureListener(); connector.setHandler(this); connector.getSessionConfig().setKeepAlive(true); } public synchronized void connect() { // System.out.println("Connecting to " + inetAddress + " ..."); cancelAllSessions(); if (inetAddress == null) { System.out.println("No address available to connect to"); return; } connectFutureListener.setInetAddress(inetAddress); connectFuture = connector.connect(inetAddress); connectFuture.addListener(connectFutureListener); } public static void main(String[] args) { MiniTcpClient [] tcpClient = new MiniTcpClient[10]; InetSocketAddress inetAddress1 = new InetSocketAddress("127.0.0.1", 51200); InetSocketAddress inetAddress2 = new InetSocketAddress("127.0.0.1", 51201); for (int i = 0; i < 10; i++) { if (i < 5) { tcpClient[i] = new MiniTcpClient(inetAddress1); } else { tcpClient[i] = new MiniTcpClient(inetAddress2); } tcpClient[i].connect(); } } /** * Cancels all established or pending sessions associated with the {@link #connector} */ private void cancelAllSessions() { // cancel any pending connect attempts if (connectFuture != null) { connectFuture.removeListener(connectFutureListener); connectFuture.cancel(); connectFuture = null; } // close any open connections immediately final boolean immediately = true; for (IoSession session : connector.getManagedSessions().values()) { CloseFuture cf = session.close(immediately); cf.awaitUninterruptibly(); } } void retryConnect() { try { Thread.sleep(1000); } catch (InterruptedException e) { System.out.println("Thread.sleep interruped on connectionFailoverInterval"); } finally { connect(); } } private class ConnectFutureListener implements IoFutureListener<ConnectFuture> { private InetSocketAddress inetAddress; public void setInetAddress(InetSocketAddress inetAddress) { this.inetAddress = inetAddress; } // handle the session close event final IoFutureListener<CloseFuture> onSessionClose = new IoFutureListener<CloseFuture>() { @Override public void operationComplete(CloseFuture iof) { System.out.println("Connection to " + iof.getSession().getRemoteAddress() + " closed."); } }; @Override public void operationComplete(ConnectFuture future) { // we are connected! if (future.isConnected()) { System.out.println("Connection established to " + inetAddress); // set up closeFuture when the connection is closed. future.getSession().getCloseFuture().addListener(onSessionClose); return; } // connection failed for whatever reason //System.out.println("Connection to " + inetAddress + " failed."); // retryConnect(); retryConnect(); } } @Override public void exceptionCaught(IoSession session, Throwable cause) throws Exception { cause.printStackTrace(); } @Override public void messageSent(IoSession session, Object message) throws Exception { log.debug("Message sent..."); } @Override public void messageReceived(IoSession session, Object message) throws Exception { log.debug("Session recv..."); } @Override public void sessionClosed(IoSession session) throws Exception { log.debug("Session closed..."); } @Override public void sessionCreated(IoSession session) throws Exception { log.debug("Session created..."); } @Override public void sessionIdle(IoSession session, IdleStatus status) throws Exception { log.debug("Session idle..."); } @Override public void sessionOpened(IoSession session) throws Exception { log.debug("Session opened..."); } } Thanks in advance, Susan Wang
