MINA服务端多线程问题

0 0

MINA服务端多线程问题3

服务器是使用MINA做的，处理一些数据

客户端也是使用MINA，在服务端出现冲突和阻塞，有时两个线程可以正常运行，有时一个运行另一个阻塞。
MINA 不是多线程的吗？为什么会阻塞。求解答

public class testClient {
	
	public static void main(String[] args){
		new Thread(new ddzx()).start();

		new Thread(new ddzx2()).start();
	}
}


class ddzx implements Runnable{
	@Override
	public void run() {
		//创建 tcp/ip 连接
		NioSocketConnector connector = new NioSocketConnector();
		
		//创建接收数据的过滤器
		DefaultIoFilterChainBuilder chin = connector.getFilterChain();
		
		//设定这个过滤器将一行一行的读取数据
		//chin.addLast("codec", new IoFilterAdapter());
		chin.addLast("mychin", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
		
		//设定客户端消息处理器
		connector.setHandler(new clientHandler());
		//设置连接超时时间
		connector.setConnectTimeout(30);
		
		//连接到服务器
		//ConnectFuture future = connector.connect(new InetSocketAddress("192.168.2.201",31024));
		ConnectFuture future = connector.connect(new InetSocketAddress("127.0.0.1",9988));
		
		future.awaitUninterruptibly();
		future.getSession().getCloseFuture().awaitUninterruptibly();		
		connector.dispose();
	}
}

class ddzx2 implements Runnable{
	@Override
	public void run() {
		//创建 tcp/ip 连接
		NioSocketConnector connector = new NioSocketConnector();
		
		//创建接收数据的过滤器
		DefaultIoFilterChainBuilder chin = connector.getFilterChain();
		
		//设定这个过滤器将一行一行的读取数据
		//chin.addLast("codec", new IoFilterAdapter());
		chin.addLast("mychin", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
		
		//设定客户端消息处理器
		connector.setHandler(new clientHandler2());
		//设置连接超时时间
		connector.setConnectTimeout(30);
		
		//连接到服务器
		//ConnectFuture future = connector.connect(new InetSocketAddress("192.168.2.201",31024));
		ConnectFuture future = connector.connect(new InetSocketAddress("127.0.0.1",9988));
		
		future.awaitUninterruptibly();
		future.getSession().getCloseFuture().awaitUninterruptibly();
		connector.dispose();
	}
}

Mina