以往都是生产者发送消息,消费者原封不动接收消息,现在能不能这样: 客户端发送消息给rabbitmq服务器,然后服务器怎么加工这条消息,比方客户端发送帮我看看股票 001111 股价是否站上5日均线,然后 rabbitMQ 需要去爬股票网的数据,然后计算5日均线,计算结果为TRUE,则发送确认消息到消费端, 如果是FALSE则发送没有达到条件的消息到消费端,这样需要去改 rabbitMQ的源码吗,因为计算的代码都是在服务器的
4条回答 默认 最新
檀越@新空间 2024-05-20 05:52关注上午好☀️☀️☀️️
本答案参考ChatGPT-3.5可以使用RabbitMQ的插件来实现这样的需求,不需要修改RabbitMQ的源码。RabbitMQ插件可以监听RabbitMQ所在的队列,并在接收到消息时进行一定的处理。下面是实现方案:
-
编写爬虫程序,用于去爬取股票网的数据,并计算5日均线。将计算后的结果存储到数据库中。
-
编写RabbitMQ插件,用于监听RabbitMQ所在的队列,当接收到消息时,调用爬虫程序进行计算并将计算结果存储到数据库中。
-
在RabbitMQ的消费端,监听数据库中的计算结果表,如果计算结果为TRUE,则发送确认消息到消费端;否则发送没有达到条件的消息到消费端。
需要注意的是,如果你使用的是RabbitMQ的集群,需要将上述两个步骤都在每个节点上进行,以保证插件能够正常运行。
参考文献:
- RabbitMQ Plugins:http://www.rabbitmq.com/plugins.html
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏 举报-