rabbitmq04 消息持久化

2018-09-20

消息持久化

之前我们考虑过，如果worker崩溃，消息将会丢失，所以引入了ack。那如果整个rabbitmq崩溃，那怎么办呢？

将队列声明为持久化

1 2	# 在queue_declare的时候，使用durable=True定义队列 channel.queue_declare(queue='task_queue', durable=True)

将消息声明为持久化

# 在basic_publish的时候，引入propertie参数
channel.basic_publish(exchange='',
                      routing_key='task_queue',
                      body=message,
                      properties=pika.BasicProperties(
                         delivery_mode = 2, # make message persistent
                      ))

这样，我们的rabbitmq在异常情况下关闭或者重启的时候就能够对消息进行持久化的保存了。

缺失模块。
1、请确保node版本大于6.2
2、在博客根目录（注意不是yilia根目录）执行以下命令：
npm i hexo-generator-json-content --save

3、在根目录_config.yml里添加配置：

  jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

大树， 人在首都，就职猪厂, 测试开发一枚 骐骥一跃不能十步，驽马十驾功在不舍 qq:565506019