集群rabbitmq
rabbitMQ死信队列和延迟交换机
一、死信队列（deadLetters） 1.死信产生的三种方式 （1）消息被消费者拒绝，requeue设置为false message在正常传输中消费者执行了nack或者reject且requeue变为false则将该message存储到死信交换机，再送入死信队列，重新被其他的消费者消费 （2）消息 ......
rabbitMQ消息可靠性
rabbitMQ消息可靠性 rabbitMQ交换机不负责消息持久化 消息存储到队列中才可以手动开启持久化 生产者端： 如何保证消息一定可以送达Exchange 消费者端： 自动ACK 手动ACK RabbitMQ保证消息可靠性： 1.保证消息一定可以送达Exchange confirm机制 可以通过 ......
rabbitMQ安装
rabbitMQ安装 安装依赖 yum -y install gcc gcc-c++ ncurses-devel openssl-devel unixODBC-devel perl vim 安装Erlang tar -xvf otp_src_26.0-rc1.tar.gz cd otp_src_26 ......
Ansible-playbook三分钟部署一个zookeeper集群
Ansible-playbook三分钟部署一个zookeeper集群 原创 Redhatlh IT运维图谱 2023-07-05 20:39 发表于陕西 收录于合集 #ansible2个 #自动化2个 不要说话音乐：陈奕迅 - 不想放手 相信大家在从事运维工作当中，都会使用到zookeeper中间件 ......
rabbitmq 修改端口
在C:\Users\Administrator\AppData\Roaming\RabbitMQ 新建rabbitmq.config 修改为：45672 [ { rabbit, [ { tcp_listeners, [ {"0.0.0.0" ,45672}] }] },{ rabbitmq_mana ......
Redis 高可用 —— 集群
参考： 码哥字节：https://xie.infoq.cn/article/c556cac5450ca3d874621edde Knight_AL: https://blog.csdn.net/qq_46548855/article/details/128944720 云三木：https://blo ......
virtual box 部署 k8s 集群
1. 安装 virtual box 版本：VirtualBox-6.1.42 2. 创建虚拟机，安装 centos7 新建虚拟机： 选择网络 安装 centos7 操作系统： 安装过程中配置网络 centos 安装完成后，需要修改 host-only 的网络参数 cd /etc/sysconfig/ ......
java判断postgres数据库集群的master节点
1.引入依赖 <!--postgresql--> <dependency> <groupId>org.postgresql</groupId> <artifactId>postgresql</artifactId> <version>42.2.2</version> </dependency> 2. ......
docker-compose安装ES集群以及kibanna并配置账号密码
# 一、安装不带密码的es集群 ## 1.1 目录结构 ~~~ -root -compose -elasticsearch -docker-compse.yml -es_data -es01 -data -logs -config -elasticsearch.yml -es02 -data -lo ......
rabbitmq php 代码示例
交换机类型 direct : 直连交换机, 根据路由键投递到与绑定键匹配的队列。fanout : 扇形交换机，采用广播模式，投递到所有与之绑定的队列。topic : 主题交换机，对路由键与绑定键进行模式匹配后再投递到相应的队列。headers : 头交换机，不处理路由键, 而是根据发送的消息内容中的 ......
k8s集群卸载
# k8s集群卸载 ```shell # 重置 kubeadm kubeadm reset rm -rf $HOME/kube rm -rf /etc/kubernetes/ rm -rf /etc/systemd/system/kubelet.service.d rm -rf /etc/syste ......
Scala连接Hbase集群出现异常tried to access method com.google.common.base.Stopwatch.<init>()V from class org.apache.hadoop.hbase.zookeeper.MetaTableLocator
总结/朱季谦 在新项目上创建以下Scala代码去连接Hbase集群，用来判断Hbase是否存在某张表。 ``` //离线Hbase val conf: Configuration = HBaseConfiguration.create() conf.set("hbase.zookeeper.quor ......
Jenkins远程管理K8S集群实现自动POD部署
# Jenkins远程管理K8S集群实现自动POD部署 大致思路 1. 修改.kube/config 文件，增加新集群的context 2. 建立隧道将集群控制端口映射到Jenkins服务器本地端口 3. 测试jenkin 切换到新context 是否能控制该集群 4. 新集群配置对接Harbor仓 ......
k8s集群node NotReady处理流程-->kubelet状态error，并伴有报错：kubelet.service has more than one ExecStart=setting,which is only allowed for Type=oneshot services.Refusing
## k8s集群node NotReady处理流程-->kubelet状态error > //20230712 集群有节点NotReady kubelet状态error，并伴有报错：```kubelet.service has more than one ExecStart=setting,whic ......
安装Hadoop单节点伪分布式集群
[toc] # 安装Hadoop单节点伪分布式集群 操作系统：Ubuntu server 20.04 参考文档：`http://apache.github.io/hadoop/hadoop-project-dist/hadoop-common/SingleCluster.html` ## 系统准备 ......
搭建pg-ha集群
[1] https://wiki.postgresql.org/wiki/Binary_Replication_Tutorial#5_Minutes_to_Simple_Replication [2] https://wiki.postgresql.org/wiki/Hot_Standby [3] ......
【后端面经-架构】RabbitMQ简介
[TOC](【后端面经-架构】RabbitMQ简介) ## 1. MQ介绍 MQ（Message Queue）用于在应用程序之间相互通信，在消息中发送数据进行通信，而不需要特意建立连接传输数据。 与之对应的另一种通信方式是远程直接调用（RPC），需要先建立通信连接然后传递数据。 ## 2. Rabb ......
Centos7 升级 Kubernetes(k8s) 集群
Centos7 升级 Kubernetes(k8s) 集群，升级master主节点，升级kubeadm，升级各个组件，升级 kubelet 和 kubectl，升级worker工作节点，升级kubeadm，升级kubelet和kubectl ......
docker 安装redis 6.0.8哨兵集群（一主两从三哨兵）
#### 准备三台主机并且安装了docker ``` 192.168.31.132 192.168.31.134 192.168.31.144 ``` #### linux 版redis6.0.8 下载 ``` 下载地址：https://download.redis.io/releases/ ``` ......
高可用k8s集群
基于kubeasz部署高可用k8s集群 在部署高可用k8s之前，我们先来说一说单master架构和多master架构，以及多master架构中各组件工作逻辑 k8s单master架构 提示：这种单master节点的架构，通常只用于测试环境，生产环境绝对不允许；这是因为k8s集群master的节点是单 ......
rabbitmq的消息持久化和消费者ack确认
消息持久化 队列持久化 交换机持久化 ExchangeBuilder.directExchange("normalExchange").build(); 1 消费者ack确认 multiple：批量 比如批量确认： 当multiple的值设置为true时，RabbitMQ将确认指定传输标签以及之前所 ......
搭建高可用集群
## 1. 关于 OpenSSL https://www.yundongfang.com/Yun224517.html https://blog.csdn.net/qq120631157/article/details/130464937 ......
RabbitMQ简介
简介 消息队列提供一个异步通信机制，消息的发送者不必一直等待消息被成功处理才返回，而是立即返回。消息中间件负责处理网络通信，如果网络连接不可用，消息被缓存到队列中;当网络畅通时，消息将转发给相应的应用程序或服务。前提是这些服务或程序订阅了该消息。 RabbitMQ是使用Erlang语言（在数据交互方 ......
07-Nginx搭建高可用集群
- [1. Keepalived+Nginx 高可用集群（主从模式）](#1-keepalivednginx-高可用集群主从模式) - [2. 配置高可用的准备工作](#2-配置高可用的准备工作) - [3. 在两台服务器上安装keepalived](#3-在两台服务器上安装keepalived) ......
RocketMQ和RabbitMQ的区别
一、概述 消息队列已经逐渐成为企业IT系统内部通信的核心手段，主要用来提升性能、系统解耦、流量消峰。 它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里 ......
Pulsar集群: instanceId xxx is not match with xxx
### Pulsar集群: instanceId xxx is not match with xxx  ##### 1.问题原因 pulsar本地存储的instanceId与zookeeper不一致导致，即使 ......
Hadoop中YARN集群启停命令
一键启停脚本 # 一键启动yarn集群 start-yarn.sh # 一键关闭yarn集群 stop-yarn.sh 单进程启停 start和stop决定启动和停止可控制resourcemanager、nodemanager、proxyserver三种进程 yarn --daemon start| ......
Kafka 集群
[TOC] # Kafka 和 ZooKeeper Kafka 使用 Zookeeper 来维护集群成员的信息。每个 Broker 都有一个唯一标识符，这个标识符可以在配置文件里指定，也可以自动生成。 在 Broker 启动的时候，它通过创建 **临时节点** 把自己的 ID 注册到 Zookeep ......
RabbitMQ基础及实践
一、RabbitMQ的基本概念，以及6种工作模式，消息确认机制 RabbitMQ 简介：RabbitMQ 基于 AMQP 标准，采用 Erlang 语言开发的消息中间件。 基本概念：●Producer：作为消息的生成者。●Consumer：作为消息的消费者。●Connection：消息的发布方或者消 ......
我用ChatGPT，给RabbitMQ加了个连接池
上次我把 RabbitMQ 集成到项目中，但是每次使用 RabbitMQ 时都去 New 一个连接，导致并发起不来，所以这次我们就给 RabbitMQ 加一个连接池。 为了偷个懒，我直接用 ChatGPT 教我加。 01 ChatGPT 生成的代码 我输入的关键字如下： rabbitmq 实现一个连 ......