@Before
    public void init() throws Exception {
        server = new BoltServer(port);
        server.start();
        server.addConnectionEventProcessor(ConnectionEventType.CONNECT, serverConnectProcessor);
        server.addConnectionEventProcessor(ConnectionEventType.CLOSE, serverDisConnectProcessor);
        server.registerUserProcessor(serverUserProcessor);// no use here

        client = new RpcClient();
        client.addConnectionEventProcessor(ConnectionEventType.CONNECT, clientConnectProcessor);
        client.addConnectionEventProcessor(ConnectionEventType.CLOSE, clientDisConnectProcessor);
        client.registerUserProcessor(clientUserProcessor);// no use here
        client.init();
        Thread.sleep(100);
    }
Connection test

@author jiangping
@version $Id: ConnectionTest.java, v 0.1 Mar 6, 2016 9:55:50 PM tao Exp $
src/test/java/com/alipay/remoting/inner/connection/ConnectionTest.java