文档章节

异步转同步

xpbug
 xpbug
发布于 2016/03/02 19:34
字数 875
阅读 177
收藏 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
粉丝 302
博文 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

没有更多内容

加载失败,请刷新页面

加载更多

中文地址

火力全開
29分钟前
0
0
71:循环之for、while、break、continue、exit

1、for循环语法: for 变量名 in 条件;do......;done 1:案例1:求1加到100的和: [root@localhost_02 for]# vim for1.sh #!/bin/bashsum=0for i in `seq 1 100`do sum=$[$sum...

芬野de博客
32分钟前
0
0
Log4j2 Analysis

Log4j2 improvement compare with Log4j : AsyncLogger : Implemented by LMAX Disruptor technology (a lock-free inter-thread communication library, instead of queues, resulting in h......

Yixin_Nemo
42分钟前
0
0
玩转js之——new方法的模拟实现

已知new的作用 1.实例可以访问到构造函数的属性和方法 2.实例可以访问到构造函数原型中的属性和方法 //demo:function Person(name, age) { this.name = name this.age = age}Person...

lsner
42分钟前
0
0
SQL--索引使用(1)

以下是优化真实环境sql。 一、原始sql查询时长如下 二、EXPLAIN分析如下,说明 关于explain的讲解详见我另一篇文章 三、结合sql语句分析出 3.1 可以单独给business_id加索引,会优化一部分效...

求是科技
44分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部