文档章节

异步转同步

xpbug
 xpbug
发布于 2016/03/02 19:34
字数 875
阅读 181
收藏 3

下面是一个CS架构的部署, 服务端是SEDA类型的架构,消息传输完全是异步。而客户端在使用SDK向服务端发起请求。为了方便客户的使用,我们希望能提供同步方式的SDK。所以我们的SDK需要将异步消息转换成同步消息。如何做到这一点呢?

因为服务器需要保持CPU的充分利用,所以异步转同步的工作不应该由Server完成,而应该有SDK来完成。简单的讲,异步转同步的流程应该分成这么几个步骤:

  1. SDK发出请求

  2. SDK等待返回

  3. 服务端持续返回消息

  4. 返回的消息和请求匹配上

  5. SDK返回响应

把以上的步骤封装在SDK里面,上面的示意图可以演变为下面的图

在实现中,requestNo和Waiter是实现的关键。RequestNo使发出的请求和返回的响应能够匹配上,而Waiter则可以使SDK等待,当拿到响应以后,唤醒SDK,返回响应。

略微解释一下上图的流程:

  1. Client调用Sender准备发请求。Sender先生成一个requestNo,将requestNo贴到请求上。然后生成一个waiter,将requestNo和waiter放入Map中。Map中存有所有正在等待消息返回的waiter。然后Sender阻塞在waiter的standby(timeout)方法上。

  2. Sender将消息塞入发送队列。

  3. Connection从发送队列取出消息。

  4. Connection发消息给Server。

  5. Server持续异步返回各类消息。

  6. Connection将返回的消息放入接收队列。

  7. Receiver从接收队里中取出消息。

  8. Receiver从消息中获取requestNo,然后从Map中获取相应的waiter。并调用waiter的accept( )方法。

  9. Waiter接受了消息,并确认成功接收到所有的响应消息。唤醒Sender。

  10. Sender返回消息给client。

public class Sender {
    public IObject send(IObject request, long timeout) {
        String requestNo = getRequestNo();
        waiter = new Waiter(client, requestNo);
        client.waiters.put(requestNo, waiter);
        request.set("requestNo", requestNo);
        connection.send(request);
        waiter.standby(timeout);  // Block
        int state = waiter.getState(); // 0=waiting first, 1=waiting next, 2=timeout, 3=complete
        if (state == 3) {
            return waiter.getResult();
        } else {
            // create new response for failure.
        }
    }
}

public class Receiver {
    public void receive(IObject msg) {
        String requestNo = node.get("requestNo");
        Waiter waiter = client.waiters.get(requestNo);
        if (waiter != null) {
            if (waiter.accept(msg)) return;
        }
        // 如果消息不被接受,则发给MessageHandler来处理。        
        if (client.handler != null) {
            client.handler.handleMessage(msg);
        }
    }
}

public class Waiter {
    // 0=waiting first; 1=waiting second; 2=timeout; 3=complete 
    private int state=0;
    private List<IObject> messages;
    
    public synchronized void standby(long timeout) {
        try {
            this.wait(timeout);
        } catch (InterruptedException e) {
        }
        if (state < 2) {
            state = 2;
            client.waiters.remove(requestNo);
        }
    }
 
    public synchronized boolean accept(IObject msg) {
        if (state >= 2) {
            // waiter is closed
            return false;
        } 
         
        try {
            if (state == 0) {
                // 收到第一个返回的消息
                messages.add(msg)
                // 查看是否还有后续消息
                // 设置state的状态
                // 如果需要后续消息, return true
            }
            if (state == 1) {
                // 如果不是期待的消息类型, return false
                // 收到了后续消息
                messages.add(msg)
                // 设置状态
                // 如果需要后续消息, return true
            }
            state = 3;
            client.waiters.remove(requestNo);
            // 唤醒SDK
            this.notifyAll();
            return true;
        } catch (Exception e) {
            // 发生解析错误, 创建错误消息
            messages.add(err)
            state = 3;
            client.waiters.remove(requestNo);
            this.notifyAll();
            return true;
        } 
    }
    
    public synchronized IObject getResult() {
        // 将message列表中的消息合并成一个result
        return result;
    }
}


© 著作权归作者所有

共有 人打赏支持
xpbug
粉丝 303
博文 102
码字总数 125336
作品 0
浦东
程序员
私信 提问
关于Alipay支付宝接口(Java版)下

4.alipay 页面跳转同步通知处理 4.1 页面跳转同步通知   当买家完成了支付流程后,会出现成功支付的页面,该页面做短暂停留后,会跳转到我们AlipayConfig.xml中的 return_url 属性所指定的...

站在云端er
2016/08/22
20
0
ajax 同步和异步的区别|已迁移

同步会阻塞后面的代码,也就是说假设这个ajax请求要3 5秒,浏览器就会阻塞住3 5秒不执行后面的,知道等到ajax请求完成。 而且同步不能直接使用jsonp。 异步不能在回调之外直接拿到返回的dat...

辣条拌鱼翅
2015/07/20
0
0
java 异步查询转同步多种实现方式:循环等待,CountDownLatch,Spring EventListener

异步转同步 业务需求 有些接口查询反馈结果是异步返回的,无法立刻获取查询结果。 正常处理逻辑 触发异步操作,然后传递一个唯一标识。 等到异步结果返回,根据传入的唯一标识,匹配此次结果...

叶止水
08/11
0
0
将不确定变为确定~开发人员应该明确知道跨域Post的问题

注意:这里的跨域指不到同一域名下,包括一级与二级域名,这里也认为不在同域下 从A网站把信息以Post的方式发送到B网站,这种过程叫做跨域POST,相类的,A网站把B网站的信息获取回来,一般称...

mcy247
2017/12/05
0
0
爱上MVC3系列~当Ajax.Beform不能满足我们的要求时...

mvc架构中提供了Html.BeginForm与Ajax.BeginForm,主要实现同步提交表单与异步提交表单,对于同步提交与传统的方式没有区别,而异步表单MVC自己进行了封装(可以看我的文章了解两种方式的表单...

mcy247
2017/12/06
0
0

没有更多内容

加载失败,请刷新页面

加载更多

js前端图片处理例子

首先需要了解几个api FileReader FileReader主要用于将文件内容读入内存,通过一系列异步接口,可以在主线程中访问本地文件。 <table> <tr> <th>方法定义</th> <th>描述</th> </tr> <tr> <t......

别人说我名字很长
11分钟前
0
0
前端常用插件、工具类库汇总(下)

前言 对本文感兴趣可以先加个收藏,也可以转发分享给身边的小伙伴,以后遇到类似的场景就来看看具体的插件及其用法。 上一篇《前端常用插件、工具类库汇总(上)》内容摘要: 动画库 滚动库 ...

我的卡
18分钟前
2
0
jq 的 $ 符号冲突解决办法

百度了一下,都是 感觉挺负责的,我只是想当前页面 简单使用jq ,解决冲突即可。 很简单的 将 $ 符号换成 jQuery 即可,就不怕冲突了。 jQuery('#message').val();...

之渊
19分钟前
0
0
如何在Cordova Android 7.0.0 以下版本集成最新插件 极光插件为例

前提 Cordova Android 7.0.0开始改变了项目安卓平台的架构。新建一个空项目分别添加Android 6.4.0 和 Android 7.0.0平台: cordova platform add android@6.4.0cordova platform add androi...

极光推送
27分钟前
0
0
移动端Appium自动化测试框架的优势

众所周知,现在市面上的移动端操作系统已被Android和IOS占领,其中Android的份额更是在80%以上。那么面对市面上林林总总的自动化测试框架和工具,为什么说Appium在自动化测试框架的统治级优势...

程序猿拿Q
41分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部