apache mina 同步接收客户端消息

uf123

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

• session.getConfig().setUseReadOperation(true);  
  

　　

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

• 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 
 
Java代码  

• 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