目前使用的是 rabbitmq 作为队列服务,比如有系统 A 和 B ,目前使用方式是:
系统 A 先把消息放在自己的 redis 里面,然后每分钟起脚本,读取( lpop ) 300 条,调 B 系统的 curl 接口;
系统 B 的接口接到消息,放在自己的 MQ queue 里面,然后起脚本消费 MQ 消息处理
我倾向的方案:
按照之前的工作经验,系统 A 和系统 B 共连一个 MQ 地址,定义一个 vhost.exchange.queue_name , A 有消息就朝里面塞, B 可以定时取就可以了啊
求各位老司机的方案!