java-如何在等待响应的同时实现请求响应协议而不会阻塞？

2019-12-02 07:04:32 阅读：457 来源： 互联网

标签：concurrency networking protocols nonblocking java

我需要实现一个使用(双向)请求-响应协议与多个客户端同时通信的应用程序.以前,我为每个客户端使用两个专用线程(一个读取器/反应器和一个写入器/发起器)来实现此目的.问题是线程管理变得非常复杂和丑陋.是否有任何标准的处理方式,甚至可能只有一个线程,或者至少有恒定数量的线程来处理所有客户端？

这是使用阻塞实现的某种通信在线程中的外观：

Command response = request("cmd1", "a", "b");
if(!response.is("OK")) {
    return;
}
response = request("cmd2", "c");
if(!response.is("OK")) {
    return;
}
response = request("cmd3");

在发送请求和等待相应的响应之间,我希望当前线程能够执行其他工作,但是一旦响应实际到达,便继续执行.

我知道,一旦收到请求的响应,就有可能使用异步IO并注册Java Future / Runnable实例来运行,但是这很容易变成匿名Runnable子类的多层嵌套,我怀疑它将是那就值得付出更多的痛苦.这可能会导致类似于下面的示例的内容,该内容很快变得高度嵌套且难以读取.当然,必须有一种更简单的方法吗？

request("cmd1", "a", "b", new ResponseHandler() {
    public void response(Command response) {
        if(response.is("OK")) {
            request("cmd2", "c", new ResponseHandler() {
                public void response(Command response) {
                    if(response.is("OK")) {
                        request("cmd3", new NullResponseHandler());
                    }
                }});
        }
    }});

我还考虑了使用专用的Actor framework处理请求-响应逻辑的可能性.尽管它们看起来可以在这种情况下提供帮助,但我之前从未使用过此类框架,因此我不知道它们是否适合这种情况.

简而言之,我的问题是：如何以非阻塞方式处理任意数量的请求-响应连接,以便恒定数量的线程就足够了？ Actor框架是有效的方法吗？

PS.我正在为此项目使用Java.

解决方法:

我认为使用某些Java NIO框架(例如. netty.没有使用Actor框架,所以不知道这是否更合适.

基本上,您创建一个处理整个通信并存储必要信息的类-该框架在后台处理整个线程,您只需提供一种方法即可. messageReceived并在那里处理.

缺点是,您必须基本上编写自己的状态机,这可能不是那么简单-但这无疑是使用NIO的最简单方法.

例：

enum State {
    S0, S1
}
private State state = State.S0;
public void messageReceived(
        ChannelHandlerContext ctx, MessageEvent e) {
    switch(state) {
    case S0:
        // read object from channel and write appropriate response
        e.getChannel().write("HELO");  // writes are asynchronous 
        state = State.S1;
        break;
    case S1:
        // same as S0
        e.getChannel().write("DONE");
        break;
    }
}

请注意,仍然仍然绝对需要阅读netty教程,因为关于NIO的某些事情不是自我解释的(至少对于我来说不是).但是,有几个易于操作的示例可以教您一些基础知识.

标签：concurrency,networking,protocols,nonblocking,java
来源： https://codeday.me/bug/20191202/2086563.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java-如何在等待响应的同时实现请求响应协议而不会阻塞？