1.安装MQTT
请参考《CentOs6.8下MQTT简介及搭建》进行安装,在此不再说明。
2.环境介绍
192.168.20.38 主节点
192.168.20.52 从节点
192.168.20.111 从节点
3.集群目的
无论在那台服务器中订阅了信息,无论在那台服务器上发布信息,订阅者都可以收到发布的信息。集群部署有一个
专有名词叫做“桥接”,实现桥接的方式需要修改config.mk与mosquitto.conf文件。值得说明的是如果有10台服务器做
mosquitto集群,每台服务器上将桥连接打开,然后只需要更改一台服务器上的mosquitto.conf文件即可,其他服务器
的mosquitto.conf文件不需要做任何改动。大大方便了集群的维护。如果有新的服务器加入或删除只需要修改主服务器
的mosquitto.conf即可。
4.开启服务器桥连接
分别在三台服务器上执行如下命令:
cd /home/mosquitto-1.4.14
vi config.mk
找到WITH_BRIDGE:=yes 将签名的“#”号去掉开启桥连接模式。(默认是开启的,为了无误查看一下)
WITH_BRIDGE:=yes
5.创建桥接客户端用户和密码
在三个节点都执行如下命令:
mosquitto_passwd -b /etc/mosquitto/pwfile hthl_bridge 123456
6.修改权限控制
在三个节点的aclfile文件中分别追加:
# This is a bridge user.
user hthl_bridge
topic #
然后分别重启服务。
7.配置mosquitto.conf的桥连接属性

	修改主节点192.168.20.38的/etc/mosquitto/mosquitto.conf文件,增加如下信息:	
	# =================================================================
	# bridge
	# =================================================================
	# 桥接名称
	connection broker52
	# 节点地址
	address 192.168.20.52:1883
	# 消息主题
	topic # both 2 "" ""
	# 桥连接用户名
	remote_username hthl_bridge
	# 桥连接密码
	remote_password 123456
	# 桥接名称
	connection broker111
	# 节点地址
	address 192.168.20.111:1883
	# 消息主题
	topic # both 2 "" ""
	# 桥连接用户名
	remote_username hthl_bridge
	# 桥连接密码
	remote_password 123456
	# 桥连接协议版本MQTT3.11
	bridge_protocol_version mqttv311
	# 是否发布桥接的状态信息
	notifications true
	# 桥接断开时,是否清除远程服务器中的消息
	cleansession true
	# 桥连接是否可用的检测开关
	try_private true
	# 桥接模式
	start_type automatic
注意:其他节点千万不要增加此信息否则消息会死循环。 7.测试 7.1订阅 在38节点执行:mosquitto_sub -h 192.168.20.38 -t hthl/hyt -u hthl_sub -P 123456 在52节点执行:mosquitto_sub -h 192.168.20.52 -t hthl/hyt -u hthl_sub -P 123456 在111节点执行:mosquitto_sub -h 192.168.20.111 -t hthl/hyt -u hthl_sub -P 123456 7.2发布 在38节点执行:mosquitto_pub -h 192.168.20.38 -t hthl/hyt -u hthl_pub -P 123456 -m "你好,世界38!" 在52节点执行:mosquitto_pub -h 192.168.20.52 -t hthl/hyt -u hthl_pub -P 123456 -m "你好,世界52!" 在111节点执行:mosquitto_pub -h 192.168.20.111 -t hthl/hyt -u hthl_pub -P 123456 -m "你好,世界111!" 订阅服务的三个窗口会分别打印收到的消息,实现了无论在那台服务器中订阅了信息,无论在那台服务器上发布信息, 订阅者都可以收到发布的信息!ok,集群成功!

centos6.8下mosquitto分布式集群的更多相关文章

  1. ios – 从Swift重写一个Obj-C类方法,返回NSArray

    .要在Swift子类中指定可选或具体值,请使用Objective-Cnullability说明符:exampleMethod;桥接以覆盖类funcexampleMethod()–>[AnyObject]exampleMethod;桥接以覆盖类funcexampleMethod()–>[AnyObject]?exampleMethod;和exampleMethod;具有相同的行为并桥接到隐式解包的可选项.

  2. 开始使用 swift 的 c语言 库

    为了手头上的一个项目,我需要使用CommonCrypto库中的HMAC函数.虽然苹果在swift中已经提供了许多系统库,但是CommonCrypto不在其中.庆幸的是,要使用这个库并不怎么费事,只需要做一点额外的工作.开始访问库在使用库之前,我们需要通知Swift编译器.要完成这个过程,我们有两种方式.它们都能在示例工程中正常运行,但是你应该根据你代码的用途来选择具体的方式.好消息是,你随便使用那

  3. OpenStack对象存储――Swift

    Swift前身是RackspaceCloudFiles项目,随着Rackspace加入到OpenStack社区,于2010年7月贡献给OpenStack,作为该开源项目的一部分。Swift目前的最新版本是OpenStackEssex1.5.1。Swift特性在OpenStack官网中,列举了Swift的20多个特性,其中最引人关注的是以下几点。在OpenStack中还可以与镜像服务Glance结合,为其存储镜像文件。Auth认证服务目前已从Swift中剥离出来,使用OpenStack的认证服务Keysto

  4. 对象存储系统Swift技术详解:综述与概念

    通过阅读Swift的技术文档,我们可以理解其中的设计的原理和实现的方法。本人于9月底开始接触swift,刚开始看文档的时候一知半解,有幸阅读了zzcase等人的博客,才得以入门。随着对swift设计原理的理解和源码的深入,文档经过数次反复的修改,希望对各位学习swift的童鞋有所帮助,水平有限,若各位发现有错误之处,恳请指出。

  5. Swift 与 Object-C 交互 Swift版本为:1.2

    一个是Swift项目调用Object-C的类,另一个是Object-C项目调用Swift类。我们的结构目录变成这样,我这里新建的桥接文件名为“SwiftCallObject-C-Bridging-Header.h”。如果你是第在Object-C项目里第一次创建Swift的类,那么依旧会有窗口提示,询问你是否需要创建桥接文件。这里先说明一下,在Object-C中调用Swift时,Xcode会帮助我们自动生成头文件,不需要我们去维护。谨记,在Object-C调用Swift端代码时,Swift类的class前需

  6. Swift和OC混用

    记得去年在北京一家公司的时候就使用了swift和OC混编。在这里想写一下swift和OC混用的一些简单使用方法,如果有错误请批评指正.在一个应用的target中导入一些Objective-C文件供Swift代码使用时,你需要依赖于Objective-C的桥接头文件来暴露给Swift。当你添加Swift文件到现有的Objective-C应用(或反之)时,Xcode会自动创建这些头文件。在这个桥接头文件中列出的所有public的Objective-C头文件都会对Swift可见。用Swift语法使用这些Obje

  7. 《转》OpenStack对象存储——Swift

    Swift前身是RackspaceCloudFiles项目,随着Rackspace加入到OpenStack社区,于2010年7月贡献给OpenStack,作为该开源项目的一部分。Swift目前的最新版本是OpenStackEssex1.5.1。Swift特性在OpenStack官网中,列举了Swift的20多个特性,其中最引人关注的是以下几点。在OpenStack中还可以与镜像服务Glance结合,为其存储镜像文件。Auth认证服务目前已从Swift中剥离出来,使用OpenStack的认证服务Keysto

  8. swift开发

    [myTableViewinsertSubview:mySubviewatIndex:2在Swift中如下调用。在Objective-C中的指针在导入Swift时被映射为Swift语言的optional类型。importUIKitclassMySwiftViewControllerUIViewController{//definetheclass}如下定义了一个采用Objective-C中的UITableViewDelegate和UITableViewDataSource协议的Swift类MySwiftV

  9. Swift和OC文件间的相互调用

    公共文件/桥接的方法2016/1/2613:33Swift使用OC文件方法看完上面内容之后,你只需要这么做,swift就能使用OC的类了注意这里是搜索bridging注意这里是搜索bridgingOC使用Swift文件方法在你需要使用的文件中导入头文件#import"-Swift.h"如果不行,创建一个桥接文件就行,桥接文件内不写任何代码.Xcode路径要填#

  10. swift 与oc 混编

    生成一个桥接文件Swift_Objc-Bridging-Header.h,这个文件在swift调用oc时学要用到。在viewController,中引入Swift_Objc-Swift.h文件,即可用oc语言使用swift类ViewController.h文件中调用代码:swift调用oc:在Swift_Objc-Bridging-Header.h文件中引入.h头文件,即可用swift语言调用oc类。

随机推荐

  1. 在airgapped(离线)CentOS 6系统上安装yum软件包

    我有一个CentOS6系统,出于安全考虑,它已经被空气泄漏.它可能从未连接到互联网,如果有,它很长时间没有更新.我想将所有.rpm软件包放在一个驱动器上,这样它们就可以脱机安装而无需查询互联网.但是,我在测试VM上遇到的问题是,即使指定了本地路径,yum仍然会挂起并尝试从在线存储库进行更新.另外,有没有办法使用yum-utils/yumdownloader轻松获取该包的所有依赖项和所有依赖项?目前

  2. centos – 命名在日志旋转后停止记录到rsyslog

    CentOS6.2,绑定9.7.3,rsyslog4.6.2我最近设置了一个服务器,我注意到在日志轮换后,named已停止记录到/var/log/messages.我认为这很奇怪,因为所有日志记录都是通过rsyslog进行的,并且named不会直接写入日志文件.这更奇怪,因为我在更新区域文件后命名了HUPed,但它仍然没有记录.在我停止并重新启动命名后,记录恢复.这里发生了什么?

  3. centos – 显示错误的磁盘大小

    对于其中一个磁盘,Df-h在我的服务器上显示错误的空白区域:Cpanel表明它只有34GB免费,但还有更多.几分钟前,我删除了超过80GB的日志文件.所以,我确信它完全错了.fdisk-l/dev/sda2也显示错误:如果没有格式化,我该怎么做才能解决这个问题?并且打开文件描述符就是它需要使用才能做到这一点.所以…使用“lsof”并查找已删除的文件.重新启动写入日志文件的服务,你很可能会看到空间可用.

  4. 如何在centos 6.9上安装docker-ce 17?

    我目前正在尝试在centOS6.9服务器上安装docker-ce17,但是,当运行yuminstalldocker-ce时,我收到以下错误:如果我用跳过的标志运行它我仍然得到相同的消息,有没有人知道这方面的方法?

  5. centos – 闲置工作站的异常负载平均值

    我有一个新的工作站,具有不寻常的高负载平均值.机器规格是:>至强cpu>256GB的RAM>4x512GBSSD连接到LSI2108RAID控制器我从livecd安装了CentOS6.564位,配置了分区,网络,用户/组,并安装了一些软件,如开发工具和MATLAB.在启动几分钟后,工作站负载平均值的值介于0.5到0.9之间.但它没有做任何事情.因此我无法理解为什么负载平均值如此之高.你能帮我诊断一下这个问题吗?

  6. centos – Cryptsetup luks – 检查内核是否支持aes-xts-plain64密码

    我在CentOS5上使用cryptsetupluks加密加密了一堆硬盘.一切都很好,直到我将系统升级到CentOS6.现在我再也无法安装磁盘了.使用我的关键短语装载:我收到此错误:在/var/log/messages中:有关如何装载的任何想法?找到解决方案问题是驱动器使用大约512个字符长的交互式关键短语加密.出于某种原因,CentOS6中的新内核模块在由旧版本创建时无法正确读取512个字符的加密密钥.似乎只会影响内核或cryptsetup的不同版本,因为在同一系统上创建和打开时,512字符的密钥将起作用

  7. centos – 大量ssh登录尝试

    22个我今天登录CentOS盒找到以下内容这是过去3天内的11次登录尝试.WTF?请注意,这是我从我的提供商处获得的全新IP,该盒子是全新的.我还没有发布任何关于此框的内容.为什么我会进行如此大量的登录尝试?是某种IP/端口扫描?基本上有4名匪徒,其中2名来自中国,1名来自香港,1名来自Verizon.这只发生在SSH上.HTTP上没有问题.我应该将罪魁祸首子网路由吗?你们有什么建议?

  8. centos – kswap使用100%的CPU,即使有100GB的RAM也可用

    >Linux内核是否应该足够智能,只需从内存中清除旧缓存页而不是启动kswap?

  9. centos – Azure将VM从A2 / 3调整为DS2 v2

    我正在尝试调整前一段时间创建的几个AzureVM,从基本的A3和标准A3到标准的DS2v2.我似乎没有能力调整到这个大小的VM.必须从头开始重建服务器会有点痛苦.如果它有所不同我在VM中运行CentOS,每个都有一个带有应用程序和操作系统的磁盘.任何人都可以告诉我是否可以在不删除磁盘的情况下删除VM,创建新VM然后将磁盘附加到新VM?

  10. centos – 广泛使用RAM时服务器计算速度减慢

    我在非常具体的情况下遇到服务器速度下降的问题.事实是:>1)我使用计算应用WRF>2)我使用双XeonE5-2620v3和128GBRAM(NUMA架构–可能与问题有关!

返回
顶部