现在我有一个webservice接口供客户方调用,以后可能并发量会越来越大。上头让我了解下mq,将请求缓存到队列中,进行流量削峰。我不太明白,客户调用接口就进入接口内了,代码上应该写在接口前,具体该怎么写呢?
就比如,一秒钟内来了一万次请求,我让服务器一秒内处理500条,其他的缓存到队列这样
现在我有一个webservice接口供客户方调用,以后可能并发量会越来越大。上头让我了解下mq,将请求缓存到队列中,进行流量削峰。我不太明白,客户调用接口就进入接口内了,代码上应该写在接口前,具体该怎么写呢?
就比如,一秒钟内来了一万次请求,我让服务器一秒内处理500条,其他的缓存到队列这样
mq队列了解一下,主流的有Apache的activemq(带ack机制)、rocketmq(阿里的现已捐献给Apache),rabbitmq,kafka(一般用于大数据)。甚至你还可以用redis。
mq是一种做异步架构常用的策略。既能做到架构解耦,又能提高系统可靠性和吞吐能力。