集群rocketmq进程 多个
SpringBoot集成RocketMQ
添加pom.xml依赖 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.2.3</version> </depen ......
RocketMQ之事务消息
一、概述 Apache RocketMQ在4.3.0版中已经支持分布式事务消息，通过消息的异步事务，可以保证本地事务和消息发送同时执行成功或失败，从而保证了数据的最终一致性。 二、案例 根据官方提供的例子，TransactionProducer.java如下： public class Transa ......
RocketMQ之管理与监控
前言 首先提出我们的监控诉求，出现如下情况时，希望能够及时接收到系统告警通知： RocketMQ服务宕机 RocketMQ消费者下线 RocketMQ消息出现长时间或者大量堆积 本文将通过修改rocketmq-console源码的方式，增加RocketMQ消费者下线和RocketMQ消息出现长时间或 ......
RocketMQ之消息发送源码分析
一、概述 负责生产消息，一般由业务系统负责生产消息。一个消息生产者会把业务应用系统里产生的消息发送到broker服务器。 RocketMQ支持三种消息发送方式： 同步消息发送(sync)：当Producer发送消息到Broker时会同步等待消息处理结果； 异步消息发送(async)：当Produce ......
RocketMQ之消息接收源码分析
一、概述 对于任何一款消息中间件而言，消费者客户端一般有两种方式从消息中间件获取消息并消费： Push方式：由消息中间件(MQ消息服务器代理)主动地将消息推送给消费者；采用Push方式，可以尽可能实时地将消息发送给消费者进行消费。但是，在消费者的处理消息的能力较弱的时候(比如，消费者端的业务系统处理 ......
RocketMQ之水平扩展及负载均衡
前言 RocketMQ是一个分布式具有高度可扩展性的消息中间件。本文旨在探索在broker端，生产端，以及消费端是如何做到横向扩展以及负载均衡的。 NameServer集群 提供轻量级的服务发现和路由。每个NameServer 记录完整的路由信息，提供等效的读写服务，并支持快速存储扩展。 就是一个注 ......
批量清理多个没有远程对应分支的本地分支
如果您需要批量清理多个没有远程对应分支的本地分支，可以使用以下命令： git fetch --prune && git branch -vv | grep ': gone]' | awk '{print $1}' | xargs git branch -D 这个命令用于清理本地已经不存在的远程分支。 ......
RocketMQ单机版安装
1、下载最新的安装包 github下载地址：https://github.com/apache/rocketmq/releases。本文安装版本为：rocketmq-all-5.1.0-bin-release.zip 2、安装JDK 3、上传并解压安装包 # 从本地电脑上传安装包到Linux服务器 ......
python中判断多个元素是否在列表中
判断单个元素是否在列表中时可以通过in >>> 'a' in ['a', 'b', 'c'] True 但如果是多个元素，就不能通过in进行判断 此时我们可以通过集合中的issubset和issuperset方法 顾名思义，issubset是判断某集合是否是另外一个集合的子集，issuperset是 ......
《asyncio 系列》6. 在 asyncio 中引入多进程
楔子 到目前为止我们使用 asyncio 获得的性能提升，一直专注在并发运行 IO 密集型工作上面，当然运行 IO 密集型工作是 asyncio 的主要工作，并且按照目前编写代码的方式，需要注意不要在协程中运行任何的 CPU 密集型代码。但这似乎严重限制了 asyncio 的使用，因为这个库能做的事 ......
[Hadoop] 在集群中安装Hadoop
[Hadoop] 在集群中安装Hadoop 类似的教程其实有很多，网上随便一搜就是一大把。这里简单的记录一下本人的安装过程，留给本人或者后人参考。 集群配置 内网互联的三台机器，IP分别为10.0.0.1,10.0.0.2,10.0.0.3。 我们的目标配置是让10.0.0.1做主节点，也就是mas ......
Linux 搭建redis集群（哨兵模式）
环境： 192.168.56.101 192.168.56.102 192.168.56.103 1、在三台服务器上都安装redis 安装步骤：https://www.cnblogs.com/leihongnu/p/14734603.html 2、配置主从 192.168.556.101：配置文件r ......
一统天下 flutter - widget 自定义: 通过组合多个 Widget 的方式实现自定义组件
源码 https://github.com/webabcd/flutter_demo 作者 webabcd 一统天下 flutter - widget 自定义: 通过组合多个 Widget 的方式实现自定义组件 示例如下: lib\widget\custom\custom_widget.dart / ......
C# 在管理员权限的进程里降权启动一个权限为普通权限的进程
在管理员权限的进程里降权启动一个权限为普通权限的进程，在根据网上的说法尝试了很多方式，要么不成功降权，要么需要账户名+密码。 最终在 https://blog.csdn.net/WPwalter/article/details/88384279#_explorerexe__50 博客中找到一个比较简 ......
RocketMQ之消息轨迹
一、概述 消息轨迹是用来跟踪记录消息发送、消息消费的轨迹。 如何启用消息轨迹？ broker端 需要在broker端的配置文件中添加配置项：traceTopicEnable=true，注意：对于消息轨迹数据量较大的场景，可以在RocketMQ集群中选择其中一个Broker节点专用于存储消息轨迹，使得 ......
RocketMQ之通信机制
一、概述 RocketMQ消息队列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4个角色，基本通讯流程如下： Broker启动后需要完成一次将自己注册至NameServer的操作；随后每隔30s时间定时向NameServer上报Topi ......
RocketMQ之重试机制
一、概述 Producer对发送失败的消息进行重新发送的机制，称为消息发送重试机制，也称为消息重投机制。 对于消息重投，需要注意以下几点： 生产者在发送消息时，若采用同步或异步发送方式，发送失败会重试，但oneway消息发送方式发送失败是没有重试机制的; 只有普通消息具有发送重试机制，顺序消息是没有 ......
Nginx 多个域名解析到同一个服务器
域名证书绑定参照：nginx 发布网站通过域名访问，后端接口反向代理 - AutumnSilence - 博客园 (cnblogs.com) 1、域名解析到服务器上 2、修改nginx 配置文件 定义两个 server，监听443端口， 修改server_name 绑定的值 server { lis ......
hadoop 3.3.5伪分布式集群部署
hadoop包下载 https://archive.apache.org/dist/hadoop/common/ 安装好jdk并配置环境变量 下载hadoop压缩包并放至 /data/hadoop目录 解压 tar -zxvf hadoop-3.3.5.tar.gz 1配置 1.1在Hadoop安装 ......
创建异步进程
笔记软件在2023/5/6 11:24:49推送该笔记 参考文档 [child_process.spawn()] [child_process.fork()] [child_process.exec()] [child_process.execFile()] ......
RocketMQ Helm模板增加ACL认证
RocketMQ版本：4.9.2 具体请按实际场景进行修改 修改rocketmq/templates/broker/configmap.yaml data: broker-base.conf: | brokerClusterName = {{ .Values.clusterName }} aclEn ......
RocketMQ开启ACL认证Go连接测试
RocketMQ开启ACL认证连接测试 导入包 go get -u github.com/apache/rocketmq-client-go/v2 go get -u github.com/spf13/pflag 查看go.mod module your_module_name go 1.16 re ......
windows守护进程工具--nssm使用
一、nssm简介 nssm是一个服务封装程序，它可以将普通exe程序封装成服务，实现开机自启动，同类型的工具还有微软自己的srvany，不过nssm更加简单易用，并且功能强大。 它的特点如下： 支持普通exe程序（控制台程序或者带界面的Windows程序都可以）安装简单，修改方便可以自动守护封装了的 ......
32位进程设置大地址(3G)空间
对应32位应用，我们不做任何设置，我们能用的地址空间其实不足2G，有两种方式设置大地址空间： 一、设置链接选项 二、工具editbin 1.开启方法 (1)利用管理员身份运行”Visual Studio 工具命令提示”程序; (2)输入命令：editbin /LARGEADDRESSAWARE D: ......
tar 压缩模糊匹配的多个目录
for dirname in 2022*; do dirlist=$dirlist' '$dirname; done tar -zcvf 2022.tar.gz $dirlist 1、for循环获取每一个模糊匹配的目录名，通过空格将每个目录名称串接起来 2、使用tar压缩命令，将得到的串接目录名作为 ......
WireShark抓包工具抓取查看指定的软件进程网络包的方法
一、查询应用的端口 1、打开【任务管理器】，点击【查看】—>【选择列】，选中【PID（进程标识符）】 2、记录想要查询端口号的PID，比如： 打开【运行】—>输入【cmd】，打开【命令处理器】 输入【netstat -ano|findstr 6600】 52330和52331即为IExplorer的 ......
rocketmq启动nameserver的坑
当你启动rocketmq时可以启动但找不到日志时： 第一：减小JVM的内存 其次：要到bin目录中输入启动命令。 楼主就是第二步解决的 ......
使用kubeadm快速部署k8s集群
使用kubeadm快速部署k8s集群 一、环境准备 操作系统 CentOS7.x-86_x64 硬盘：40G+ | 角色 | IP | | | | | master | 192.168.130.10 | | node | 192.168.130.20 | 二、kubeadm工具介绍 kubeadm是 ......