docker run 

        <!--rabbitmq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

spring:
  rabbitmq:
    host: ${quick.rabbitmq.host}
    port: ${quick.rabbitmq.port} # 端口
    virtual-host: ${quick.rabbitmq.virtual-host} # 虛擬主機(jī)
    username: ${quick.rabbitmq.username} # 用戶名
    password: ${quick.rabbitmq.password} # 密碼
quick:
  rabbitmq:
    host: 192.168.75.101 #服務(wù)器ip地址（此處為虛擬機(jī)地址）
    port: 5672 # 端口
    virtual-host: /xxx # 虛擬主機(jī)
    username: xxx # 用戶名
    password: xxx # 密碼
    listener:
      simple:
        acknowledge-mode: auto # 自動(dòng)ack
        retry:
          enabled: true # 開(kāi)啟消費(fèi)者失敗重試
          initial-interval: 1000ms # 初識(shí)的失敗等待時(shí)長(zhǎng)為1秒
          multiplier: 1 # 失敗的等待時(shí)長(zhǎng)倍數(shù)，下次等待時(shí)長(zhǎng) = multiplier * last-interval
          max-attempts: 3 # 最大重試次數(shù)
          stateless: false # true無(wú)狀態(tài)；false有狀態(tài)。如果業(yè)務(wù)中包含事務(wù)，這里改為false
    publisher-confirm-type: CORRELATED # 交換機(jī)的確認(rèn)
    publisher-returns: true # 隊(duì)列的確認(rèn)

/**
 * 配置消息轉(zhuǎn)換器
 */
@Configuration
@ConditionalOnClass(RabbitTemplate.class) //有RabbitTemplate依賴才會(huì)生效，否則不生效
public class MqConfig {
    @Bean
    public MessageConverter messageConverter(){
        //使用json序列化發(fā)送消息
        return new Jackson2JsonMessageConverter();
    }
}

/**
 * 接收消息
 */
@Component
@RequiredArgsConstructor
public class StoreListener {
    private final IStoreService storeService;
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "store.addFavorite.success.queue", durable = "true"), // 隊(duì)列 起名規(guī)則（服務(wù)名+業(yè)務(wù)名+成功+隊(duì)列），durable持久化
            exchange = @Exchange(name = "addFavorite.direct"), // 交換機(jī)名稱(chēng)，交換機(jī)默認(rèn)類(lèi)型就行direct，所以不用配置direct
            key = "addFavorite.success" // 綁定的key
    ))
    public void listenAddFavoriteCountsSuccess(Long storeId){
        storeService.updateStoreFavoriteUsersCountAdd1(storeId);
    }
}

@Transactional
    @Override
    public void add(Long storeId) {
        Favorite favorite = Favorite.builder()
                .storeId(storeId)
                .userId(BaseContext.getCurrentId()).build();
        Favorite one = Db.getOne(favorite);
        if (one!=null){
            throw new FavoriteException(MessageConstant.COLLECTION_BE_REPEAT);
        }
        // 更新收藏表
        favoriteMapper.insert(favorite);
        // 更新商品表,收藏?cái)?shù)+1
        //storeService.updateStoreFavoriteUsersCountAdd1(storeId);
        // 發(fā)送消息 (交換機(jī)+綁定的key和發(fā)送的消息)
        try {
            rabbitTemplate.convertAndSend("addFavorite.direct","addFavorite.success",storeId);
        } catch (Exception e) {
            log.error("發(fā)送添加收藏消息失敗，店鋪id：{}",storeService,e);
        }
    }

# 創(chuàng)建目錄
mkdir -p /etc/docker
# 復(fù)制內(nèi)容，注意把其中的鏡像加速地址改成你自己的
tee /etc/docker/daemon.json <<-'EOF'
{
    "registry-mirrors": [
        "http://hub-mirror.c.163.com",
        "https://mirrors.tuna.tsinghua.edu.cn",
        "http://mirrors.sohu.com",
        "https://ustc-edu-cn.mirror.aliyuncs.com",
        "https://ccr.ccs.tencentyun.com",
        "https://docker.m.daocloud.io",
        "https://docker.awsl9527.cn"
    ]
}
EOF
# 重新加載配置
systemctl daemon-reload
# 重啟Docker
systemctl restart docker

docker pull rabbitmq

docker run 

docker images
docker ps

rabbitmq-plugins list

rabbitmq-plugins enable rabbitmq_management

  rabbitmq:
    host: ${quick.rabbitmq.host}
    port: ${quick.rabbitmq.port} # 端口
    virtual-host: ${quick.rabbitmq.virtual-host} # 虛擬主機(jī)
    username: ${quick.rabbitmq.username} # 用戶名
    password: ${quick.rabbitmq.password} # 密碼