小程序验证点击收藏

发布时间：2025-06-24 18:13:55  作者：北方职教升学中心  阅读量：238

创建虚拟主机

五、拉取RabbitMQ镜像

4、编写接收方接收消息

/** * 接收消息 */@Component@RequiredArgsConstructorpublic class StoreListener {    private final IStoreService storeService;    @RabbitListener(bindings = @QueueBinding(            value = @Queue(name = "store.addFavorite.success.queue", durable = "true"), // 队列 起名规则（服务名+业务名+成功+队列），durable持久化            exchange = @Exchange(name = "addFavorite.direct"), // 交换机名称，交换机默认类型就行direct，所以不用配置direct            key = "addFavorite.success" // 绑定的key    ))    public void listenAddFavoriteCountsSuccess(Long storeId){        storeService.updateStoreFavoriteUsersCountAdd1(storeId);    }}

虽然代码里面也已经解释了，但是下面也再解释一下：

value：是队列信息。关于图形化界面可能出现的问题
Stats in management UI are disabled on this node
可以参考这篇博客：
RabbitMQ客户端界面问题 Stats in management UI are disabled on this node-CSDN博客
五、docker中安装rabbitmq
1、
在其他教程到这一步已经可以了，可以参考下面两篇博客：
宝塔面板安装RabbitMQ（已解决）_宝塔安装rabbitmq-CSDN博客
宝塔安装rabbitMQ实战-CSDN博客
四、RabbitMQ安装
二、创建虚拟主机
创建一个单独的虚拟主机来进行隔离，这里可以参考前面在虚拟机上的操作。启动RabbitMQ
三、
目录
一、
再次去：https://www.erlang-solutions.com/downloads/#
我是centos7，所以下载该版本。
3、后来猜到应该是客户端服务可能是没开启，在之前宝塔软件里面好像有看过这个东西。部署项目验证
六、
去查看mq客户端：
成功更新，说明使用RabbitMQ实现异步通讯成功。安装RabbitMQ
在软件商店中安装RabbitMQ
出现问题：
看到报错日志，我又去下载报错日志里面的版本。开放客户端服务
在mq容器中打开终端
列出所有可用的插件：
rabbitmq-plugins list
找到rabbitmq_management：
开启rabbitmq_management：
rabbitmq-plugins enable rabbitmq_management
然后再访问客户端，成功访问：
7、小程序验证
三、
六、RabbitMQ安装
由于在测试环境中，我们现在虚拟机上基于docker安装mq
docker run \ -e RABBITMQ_DEFAULT_USER=quick \ -e RABBITMQ_DEFAULT_PASS=123 \ -v mq-plugins:/plugins \ --name mq \ --hostname mq \ -p 15672:15672 \ -p 5672:5672 \ --network your-net\ -d \ rabbitmq:3.8-management
在docker环境上运行改指令
前两个是登录的用户名密码
network是连接的网络，如果用默认网络的话就不需要写
最后一个是版本，这个是目前测试的版本
二、
在RabbitMQ的界面中队列也有一条消息出现，说明mq实现异步通讯成功。编写发送方发送消息
6、
6、编写发送方发送消息
@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);        // 更新商品表,收藏数+1        //storeService.updateStoreFavoriteUsersCountAdd1(storeId);        // 发送消息 (交换机+绑定的key和发送的消息)        try {            rabbitTemplate.convertAndSend("addFavorite.direct","addFavorite.success",storeId);        } catch (Exception e) {            log.error("发送添加收藏消息失败，店铺id：{}",storeService,e);}    }
虽然代码里面也已经解释了，但是下面也再解释一下：
"addFavorite.direct"：是交换机名称，和接收方一致
"addFavorite.success"：是绑定的key，和接收方一致
storeId：是发送的信息
6、前往宝塔面板
进入tmp目录，将之前的rpm包放进去。
收藏成功，去看一下数据库，查看是否更新。
安装之前注意版本兼容问题：Erlang Version Requirements | RabbitMQ
安装erlang地址：https://www.erlang-solutions.com/downloads/#
（1）查看rabbitmq的版本
先去宝塔查看rabbitmq的版本：
（2）查找erlang兼容版本
然后去找到版本兼容的erlang版本：Erlang Version Requirements | RabbitMQ
（3）安装RPM包
去下载：https://www.erlang-solutions.com/downloads/#
 
下载后拿到rpm文件：
注意：这里没有下载的版本，下载需要与自己的版本一致，如果发现启动不了RabbitMQ，请看后面的启动RabbitMQ。
参考博客：Docker RabbitMQ安装_all stable feature flags must be enabled after com-CSDN博客
8、配置docker镜像加速
3、登录RabbitMQ客户端
8、引入依赖
2、起名规则（服务名+业务名+成功+队列），durable表示持久化

exchange：是交换机名称。开放客户端服务
7、查看镜像和容器
docker imagesdocker ps
到这里已经是成功在docker中装好mq容器了
但是在我访问http://主机ip:15672的时候却无法访问，即使我开放了服务器的安全组。部署项目验证
参考我之前的博客：记录部署项目《庆自提》完整流程-CSDN博客
修改yml配置文件，修改下面的消息：
rabbitmq:    host: ${quick.rabbitmq.host}    port: ${quick.rabbitmq.port} # 端口    virtual-host: ${quick.rabbitmq.virtual-host} # 虚拟主机    username: ${quick.rabbitmq.username} # 用户名    password: ${quick.rabbitmq.password} # 密码
在已经上线的小程序测试~~
目前只有一个人收藏，现在去测试一下。宝塔中安装RabbitMQ
1、查看镜像和容器
6、登录RabbitMQ客户端
这里显示有些特性标志未开启，我们可以去开启那些标志。拓展使用
关于一些拓展使用可以参考以下这些博客：
RabbitMQ实现多线程处理接收消息-CSDN博客
在配置mq过程中遇到许许多多的bug和问题，改了很久很久，如果里面有哪些不足的欢迎指正和建议！！！