docker-compose客户端rabbitmq compose
RabbitMQ高可用集群的搭建部署（Centos7）
高可用集群架构 节点域名 操作系统 RabbitMQ版本 Erlang版本 iamdemo.tp-link.com Centos7.9 3.8.28 23.3-2 iamdemo2.tp-link.com Centos7.9 3.8.28 23.3-2 iamdemo3.tp-link.com Ce ......
RabbitMQ 延迟消息的实现——死信交换机（不推荐）
生产者给MQ发送 带过期时间的消息： @GetMapping("/mq07")public void sendTTLMessage(){ //第四个参数：后置消息处理器。用后置消息处理器给消息加过期时间 rabbitTemplate.convertAndSend("simple.direct", " ......
RabbitMQ 消费者可靠性——业务幂等性
如何保证业务是幂等的？ 方案一： 生产者、消费者都配置上 setCreateMessageIds(true)。配好后，生产者给MQ发消息，消息就会带上自动生成的 id。将来消费者拿到消息后，就可以获取到 id，把 id保存起来 做唯一匹配 代码示例： package com.itheima;impo ......
RabbitMQ避免重复消费
在Java中，可以使用消息队列来实现消息的异步处理，其中常用的消息队列有 RabbitMQ、ActiveMQ、Kafka 等。 什么是幂等性？ 幂等性是指无论操作执行多少次，都是得到相同的结果，而不会产生其他副作用。 在rabbitMQ中 什么是消息重复消费？ 同一条消息在MQ中被消费多次 出现重复 ......
Nginx docker compose 挂载
Nginx docker compose 挂载 version: "3" services: nginx: image: nginx:1.22.1 ports: - "80:80" volumes: - "/home/nginx/html:/usr/share/nginx/html" - "ngin ......
RabbitMQ 消费者可靠性——失败重试机制
效果： 消费者抛异常后，会本地重试，如果本地重试次数达到最大重试次数之后，直接给队列返回reject，队列收到后就会丢弃该消息，也就是策略的第一种 但就这样把删了不太好，所以有了失败消息处理策略 第二种 ImmediateRequeueMessageRecoverer：消费者抛异常后，会本地重试，如 ......
RabbitMQ 消费者可靠性——消费者确认
代码示例： 在消费者的 appplication.yml 文件中加入配置： spring: rabbitmq: listener: simple: acknowledge-mode: auto ......
RabbitMQ 生产者可靠性——生产者确认原理
生产者确认更加注重 消息发送失败时该怎么办 消息发送失败 采用的是确认机制（有两种确认机制：Publisher Confirm 和 Publisher Return） ......
RabbitMQ 生产者可靠性——生产者重连
我们配置的这个失败后的重连机制仅仅是发送者连接MQ失败 的 连接失败重试，如果消息发送抛出异常时不会重试，因为它只是连接失败的重试，不是消息发送的重试 spring: rabbitmq: host: 192.168.88.130 port: 5672 virtual-host: /hmall use ......
01.用户端Web自动化测试
1.css调试四要素：$符号 小括号() 字符串“” 单双引号 2.元素定位有多个类名要把空格换成点 3.文本定位使用中括号 4.css关系定位 5.xpath高级定位 ......
RabbitMQ 消息转换器
代码示例： 1. 引入依赖 <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId></dependency> 2. 在启动类中创建Bean package ......
RabbitMQ Java代码声明队列和交换机（方法二）
代码示例：创建一个Direct交换机，与两个队列绑定（direct.queue1、direct.queue2） 既是消费者，又可以创建交换机和队列，以及交换机与队列的 RoutingKey @RabbitListener(bindings = @QueueBinding( value = @Queu ......
RabbitMQ Java代码声明队列和交换机（方法一）
交换机和队列的声明一般写在消费者模块里 代码示例： package com.itheima.config_RabbitMQ;import org.springframework.amqp.core.*;import org.springframework.context.annotation.Bea ......
RabbitMQ Topic交换机
代码示例： 1. 新建两个队列 2. 创建交换机，名字叫 hmall.topic，类型选择 topic 3. hmall.topic 交换机绑定第一步的两个队列，绑定过程中填写 RoutingKey 4. 编写消费者代码监听这两个队列 @RabbitListener(queues = "topic. ......
RabbitMQ Direct交换机
代码示例： 1. 交换机绑定了两个队列，并给它们设置了RoutingKey 2. publisher 发送者给 Direct 交换机发消息时，第二个参数指定 RoutingKey： @GetMapping("/mq03")public void mq03(){ String exchangeName ......
RabbitMQ 发送消息到交换机
发送消息到交换机的代码： @GetMapping("/mq02")//发送消息给交换机public void mq02(){ String exchangeName = "hmall.fanout"; String msg = "hello, 每个人"; //三个参数：交换机名称、RoutingKe ......
RabbitMQ Fanout交换机
容易搞混的点： 1. 假如 publisher 给Fanout交换机发送了一条消息，那么Fanout交换机会给每一个绑定到它身上的队列都发送这条消息，也就是说有多少个队列跟它绑定了，这条消息就有几份，每个队列都收到一份。 2. 假如一个队列绑定了多个消费者，那么该队列在给消费者投递消息时就是轮询，一 ......
tp6 composer安装workerman报错
命令：composer require topthink/think-worker 错误信息： Problem 1 - Root composer.json requires topthink/think-worker ^4.0 -> satisfiable by topthink/think-wo ......
rabbitmq的推(push)拉(pull)模式介绍及代码实现
在rabbitmq中有两种消息处理的模式，一种是推模式/订阅模式/投递模式（也叫push模式），消费者调用channel.basicConsume方法订阅队列后，由RabbitMQ主动将消息推送给订阅队列的消费者；另一种是拉模式/检索模式（也叫pull模式），需要消费者调用channel.basic ......
redis 客户端常见异常汇总
无法从连接池获取数据 高并发下连接池设置过小 连接被占用归还不及时，新连接被拒绝，增加最大连接数。 客户端未正确释放连接池 及时归还释放操作，避免无效占用。 慢查询 服务端阻塞 客户端读写超时 超时判定时间过短 命令本身执行就需要大量时间 客户端与服务端网络信道不稳定 redis阻塞 客户端连接超时 ......
RabbitMQ work模型
默认情况下，MQ队列如果绑定了多个消费者，那么队列在投递消息时就是轮询，一人投递一个（并且一条消息只能投递给监听该队列的某一个消费者） 在一个MQ队列上绑定多个消费者的目的是加快队列中消息的处理效率，防止队列中消息的堆积问题。 注：要在消费者的 application.yml 文件中加上这个配置 ......
RabbitMQ 接收队列的消息
代码示例： 注：要把这个类加上Component注解 package com.itheima.amqp_listener;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframewo ......
RabbitMQ 发送消息到队列（交换机不参与的那种）
1. 导包 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId></dependency> 2.在 application.yml 文件里编 ......
docker-compose version 版本匹配
version: '3.8' services: rmqnamesrv: image: apache/rocketmq:5.1.0 container_name: rmqnamesrv ports: - 9876:9876 restart: always privileged: true volum ......
XmlRPC入门_基于组合类型的客户端、服务端
1、客户端 #include <stdlib.h> #include <stdio.h> #include <xmlrpc-c/base.h> #include <xmlrpc-c/client.h> #include "config.h" /* information about this bui ......
XmlRPC入门_基于C的服务端、客户端
以下客户端与服务端的代码内容为官网给出的示例，此处拷贝记录，了解基础使用方式。 1、服务端 #include <iostream> #include <winsock2.h> #include <windows.h> #include "xmlrpc-c/base.h" #include "xmlr ......
Doker：最新docker-compose操作
1. docker compose说明 目前docker新版本已经集成docker compose工具，直接使用"docker compose"命令就可以操作 2. docker-compose.yml文件说明 docker compose命令的运行需要docker-compose.yml文件的支持 ......
百度网盘免客户端下载方法
(function(){ var _id = 309847; var isHome = $('a[title="我的卡包"]').html(); var _temp = isHome ? "" : $('span[title]:first').attr('title').slice(4); var ......