Mina实现同步设置
mina是个异步通信框架,一般使用场景是服务端开发,长连接、异步通信使用mina是及其方便的。
?
对于并发量不高的场景,现在流行使用短连接:每次连接只进行一次通信,即连接-发送-接收-断开。此种模式的通信客户端,能否使用mina开发?答案是肯定的。
?
mina典型应用,需要实现IoHanlder接口,当收到消息时,此接口的messageReceived方法被触发,开发人员实现此方法即可处理消息。
?
一个同步的客户端,可以不再需要IoHandler,但必须设置如下属性useReadOperation为true。mina会自动添加一个默认的IoHandler实现。
?
下面给出代码片段,一看即明
?
?
?????? NioSocketConnector connector = new NioSocketConnector();
?????? connector.setConnectTimeoutMillis(30000L);
?????? connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new YourCodecFactory()));
?????? SocketSessionConfig cfg = connector.getSessionConfig();
?????? cfg.setUseReadOperation(true);
?????? IoSession session = connector.connect(ip,port).awaitUninterruptibly().getSession();
?
?
现在已实现了连接,接下来就是发送-接收-断开了
?
?
?????????? try {
????????????? // 发送
????????????? session.write(YourMessage).awaitUninterruptibly();
?
????????????? // 接收
????????????? ReadFuture readFuture = session.read();
?
????????????? if (readFuture.awaitUninterruptibly(waitTimeout, TimeUnit.SECONDS)) {
????????????????? YourMessage msg = readFuture.getMessage();
????????????????? // TODO 处理消息
????????????? } else {
????????????????? // 读超时
????????????? }
??? ?????? } finally {
????????????? // 断开
?????? ?????? session.close(true);
?????? ?????? session.getService().dispose();
?????????? }