RabbitMQ是什么,rabbitmq是干什么的

  RabbitMQ是什么,rabbitmq是干什么的

  1、当信息在一个队列中变成死信时,可以重新发送到DLX,绑定DLX的队列称为rabbitmq。

  也叫死信队列。

  2、常用于订单超时自动取消,会议预订提前提醒等等。

  实例

  进口皮卡

  importjson

  进口时间

  凭据=鼠兔。纯凭据( admin , admin)#mq用户名和密码

  #虚拟队列需要指定参数虚拟主机,如果是默认的可以不填。

  连接=鼠兔BlockingConnection(pika .连接参数(主机=127.0.0.1 ,端口=5672,凭据=凭据))

  channel=connection.channel()

  #声明消息队列,消息将在这个队列传递,如不存在,则创建

  queue_name=delay_queue_a

  exchange=delay_exchange_a

  routing _ key= delay _ routing _ key _ a

  dead _ letter _ exchange= dead _ exchange _ a # amq。直接 # dead _ exchange _ a

  dead _ letter _ routing _ key= dead _ letter _ routing _ key _ a # dead _ queue _ a # dead _ letter _ routing _ key _ a

  参数={

  x消息-ttl:5000,

  x-死信交换 :死信交换,

  x-dead-letter-routing-key : dead _ letter _ routing _ key

  }

  渠道。确认_交付()

  渠道。exchange _ declare(exchange=exchange,durable=True,exchange_type=direct )

  结果=渠道。queue _ declare(queue=queue _ name,durable=False,arguments=arguments)

  渠道。queue _ bind(exchange=exchange,queue=队列名称路由关键字=路由关键字)

  (10):

  message=JSON。转储({ OrderId : I })

  #向队列插入数值路由_密钥是队列名

  渠道。basic _ publish(交换=交换,路由密钥=路由密钥,正文=消息

  属性=鼠兔。基本属性(delivery_mode=2))

  打印(消息)

  时间。睡眠(1.5)

  connection.close()以上就是python rabbitmq的介绍,希望对大家有所帮助。更多计算机编程语言学习指路:python基础教程

  本文教程操作环境:windows7系统、Python 3.9.1、戴尔自交第三代电脑。

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: