首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Sprint Boot如何基于Redis发布订阅实现异步消息系统的同步调用?

    在很多互联网应用系统中,请求处理异步化是提升系统性能一种常用的手段,而基于消息系统的异步处理由于具备高可靠性、高吞吐量的特点,因而在并发请求量比较高的互联网系统中被广泛应用。与此同时,这种方案也带来了调用链路处理上的问题,因为大部分应用请求都会要求同步响应实时处理结果,而由于请求的处理过程已经通过消息异步解耦,所以整个调用链路就变成了异步链路,此时请求链路的发起者如何同步拿到响应结果,就需要进行额外的系统设计考虑。 为了更清晰地理解这个问题,小码哥以最近正在做的共享单车的IOT系统为例,给大家来一张图描述下,如图所示:

    03

    解决同时修改数据库表字段的调用顺序问题

    AB两个接口更新同一个表的字段,但是以B接口下发数据为准,上游调用A接口的同时调用C接口,C接口再同时调用B接口,理论情况下更新时间是按着A先插入了tabel的字段,B再进行更新,最终数据是以B接口下发数据为准的,但由于A接口下发业务逻辑复杂,导致短时间A接口未提交事务时B接口被调用就进行了更新并提交事务导致A接口的事务提交覆盖了B操作,但更可怕的就是A还未提交事务,表中无数据可更新,B无法更新的情况如何更新数据?目前方案在B接口调用时放入缓存数据,在A接口被调用时缓存中有数据则更新缓存中的数据,没有则表明此时B还未被调用则不更新,常规的发生异常或者B后提交事务可以解决,但是A未提交事务时,B无法更新的情况如何处理?

    01

    SignalR

    SignalR是一个继承的客户端与服务器库,基于浏览器的客户端和基于ASP.NET的服务器组件可以借助它来进行双向多步对话,换句话说,该对话可不受限制的进行单个无状态请求/响应数据交换;它将继续,直到明确关闭。对话通过永久连接进行,允许客户端和服务器发送多个消息,并允许服务器做出相应答复,值得注意的是,还允许服务器向服务端发送异步消息,它和Ajax类似,都是基于现有的技术。本身时一个复合体。一般情况下,SignalR会使用JS的长轮询(long polling),实现客户端和服务端通信。在WebSockets出现以后,SignalR也支持WebSockets通信。当然SignalR也使用了服务端的任务并行处理技术以提高服务器的扩展性。它的目标整个.NET Framework平台,它也不限Hosting的应用程序,而且还是跨平台的开源项目,支持Mono2.10+,觉得它变成时Web API的另一种实作选择,但是它在服务端处理联机的功能上比ASP.NET MVC的Web API要强多了,更重要的是,它可以在Web Form使用

    02
    领券