MINA2的一个BUG

   我们知道，在MINA2中，发送和接受时两个独立的工作线程，但是可以设置一个参数，当服务端发送消息之后同步读取客户端的返回:

session.getConfig().setUseReadOperation(true);

近日，采用MINA2（RC)的同步读取方法，发现无法真的同步读取客户端的返回；
场景是：服务端发送一个消息给客户端，需要同步等待客户端的一个消息回执，然后服务端的程序继续执行；
 

sendSession.getConfig().setUseReadOperation(true);
		WriteFuture future = sendSession.write(xmlMsgBean); // 发送数据
		future.awaitUninterruptibly(); // 等待发送数据操作完成
		if (future.getException() != null) {
			throw new AppException(future.getException().getMessage());
		}
		if (future.isWritten()) {
			// 数据已经被成功发送
			logger.debug("数据已经被成功发送");
			ReadFuture readFuture = sendSession.read();
			readFuture.awaitUninterruptibly();
			if (readFuture.getException() != null) {
				throw new AppException(readFuture.getException().getMessage());
			}
			sendSession.getConfig().setUseReadOperation(false);
			return ((XmlMsgBean) readFuture.getMessage()).getStrErrMsg();
		} else {
			// 数据发送失败
			logger.debug("数据发送失败");
		}
  

  后来用GOOGLE搜索了一下，发现在MINA的官网上，老外同样问了一个一模一样的问题，并且提了一个BUG上去，但是目前BUG的状态还是open；
  https://issues.apache.org/jira/browse/DIRMINA-777
 

I'm attempting to perform a synchronous write/read in a demux-based client application with MINA 2.0 RC1, but it seems to get stuck. Here is my code: 

{code} 
public boolean login(final String username, final String password) { 
    // block inbound messages 
    session.getConfig().setUseReadOperation(true); 

    // send the login request 
    final LoginRequest loginRequest = new LoginRequest(username, password); 
    final WriteFuture writeFuture = session.write(loginRequest); 
    writeFuture.awaitUninterruptibly(); 

    if (writeFuture.getException() != null) { 
        session.getConfig().setUseReadOperation(false); 
        return false; 
    } 

    // retrieve the login response 
    final ReadFuture readFuture = session.read(); 
    readFuture.awaitUninterruptibly(); 

    if (readFuture.getException() != null) { 
        session.getConfig().setUseReadOperation(false); 
        return false; 
    } 

    // stop blocking inbound messages 
    session.getConfig().setUseReadOperation(false); 

    // determine if the login info provided was valid 
    final LoginResponse loginResponse = (LoginResponse)readFuture.getMessage(); 
    return loginResponse.getSuccess(); 
} 
{code} 

I can see on the server side that the LoginRequest object is retrieved, and a LoginResponse message is sent. On the client side, the DemuxingProtocolCodecFactory receives the response, but after throwing in some logging, I can see that the client gets stuck on the call to `readFuture.awaitUninterruptibly() `. 

I can't for the life of me figure out why it is stuck here based upon my own code. I properly set the read operation to true on the session config, meaning that messages should be blocked. However, it seems as if the message no longer exists by time I try to read response messages synchronously.

 
Key: DIRMINA-777 
Type:  Bug 
Status:  Open 
Priority:  Blocker 
Assignee: Unassigned 
Reporter: Matt Huggins 
Votes: 0 
Watchers: 0 

评论

8 楼 crazy_joe 2014-08-29  

这问题貌似还是没有解决

7 楼 tianlovv 2013-12-19  

在MINA2中，发送和接受时两个独立的工作线程
这句话不太认同，如果没加executorfilter  read write是在用一个线程里处理的吧

另外你写的那段代码是放在messagereceive方法中的吗

6 楼 panwuhai 2013-04-28  

我不明白你的问题，我用的是mina2.07的，关于你的业务场景是绝对可以实现的。
场景是：服务端发送一个消息给客户端，需要同步等待客户端的一个消息回执，然后服务端的程序继续执行；

超时时间根据网络来定，或者长连接用来不间断的一问一答，人工来判断何时关闭；当服务端session.write()后，客户端执行handler received ，处理自己的业务；然后仍然在这个方法里 session.write()；然后session.close;
除非你还要继续一问一答。
另外，服务器session.close后 客户端端自动会关闭该session.

5 楼 scholers 2013-02-27  

从百草园到三味书屋 写道

请看我写的文章http://firethemax.iteye.com/blog/1606140

哥们写的很不错，有兴趣换个工作吗？

4 楼 从百草园到三味书屋 2012-07-24  

请看我写的文章http://firethemax.iteye.com/blog/1606140

3 楼 bcw104 2011-03-31  

有个不太好的解决办法，每次超时后都要关闭session，然后重新建立一个session

2 楼 scholers 2011-03-31  

bcw104 写道

这个bug我也碰到了，
readFutur.await(500, TimeUnit.MILLISECONDS) 超时后下次再读多少次都是超时，decoder里面明明已经out.write(message)了。

这个BUG在2.0.0中仍然没有得到解决。

1 楼 bcw104 2011-03-31  

这个bug我也碰到了，
readFutur.await(500, TimeUnit.MILLISECONDS) 超时后下次再读多少次都是超时，decoder里面明明已经out.write(message)了。