docker-compose客户端rabbitmq compose
RabbitMQ03
# 1. RabbitMQ死信队列 ## 1.1 死信队列简介 在实际开发项目是，在较为重要的业务场景中，要确保未被消费的消息不被丢弃（例如：订单业 务），那为了保证消息数据的不丢失，可以使用RabbitMQ的死信队列机制，当消息消费发生异 常时，将消息投入到死信队列中进行处理。 死信队列：Rabb ......
rabbitmq 开启 virtual host
由于我的rabbitmq架设在测试服务期。 导致我本地测试的mq消息，经常被服务器消费掉。 所以通过添加v-host，可以创建专属v-host域下的消息进行生产和消费。 一 新增用户 点击Admin,点击右边Users 输入Username Password ，并且Tags给与Admin权限 二 创 ......
docker-compose中的links和depend_on关键字
links link关键字用于在不同的容器之间创建网络链接。 它允许一个容器能够访问另一个容器的网络连接信息（如IP地址和端口）。 使用方法：在Docker Compose配置文件中，通过links关键字定义容器之间的链接关系。例如： version: '3' services: web: buil ......
django使用gunicorn框架，客户端请求耗时接口被中断问题
项目使用的是django，使用了gunicorn作为动态web服务，使用的是supervisor作为进程管理工具。 由于特殊原因，最近上线了一个非常耗时的http接口，一段时间后开始有用户陆续反馈他们的代码调用这个接口会返回502错误，经过一段时间的排查排除了网关的问题，确认是系统问题。 经过日志信 ......
制作有延迟插件的rabbitmq镜像
插件Git官方地址：https://github.com/rabbitmq/rabbitmq-delayed-message-exchange Dockerfile ```shell-session FROM rabbitmq:3.8.2-management ADD ./rabbitmq_dela ......
不更改composer源文件的情况下重写compsoer类
在工作中有时候会遇到原来用的composer包已经不能完全满足需求了，需要重新加入一些功能，这个时候我们可以通过重写composer包类来实现。 ###1.排除的compsoer类，以下为例： ~~~ "exclude-from-classmap": [ "vendor/vectorface/goo ......
WebSocket客户端向服务发送心跳和接收信息
//自定义心跳连接 public bool CheckAndReConnet(out string rcvMessage) { int iConnectTime = 0; rcvMessage = ""; ReConnectLable: if (webSocket == null) { if (iC ......
nginx日志配置显示客户端提交的body和header
第一种方式是直接添加$request_body方式获取，这种获取到的日志中记录的是十六进制的值不方便查看 第二种方式是log_format json_log escape=json '{"realip":"$remote_addr","@timestamp":"$time_iso8601","hos ......
获取邮箱(QQ、126、163)的客户端授权码
# 获取QQ邮箱的客户端授权码 # 获取126邮箱的客户端授权码 1、登录网页版邮箱（https://mail.126.com/)，进入126邮箱首页。 2、点击上方“设置”，选择“POP/SMTP/IMAP”选项。  > 工作队列，又称任 ......
RabbitMQ的消息失败策略
我们都知道消息在消费者端消费的时候，如果消费端出现异常，那么它会依据spring的重试机制进行重试，达到最大重试次数后，消息会被丢弃，这是由Spring内部机制决定的。 在开启重试模式后，重试次数耗尽，如果消息依然失败，则需要有MessageRecovery接口来处理，它包含三种不同的实现： Rej ......
RabbitMQ消息持久化
我们看下之前启动idea测试消息发送的时候在后台生成的一条消息，现在已经在消息队列里面还没有被消费。 现在我们重启下RabbitMQ，执行linux命令：docker restart mq 看上图实时显示的错误信息，失去连接了，接下来刷新这个页面，可以发现这个对象没有了。 说明rabbit消息并不会 ......
docker-compose http curl 实现 自动化部署
### 使用 m2 开启 orbstack 的的 docker 远程 API (docker/damon.json) ``` { "hosts": [ "tcp://0.0.0.0:2375", "unix:///var/run/docker.sock" ], "registry-mirrors": ......
RabbitMQ示例
在MQ之前，我一直使用的redis作为中间人broker然后用celery执行耗时任务。从未在python项目中使用过MQ。所以今天就在django中用RabbitMQ取代redis+celery。 django中使用RabbitMQ： 本次使用RabbitMQ完成点击注册后给用户发送激活邮件的场景 ......
RabbitMQ的死信队列，延时队列
## 死信队列简介 RabbitMQ 的死信队列（Dead Letter Queue）是一种特殊的队列，用于存储那些被标记为“死信”的消息。所谓死信即无法被正常消费和处理的消息，通常是由于一些特定的情况或条件导致的，比如过期、重试次数超过限制等。 ### 普通消息成为死信的常见原因有 - **消息被 ......
Python操作RabbitMq
Python操作RabbitMq：pika--队列） 安装使用其他读取方法 安装 pip install pika 使用 import pika # 建立连接 # user：账号 pwd：密码 userx = pika.PlainCredentials(user, pwd) # hosh：rabbi ......
Kubernetes编程——修改客户端默认支持 Protobuf
修改客户端默认支持 Protobuf 一、在 kubernetes 客户端中修改默认支持 Protobuf 确保你已经安装了kubectl命令行工具，并且版本在1.14.0或更高。 打开~/.kube/config文件，该文件存储了你的Kubernetes集群配置信息。 找到clusters部分，并 ......
RabbitMQ01
# 1. 消息队列MQ ## 1.1. 什么是消息队列 > MQ（Message Queue）消息队列（消息中间件），是基础数据结构中“先进先出”的一种数据 结构。指把要传输的数据（消息）放在队列中，用队列机制来实现消息传递——生产者产生消 息并把消息放入队列，然后由消费者去处理。消费者可以到指定队 ......
centos7 rpm安装rabbitmq
1、在 https://www.rabbitmq.com/which-erlang.html 查看erlang和rabbitmq的版本对应关系 2、在https://packagecloud.io/rabbitmq/erlang?page=1 下载erlang的rpm包 3、在https://git ......
RabbitMQ消息中间件
消息队列在使用过程中，面临着很多实际问题需要思考： 消息从发送，到消费者接收，会经理多个过程： 其中的每一步都可能导致消息丢失，常见的丢失原因包括： 发送时丢失： 生产者发送的消息未送达exchange 消息到达exchange后未到达queue MQ宕机，queue将消息丢失 consumer接收 ......
calcite-avatica数据传输时对日期类型压缩，导致客户端展示数据异常问题排查
一、背景 用户使用如下sql来获取周开始和结束时间，直连presto查询该sql，得到的week_start=2019-12-30，而通过calcite-avatica查询出结果为week_start=2019-12-29. 日期相差一天。 with week_array as ( select s ......
docker compose 配置 mysql 容器启动时创建数据库
要在 Docker Compose 中配置 MySQL 容器，在容器启动时创建数据库，你可以按照以下步骤进行操作： 1. 在你的 Docker Compose 文件中，定义一个 MySQL 服务。确保你已经设置了适当的环境变量，如 `MYSQL_ROOT_PASSWORD` 和 `MYSQL_DAT ......
centos 7 安装RabbitMQ
RabbitMQ是一个开源的遵循 AMQP协议实现的基于 Erlang语言编写，即需要先安装部署Erlang环境再安装RabbitMQ环境。 Linux系统：CentOS7.x （如果是CentOS8.x的话，需要修改下面两个环境版本号中的el7为el8） Erlang： erlang-22.3.4 ......
docker compose部署mysql数据库
## 1. 想要达成的目标 通过docker compose 来部署 mysql，并实现一些列需求 > - 在mysql容器初始化时设置字符类型 > - 设置mysql容器的时区为中国时区 > - 设置mysql root密码，采用.env传入参数 > - 初始化时创建一个数据库 > - 初始化时创 ......
Rabbitmq：消息队列介绍、Rabbitmq安装、 基于Queue实现生产者消费者模型、基本使用（生产者消费者模型）、消息安全之ack、 消息安全之durable持久化、发布订阅闲置消费、
[toc] ### 一、消息队列介绍 #### 1.1介绍 消息队列就是基础数据结构中的“先进先出”的一种数据机构。想一下，生活中买东西，需要排队，先排的人先买消费，就是典型的“先进先出” ![image](https://img2023.cnblogs.com/blog/2970690/20230 ......
rabbitmq在.net中的使用
在 .NET 中使用 RabbitMQ 的步骤如下： 安装 RabbitMQ 首先，您需要在系统上安装 RabbitMQ。您可以从 RabbitMQ 官方网站下载适用于您所使用的操作系统的安装程序。如果您使用的是 Windows 操作系统，则可以从 Microsoft 官网下载安装程序。 安装 Ra ......
Feign客户端的拦截器
import feign.RequestInterceptor; import feign.RequestTemplate; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; impo ......