当前位置: 首页 > 网络应用技术

消息队列兔子模式的详细说明

时间:2023-03-06 14:40:53 网络应用技术

  RABBITMQ:3管理安装并启用RabbitMQ_Management

  参数描述:

  查看启动:

  将Docker设置为启动时自动启动(可选)(可选):

  输出结果:

  AMQP://admin@1.14.14.160.174:5672 // lzscxb

  操作结果:

  操作结果:

  从案例中可以看出,一旦新闻消耗,该消息将立即从队列中删除

  RabbitMQ如何知道该消息被消费者接受?

  完整代码:

  如果有两名员工,当所有奇怪的消息都很沉重时,即使是新闻也很轻,一名员工总是很忙,另一个员工也不做任何工作。均匀地分发消息。这是因为rabbitmq在输入队列时发送消息。它没有查看未确认消息的用户数量。它只是将N新闻盲目地分配给NN消费者。

  为了克服此问题,我们可以使用设置的基本QOS方法设置来prefetchcount = 1。这告诉兔子。请勿一次向工人发送消息,换句话说,请勿在工作处理和确认上一条消息之前向其发送新闻。instead,它将将其分发给下一个非笨拙的工人。

  您必须使用ACK确认消息才能生效

  生活中的案例:这是玩Douyin Fast Hands。许多粉丝正在关注视频主。视频所有者摆放视频。所有粉丝都可以收到视频通知

  X队列通过渠道向消费者发送信息以消费

  在整个过程中,您必须首先创建一个路由

  运行程序的顺序:

  1.消息人士

  路线将根据图中所示,根据不同队列的类型执行定向分布消息。

  它可以理解为快递公司的分类中心。

  原始:https://juejin.cn/post/7112700994009432072

猜你喜欢