本月博客排行
年度博客排行
-
第1名
宏天软件 -
第2名
青否云后端云 -
第3名
龙儿筝 - gashero
- wallimn
- vipbooks
- wy_19921005
- benladeng5225
- fantaxy025025
- e_e
- zysnba
- ssydxa219
- sam123456gz
- javashop
- arpenker
- tanling8334
- kaizi1992
- xpenxpen
- xiangjie88
- wiseboyloves
- ranbuijj
- ganxueyun
- sichunli_030
- xyuma
- wangchen.ily
- lemonhandsome
- jh108020
- zxq_2017
- jbosscn
- Xeden
- luxurioust
- zhanjia
- lzyfn123
- forestqqqq
- ajinn
- nychen2000
- wjianwei666
- daizj
- hanbaohong
- 喧嚣求静
- johnsmith9th
- silverend
- mwhgJava
- kingwell.leng
- lchb139128
- kristy_yy
- lich0079
- jveqi
- java-007
- sunj
最新文章列表
Centos离线安装RabbitMQ并开启MQTT
RabbitMQ全离线安装
安装包下载地址
下载链接: http://www.rpmfind.net/linux/rpm2html/search.php?query=epel-release&submit=Search+...&system=&arch=
参考文章: CentOS 7 下 RabbitMQ 3.7 离线安装与配置 常用指令
#rpm依次安装
rabbitmq的终端管理命令rabbitmqadmin
启动rabbitmq
systemctl start rabbitmq-server
可以在启动rabbitmq后,执行这个命令。
rabbitmq-plugins enable rabbitmq_management
界面显示:注意这里会立刻开启一个http服务,自动的,端口默认15672
Enabling plugins on node rabbit@iZbp1hpvk8ectela8z8 ...
centos 安装 RabbitMQ
安装 erlang语言环境。
千万不要直接 yum install erlang,那样版本太老,且修复麻烦。
cd
wget https://packages.erlang-solutions.com/erlang-solutions-2.0-1.noarch.rpm
rpm -Uvh erlang-solutions-2.0-1.noarch.rpm
yum -y install erlang ...
深度剖析 Kafka/RocketMQ 顺序消息的一些坑
我不记得有多少人问过以下这个问题了:
我觉得这个问题问得很频繁,而且非常经典,在这里我就以 Kafka 为例子,说说我对 Kafka 顺序消息的一些理解吧,如有理解不对的地方麻烦留言指点一下。
通常我们在说顺序消费指的是生产者按照顺序发送,消费者按照顺序进行消费,听起来简单,但做起来却非常困难。
我们都知道无论是 Kafka 还是 RocketMQ,每个主题下面都有若干分区(Rocket ...
基于SpringBoot自定义Rabbitmq配置来发布订阅消息
代码库
https://gitee.com/liyghting/springrabbitmqdemo
原理
基于spring启动的时候加载发布订阅配置,发送基于json的消息。
step1:实现Spring接口
step2:生产者配置信息Spring的Bean生成
step3:消费者配置信息初始化和建立监听
具体代码请看RabbitmqConfig.java
发布消息 ...
rabbitmq 的三种模式fanout topic direct
1.需要在rabbitmq 管理界面上,定义用户和 Virtual host
登录地址:http://localhost:15672/
用户名为:gjpztb;密码:gjpztb; Virtual host
实现代码在附件中
2.建立maven 项目:
<beans xmlns="http://www.springframework.org/schema/beans" ...
RabbitMQ如何实现高可用
RabbitMQ一共具有三种模式:单机、普通集群、镜像集群
单机模式
单机模式,就是我们平常玩的demo,生产上肯定不能用。具体安装部署过程可以参考我的这篇文章:CentsOS原生RabbitMQ安装过程
普通集群
普通集群就是在多台机器上启动多个实例。每个队列只会存在其中的一个实例上,然后所有实例同步这些队列的元数据。消费者在进行消费的时候,如果连接的实例上恰好不是队列所在的实例,就会根据队列的元 ...
RabbitMQ高级面试题
本文涉及:投递失败的消息怎么处理、如何实现延时队列、如何指定消息的优先级、消息的持久化是如何实现的、如何保证消息不丢失
投递失败的消息怎么处理
首先投递失败存在如下两个情况
当交换器无法根据自身的类型和路由键找到符合条件的队列
如果交换器在将消息路由到队列时发现队列上并不存在任何消费者
解决方案:
在生产者投递消息时指定mandatory或者imrnediate参数设为 true 时,Rabb ...
RabbitMQ集群安装
首先参考上一篇文章【CentsOS原生RabbitMQ安装过程】在两到三台机器上先安装单独的RabbitMQ节点
修改一下hostname
1
2
3
4
[root@rnode1 ~]# vim /etc/hosts
172.16.20.110 rnode1
172.16.20.111 rnode2
172.16.20.112 rnode3
erl ...
CentsOS原生RabbitMQ安装过程
版本依赖问题
RabbitMQ安装时与Erlang的版本一定要保持以下的对应关系,否则会引发无法启动的问题
安装Erlang
下载Erlang依赖
1
wget http://erlang.org/download/otp_src_20.3.tar.gz
解压后进入资源文件夹
1
tar xvf otp_src_20.3.tar.gz
...
RabbitMQ实战篇(一)--虚拟机上RabbitMQ的安装及使用
我们都知道,RabbitMQ 是目前非常热门的一款消息中间件,不管是互联网行业还是传统行业都在大量地使用。那么什么是消息?什么是消息中间件?这些专有名词都必须有了解。
一、消息中间件概述
1、消息 (Message) 是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串、JSON 等,也可以很复杂,比如内嵌对象。
2、消息中间件,全称叫消息队列中间件 (Message Qu ...
RabbitMQ的一些理解和笔记
在这篇博客中,简单记录一下 rabbitmq 服务器中一些基本的概念。
Connection: connection 为 TCP连接,是我们的应用程序和RabbitMQ服务器真正发送和接收数据的地方。
Channel: channel为connection创建的“信道”,具体的AMQP命令都是通过信道发送出去的。每一条信道都有一个唯一的id,channel是线程不安全的。
b ...
springboot 整合 rabbitmq
这篇文章,我们使用springboot来简单整合一下RabbitMQ,由于sprinboot的 “约定优于配置“,使得我们整合起来非常方便。参考文档
实现功能:
自动申明队列、交换器和绑定
使用自定义的MessageConvert如何进行配置
如何传递 JavaBean 消息和普通消息
如何手动签收消息
实现要点:
** 自定申明队列、交换器和绑定
...
spring整合rabbitmq
本文简单记录一下 spring 整合 rabbitmq,此处引入spring boot是为了方便引入和rabbitmq整合相关的jar包,并没有使用spring boot整合 rabbitmq。
实现功能
完成 spring 和 rabbitmq 的整合
完成使用 rabbitAdmin 创建队列等
完成使用 @Bean 注解声明队列等
完成使用 RabbitTempla ...