c# M2Mqtt连接Apollo MQTT服务器[附源码]

小渣渣

分享一款mqtt测试工具
http://www.itsvse.com/thread-3905-1-1.html
(出处: 架构师)

.net/c# activemq操作示例[源码]
http://www.itsvse.com/thread-3907-1-1.html
(出处: 架构师)

关于activemq和rabbitmq资料汇总
http://www.itsvse.com/thread-4659-1-1.html
(出处: 架构师_程序员)

先附上网上的代码：

建立客户端连接并订阅

登录可见。

发布消息

登录可见。

网上的代码，应该连接mosquito mqtt服务器是对的，但是，连接Apollo MQTT服务器就需要改一些代码了。

然后，自己参考了许多文章，自己才写出来。

源码下载：

游客，如果您要查看本帖隐藏内容请回复

小渣渣

Apache Apollo是一个代理服务器，主要用于消息的请求转发，下面是其常用的一些配置文件的介绍
一、users.properties：
用来配置可以使用服务器的用户以及相应的密码。
其在文件中的存储方式是：用户名=密码，如：
lily=123456
表示新增一个用户，用户名是：lily，密码是：123456
二、groups.properties：
持有群体的用户映射，可以通过组而不是单个用户简化访问控制列表。
可以为一个定义的组设置多个用户，用户之间用“|”隔开，如：
admins=admin|lily
表示admins组中有admin和lily两个用户
三、black-list.txt：
用来存放不允许连接服务器的IP地址，相当于黑名单类似的东西。
例如：
10.20.9.147
表示上面IP不能够连接到服务器。
四、login.config：
是一个服务器认证的配置文件，为了安全apollo1.6版本提供了认证功能，只有相应的用户名和正确的密码才能够连接
服务器。
五、服务器主配置文件apollo.xml：
该配置文件用于控制打开的端口，队列，安全，虚拟主机设置等。
       1、认证：可以使用<authenticationdomain="internal" />来配置是否需要连接认证，如果将其属性enable设置为false表示不用认证，任何人都可以连接服务器，默认为true
       2、access_rule：可以在broker或者virtual_host中用于定义用户对服务器资源的各种行为。如：
<access_rule allow="users" action="connect create destroy send receive consume"/>表示群组users里面的用户可以对服务器资源进行的操作有：connect 、create、 destroy、 send 、receive 、consume。详细的操作说明见：
http://activemq.apache.org/apollo/documentation/user-manual.html
       3、message stores：默认情况下apollo使用的是LevelDB store，但是推荐使用BDB store（跨平台的）只能够实用其中一种。使用LevelDB store的配置是：<leveldb_store directory="${apollo.base}/data"/>默认有提供不用任何修改。使用BDB store需要到网站下jar包支持http://download.Oracle.com/maven/com/sleepycat/je/5.0.34/je-5.0.34.jar，将jar包放在服务器的lib目录下面，然后将配置文件改成：<bdb_store directory="${apollo.base}/data"/>即可。
       4、connector：用于配置服务器支持的链接协议以及相应的端口。如：
<connector id="tcp" bind="tcp://0.0.0.0:61613" connection_limit="2000" protocol="mqtt"/>表示支持tcp链接，使用的端口是61613，链接限制是2000，自动侦听的协议是mqtt协议。

安而立

@小渣渣  打扰了，想询问下，ssl/tls链接的问题。由于使用m2mqtt，在.net上编写客户端，使用的是.crt证书，  apollo是Java架构的，使用的证书是keystore封装的。故我自己生成了根证书和服务器证书，并将服务器证书打包成keystore，替换apollo中原本的keystore。先使用paho测试，将秘钥库和信任库都设置为我生成的keystore进行ssl安全通信，成功链接。然后 用c#编程， 想实现单向验证，将ssl    secure设为true，将根证书载入，客户端证书设为空，链接失败。然后发现单向认证好像需要设置client_auth属性。但是在设置该属性（即使设置为默认属性即client_auth=none）后，原本用paho测试端使用keystore可以链接到Apollo的，也不能了。不知道您对此有了解吗？感谢大佬

安而立

打扰了，看到您发表过关于M2mqtt库链接Apollo代理服务的帖子，想询问下，在客户端使用.crt证书，在Apollo上使用keystore进行ssl安全通信，想实现单向验证，好像需要设置client_auth属性。但是在设置该属性（即使设置为默认属性即client——auth=none）后，原本用paho测试端使用keystore可以链接到Apollo的，也不能了。不知道您对此有了解吗？感谢大佬

chenglin

asdasef想到法官腐败

zjpzjp

学习一下，正在使用MQTT中，需要更换Apollo

小渣渣

zjpzjp 发表于 2017-5-3 10:30
学习一下，正在使用MQTT中，需要更换Apollo

Apollo  有缺陷

浮生若佛

正在找相关资源，MARK

chenhuan

挺好的，是我想要的内容

hjxcomputer

正在学习，感谢分享

zeykiss

MQTT学习一下。。。。。

bruce

我也遇到这个问题，谢谢楼主分享