本文主要是介绍RabbitMQ应用一:分散业务处理,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
对于需要处理很多工作的业务接口中,对各种接口的调用往往造成这个接口耗时过长,而各种接口的频繁调用,也对服务器造成了很大压力。用线程来解决前面的问题,在线程的新建和销毁都需要耗费时间,即使用线程池来实现,服务器照样也有压力。而提升服务器性能来解决后一个问题,性价比不够高。如果这时能用上MQ,不为是一个比较好的解决方法。
如上图所示,在一个博彩类APP中,用户在界面下注比赛,会调用服务器的下注接口。下注接口是一个业务处理量非常大的接口。对用户的体验也非常主要,谁也不想下注一场比赛要等好几秒才下单成功。但这个接口不仅要把下注信息写入到数据库中,还要统计很多信息,比如用户的喜好,用户花费金额的排行榜,下注额在一场比赛的某一方的总额,总额过高,就要调低这一方的赔率,防止黑天鹅事件导致公司亏损过大等。
在普通应用处理场景,一条流水线下来,每个业务处理都要花费时间,同步进行的处理,累积出来的时间就延长了。如果访问量过大,还会造成服务器崩溃。所以我们想到,最重要的主业务还是主服务器处理,而那些统计及其其他不重要、不需要及时反馈的业务处理通过MQ来发送。MQ再推送到其他副业务处理服务器上处理。减轻了服务器压力,提高了响应能力。
详细代码参考我的git项目:https://github.com/888xin/rabbitmq
里面的主服务器(也就是MQ的发送端)是项目:rabbit-pruducer , 副服务器(也就是MQ的消费端)是项目:rabbit-consumer
主服务器端(MQ发送端)先实现下注逻辑PlayBall.java
package com.lhx.contest;import com.lhx.bean.Bet;
import org.codehaus.jackson.map.ObjectMapper;
import org.slf4j.Lo
这篇关于RabbitMQ应用一:分散业务处理的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!