和外部系统对接,对方是HTTP调用将消息推过来
为了性能和健壮性考虑,希望将HTTP body放到RabbitMQ(或者Kafka等)里,然后由多个订阅者处理
一种方法就是spring写个简单的web项目,然后拦截所有请求写入MQ
或者直接自动写库也可以
和外部系统对接,对方是HTTP调用将消息推过来
为了性能和健壮性考虑,希望将HTTP body放到RabbitMQ(或者Kafka等)里,然后由多个订阅者处理
一种方法就是spring写个简单的web项目,然后拦截所有请求写入MQ
或者直接自动写库也可以
就是个同步请求转异步处理的场景,就在web项目中收到请求后,想msg_body写进队列就行了,注意下幂等和重试即可。