集群rabbitmq
容器化部署RocketMQ4.9.4集群
## 容器化部署RocketMQ4.9.4集群 - 背景： 生产环境单机的MQ不具有高可用，所以我们应该部署成集群模式，这里给大家部署一个**双主双从异步复制的Broker集群** ### 一、安装docker ```sh yum install -y docker systemctl enable ......
【Websocket】SpringBoot整合Websocket集群实现服务端推送(一)
一.背景 最近项目中有需要使用到Websocket做长连接推送，这里整理在具体实现过程中的细节和踩过的坑 二.问题点 在实现过程中，这里自己整理了一些问题点 1.WebsocketSession无法序列化到Redis以及MySQL中,集群环境下，如果进行服务端推送到指定客户端，如何知道该客户端与后台 ......
RabbitMQ消息中间件
消息队列在使用过程中，面临着很多实际问题需要思考： 消息从发送，到消费者接收，会经理多个过程： 其中的每一步都可能导致消息丢失，常见的丢失原因包括： 发送时丢失： 生产者发送的消息未送达exchange 消息到达exchange后未到达queue MQ宕机，queue将消息丢失 consumer接收 ......
promethues + grafana 监测ceph集群状态
##### 前 最近在使用海量小文件压测ceph集群，想着搭建一个可视化的界面来监测集群状态，由于很久之前使用过promethues + grafana 监测k8s集群状态，用来监测 ceph 集群应该问题不大，那么就开始吧！ 首先了解下 promethues 和 grafana 是什么？ prom ......
使用kubeadm快速部署一个K8s集群
kubeadm是官方社区推出的一个用于快速部署kubernetes集群的工具。 这个工具能通过两条指令完成一个kubernetes集群的部署： ``` # 创建一个 Master 节点 $ kubeadm init # 将一个 Node 节点加入到当前集群中 $ kubeadm join ``` # ......
minio对象存储四台服务器部署4个节点集群
# 环境说明 **·** 分布式Minio至少需要4个节点 **·** 如果资源不够，可以采用两个节点每个节点启动两个实例的方式来实现四节点的集群，仅用于测试环境 **·** 生产环境建议最少4节点 # 环境准备 ``` #所有节点执行下列操作 # 配置时间同步，配置时间同步的方式不做讲述 # 创建 ......
Redis集群环境下keys被禁用，该怎么实现keys?
> 在生产环境中，禁用Redis的keys命令是为了避免对Redis实例的性能造成负面影响。keys命令会遍历整个 Redis数据库，查找与给定模式匹配的所有键，这在大规模的Redis数据库中可能会非常耗时; 那么，在keys禁用的情况下，仍然需要使用keys该怎么办呢？我们搜索一些处理方案大多是建 ......
centos 7 安装RabbitMQ
RabbitMQ是一个开源的遵循 AMQP协议实现的基于 Erlang语言编写，即需要先安装部署Erlang环境再安装RabbitMQ环境。 Linux系统：CentOS7.x （如果是CentOS8.x的话，需要修改下面两个环境版本号中的el7为el8） Erlang： erlang-22.3.4 ......
Hive3.1.3集群安装
一、安装mysql Hive默认的Derby数据库一次只能打开一个会话，不支持多用户并发访问，需要替换Hive的存储引擎为mysql 1. 下载mysql安装包 wget http://dev.mysql.com/get/mysql57-community-release-el7-7.noarch. ......
006.hdfs-查看各节点磁盘使用情况,集群平衡
查看各节点磁盘使用情况 hdfs dfsadmin -report | grep -E "Name:|DFS Used%:" 集群平衡 mv balance.sh /home/hdfs/ su hdfs vim balance.sh chmod +x balance.sh ls hdfs dfsad ......
Rabbitmq：消息队列介绍、Rabbitmq安装、 基于Queue实现生产者消费者模型、基本使用（生产者消费者模型）、消息安全之ack、 消息安全之durable持久化、发布订阅闲置消费、
[toc] ### 一、消息队列介绍 #### 1.1介绍 消息队列就是基础数据结构中的“先进先出”的一种数据机构。想一下，生活中买东西，需要排队，先排的人先买消费，就是典型的“先进先出” ![image](https://img2023.cnblogs.com/blog/2970690/20230 ......
CentOS7 部署 k8s 集群
CentOS7 部署 k8s 集群 BUG弄潮儿 2023-06-10 20:32 发表于广东 BUG弄潮儿 多年开发经验，专注软件开发、架构；推送 微服务，分布式，Spring全家桶，Redis，Linux，Nginx等技术，欢迎一起学习、探讨。 396篇原创内容 公众号 K8s+Istio+Go ......
rabbitmq在.net中的使用
在 .NET 中使用 RabbitMQ 的步骤如下： 安装 RabbitMQ 首先，您需要在系统上安装 RabbitMQ。您可以从 RabbitMQ 官方网站下载适用于您所使用的操作系统的安装程序。如果您使用的是 Windows 操作系统，则可以从 Microsoft 官网下载安装程序。 安装 Ra ......
何时使用Kafka而不是RabbitMQ
Kafka 和 RabbitMQ 都是流行的开源消息系统，它们可以在分布式系统中实现数据的可靠传输和处理。Kafka 和 RabbitMQ 有各自的优势和特点，它们适用于不同的场景和需求。本文将比较 Kafka 和 RabbitMQ 的主要区别，并分析何时使用 Kafka 而不是 RabbitMQ。 ......
zookeeper集群启停脚本
方式一 #!/bin/bash #zookeeper集群启停脚本 ip="master slave1 slave2 slave3 slave4" #IP地址或域名都可以 zk-home="/home/zookeeper/zookeeper-3.4.14" case $1 in "start"){ f ......
重新初始化k8s集群
##### 执行如下命令，所有节点都执行 ```shell kubeadm reset ``` ##### 初始化集群，仅在master(centos01)上执行 ```shell [root@centos01 opt]# kubeadm init --apiserver-advertise-add ......
Redis分片集群-故障转移
为了演示故障转移，我们可以先通过watch命令查看某台节点信息监控整个集群状态： watch redis-cli -p 9001 cluster nodes 接着我们让某台节点宕机，执行命令：redis-cli -p 9002 shutdown，回车。 可以发现控制台监控到9002已失去连接。等待一 ......
Redis分片集群-集群伸缩
redis-cli --cluster提供了很多操作集群的命令，可以通过下面方式查看： redis-cli --cluster help执行如下： 比如，添加节点的命令： new_host代表需要添加的节点ip， exitsting_host代表已经存在的主机IP，也即集群中已经有的，为什么需要知道 ......
Kubernetes编程——查询集群提供哪些API资源
查询集群提供哪些API资源 [root@JumperServer:~] # kubectl api-resources NAME SHORTNAMES APIVERSION NAMESPACED KIND bindings v1 true Binding componentstatuses cs v ......
行行AI人才直播第3期：浙江大学周鑫博士《空中机器人复杂环境高效自主导航—从单机到集群》
空中飞行的无人车、无人机集群是科幻电影的常客，也往往是未来科技的一大代表。在电影《星球大战：西斯的复仇》（2005）和《银翼杀手2049》（2017）中，飞车构成的密集空中交通有条不紊的运行于高楼大厦之间，俨然是高科技星球的“标配”。电影中的集群所展现出的导航和协同能力数十年来吸引了无数的研究者。 ......
RabbitMQ
一、 MQ （MessageQueue）：消息队列，字面来看就是存放消息的队列。也就是事件驱动架构中的Broker。 RabbitMQ是基于Erlang语言开发的开源消息通信中间件。 二、 安装RabbitMQ 拉取RabbitMQ镜像：docker pull rabbitmq:3-manageme ......
SpringCloud使用RabbitMQ 实现微服务之间的异步调用
最近公司内部员工为了完成小程序分裂考核任务，使用黑客软件发起大量请求刷任务，导致后台小程序模块A的微服务卡死， 微服务B调用了微服务A的微信消息推送功能，其他微服务又调用微服务B...... 由于微服务A卡死，服务调用链产生阻塞，新的请求不断来到，阻塞的线程越来越多，最终因服务器资源耗尽而导致整个系 ......
kafka集群搭建
https://blog.csdn.net/wudidahuanggua/article/details/127086186 1 安装准备 请确保zookeeper集群的正常启动 可参考：大数据学前准备--zookeeper详解与集群搭建（保姆级教程） 2 下载kafka Apache Kafka ......
Keepalived+Nginx 高可用集群架构
Keepalived+Nginx 高可用集群（主从模式） 一、两台群集服务器都需要安装nginx和keepalived，先添加nginx yum 源 vim /etc/yum.repos.d/nginx.repo [nginx-stable] name=nginx stable repo baseu ......
python操作rabbitmq
rabbitmq安装部署 RabbitMq生产者消费者模型 生产者（producter） 队列消息的产生者，复制生产消息，并将消息传入队列生产者代码： import pika import json credentials = pika.PlainCredentials('admin','admin ......
rabbitmq安装部署和常用命令
python操作rabbitmq rabbitmq实现可以使用java或者springboot的封装方法，自己创建实现，也可以使用中间件实现，相对于自建，使用rabbitmq应用场景及使用更系统安全。本文具体介绍rabbitmq中间件部署。 消息队列中间件是分布式系统中重要的组件，主要解决应用耦合， ......
MGR集群命令
MGR集群命令 https://www.modb.pro/db/538741 官方文档： #### 一. 基本命令 ##### 1.检查集群状态，或者叫组复制状态 ``` select * from performance_schema.replication_group_members; ``` ......
ElasticSearch-03-集群核心概念（Windows集群）
Windows集群安装(es版本7.10.1) # 1.安装 1，解压elasticsearch-7.10.1-windows-x86_64.zip，复制出3个文件夹，重命名为node01、node02、node03 ![](https://img2023.cnblogs.com/blog/7024 ......
使用PhpAmqpLib常用的2种连接rabbitmq的方式
#connect to AMQP broker at example.comuse PhpAmqpLib\Connection\AMQPStreamConnection;$amqp = new AMQPStreamConnection('example.com', 5672, 'user', 'pw ......
Hadoop中HDFS集群启停命令
一键启停脚本 # 一键启动hdfs集群 start-dfs.sh # 一键关闭hdfs集群 stop-dfs.sh 单进程启停 $HADOOP_HOME/sbin/hadoop-daemon.sh，此脚本可以单独控制所在机器的进程的启停 用法: hadoop-daemon.sh (start|sta ......