消息队列RabbitMQ版 网络异常自动恢复
首页>消息队列RabbitMQ版>最佳实践>网络异常自动恢复 网络异常自动恢复 由于服务端升级、服务端重启、网络抖动等原因，服务端和客户端的网络连接可能会断开。本文介绍如何在客户端设置Connection和Topology自动恢复，使Connection和Topology在网络连接断开后自动恢复，避免断连对您的业务造成影响。 触发原因 触发Connection自动恢复的原因如下： Connection的I/O抛出异常。 Socket读取操作超时。 检测到服务端心跳丢失。 恢复方法 注意 4.0.0及以上版本Java客户端默认开启Connecti...
RabbitMQ的工作原理及安装
一、docker安装： docker run -d --name rabbitmq3.7.7 -p 5672:5672 -p 15672:15672 -v `pwd`/data:/var/lib/rabbitmq --hostname myRabbit -e RABBITMQ_DEFAULT_VHOST=my_vhost -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin 说明： -d 后台运行容器； --name 指定容器名； -p 指定服务运行的端口（5672：应用访问端口；15672：控制台Web端口号）； -v 映射目录或文件； --hostname 主机名（RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据，默认为主机名）； -e 指定环境变...
CentOS在线安装RabbitMQ3.7
一、通过yum命令在线安装RabbitMQ yum在线安装，简单、快捷、自动安装相关依赖包。 1.安装Erlang环境（RabbitMQ由Erlang语言开发） 1.1）下载rpm安装包 官方地址：http://www.erlang.org/downloads wget -O erlang-20.3.4-1.el7.centos.x86_64.rpm https://bintray.com/rabbitmq/rpm/download_file?file_path=erlang%2F20%2Fel%2F7%2Fx86_64%2Ferlang-20.3.4-1.el7.centos.x86_64.rpm 1.2）安装Erlang yum install -y erlang-20.3.4-1.el7.centos.x86_64.rpm 1.3）检查Erlang是否安装成...
使用stomp连接RabbitMQ
1.安装rabbitmq 2.开启stomp插件 rabbitmq-plugins enable rabbitmq_web_stomp 3.成功后重启RabbitMQ 4.WEB代码 <!DOCTYPE HTML> <html> <head> <title>MyWebSocket</title> </head> <body> Welcome<br/> <input id="text" type="text"/> <div id="message"> </div> </body> <script src="https://cdn.bootcss.com/stomp.js/2.3.3/stomp.js"></script> <script src="https://cdn.bootcss.com/sockjs-client/1.1.4/...
ActiveMQ资料大全
官方文档 入门：http://activemq.apache.org/getting-started.html 常见问题：http://activemq.apache.org/faq.html 各种功能特性详解：http://activemq.apache.org/features.html 连通性相关文档：http://activemq.apache.org/connectivity.html 相关的各种工具：http://activemq.apache.org/tools.html 开发者文档：http://activemq.apache.org/developers.html 设计文档：http://activemq.apache.org/design-documents.html 经验与技术文章 各路神仙关于ActiveMQ的技术文章：http://activemq.apache.org/articl...
ActiveMQ的消息持久化
当 MQTT客户端订阅者同时满足如下条件时，会变成持久订阅者，此时可以为MQTT订阅者持久化消息到数据库或文件存储： 1. cleanSession为false 2. clientId不为空
C#调用安全验证下的ActiveMQ REST管理接口
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.Net; using System.IO; namespace WindowsFormsApplication1 { public partial class Form1 : Form { public Form1() { InitializeComponent(); } private void button1_Click(object sender, EventArgs e) { String url = textBox2.Text; ...
ActiveMQ REST Management API
ActiveMQ的管理接口是基于JMX的（参见 JMX操作ActiveMQ(1)、JMX操作ActiveMQ(2)），通过管理接口我们可以与Broker交互，查询各种Broker状态、统计数据，浏览连接、消费者、生产者，以及管理消息。 虽然ActiveMQ通过CMS（支持c++）、NMS（支持.net）以及多种protocol（STOMP、MQTT、AMQP等）支持了多种平台环境下的消息发送接收，但是由于JMX是Java专有的技术，导致ActiveMQ JMX管理接口一直不能使用在其他环境。 从ActiveMQ5.8.0起，引入了jolokia库，使得JMX接口可以直接转换成REST接口，JMX管理接口就成了现在的...