mqtt 服务器 哪个好 activemq rabbitmq mosquitto

1、 下载mosquitto安装文件（）

2、 找到相应系统的安装文件安装，如果不想做任何设置直接在服务里启动就行。

3、配置文件

如果需要配置一些用户名、密码、用户权限的参数，则需要修改安装目录下的mosquittoconf文件

下面来说说我用到的一些参数吧：

①用户密码： #password_file pwfileexample 后面跟着是用户密码配置文件，需写上绝对路径并且路径不带空格

②创建用户密码：打开doc窗口，进入mosquitto安装目录，运行mosquitto_passwd -c pwfileexample userName 回车，然后输入密码(密码输入两遍后，在该文件里会自动加密密码)

生成的文件内容格式例如：

userName:$6$Ls7JYQTdn9xagJJ2$zngeT758n1Wn1hnVLjFdK2cHb6lcmI5CMrMTNZe2SqkUj0fBgKts62gvlyWYwdY3/WArx/SAtFRKlvKKnHRCUg==

userName2:$6$bymgVcrtj+7wj8mR$nq1atPD3nreRgA6gDbDjfbUGZIlrmenOcWrXMoneBp+zmAxnOybqJvrBZboxX1XXPnz/TKZwz9aKQJ72zJym5A=

③如果想再增加用户，则执行mosquitto_passwd -u pwfileexample userName2即可

④用户权限：#acl_file aclfileexample 后面跟着是用户权限配置文件，需写上绝对路径并且路径

文件内容格式为：

user userName

/etc/ldsoconfd

mosquittoconf

/usr/local/lib/python26/site-packages ( mosquittopy )

/usr/local/bin

vi /etc/sysconfig/iptables

/usr/local/src/mosquitto-113/lib/python

make install

ldconfig

不改configmk里面的东西

需要安装

yum -y install patch make gcc gcc-c++ gcc-g77 flex bison

centos56下 yum -y install gcc automake autoconf libtool make

yum -y install openssl openssl-devel vim-minimal

这里为只读

topic read 主题

user userName2

这里为可读可写

topic 主题

topic #(或+)表示可以读写任何主题

到这里用户密码及权限已配置完成，订阅和发布的时候加上用户名及密码即可验证：

例如：订阅

client = new MqttClient("tcp://127001:1883","java_client0000000000");

// 回调处理类

Myback callback = new Myback();

clientsetCallback(callback);

// 创建连接可选项信息

MqttConnectOptions conOptions = new MqttConnectOptions();

conOptionssetCleanSession(false);

conOptionssetUserName("userName");

conOptionssetPassword("pwd"toCharArray());

// 连接broker

clientconnect(conOptions);

clientsubscribe("主题");

}

发布：

MqttClient client = new MqttClient("tcp://127001:1883","mqttserver-pub");

MqttTopic topic = clientgetTopic("主题");

MqttMessage message = new MqttMessage(topicgetName()getBytes());

messagesetQos(1);

MqttConnectOptions options = new MqttConnectOptions();

optionssetUserName("userName");

optionssetPassword("pwd"toCharArray());

clientconnect(options);

topicpublish(message);

}

即可验证！

没有安装mosquitto的可以看一下链接先安装一下

MQTT服务器搭建-mosquitto144安装指南

然后我们来安装php扩展

如果你已经使用预先建立的软件包来安装Mosquitto，你需要确保你已经安装了开发头文件。在红帽派生的系统上，这可能是叫做libmosquitto-devel，在基于 Debian的系统上叫做libmosquitto-dev。

你可以使用pecl来来安装这个拓展包：

pecl install Mosquitto-alpha

1

或者，你也可以使用常规的安装拓展的方法来安装：

phpize

/configure --with-mosquitto=/path/to/libmosquitto

make

make install

1

2

3

4

然后添加extension=mosquittoso到你的PHP配置文件phpini中。

--with-mosquitto

1

是可选参数，只有当安装程序找不到libmosquitto拓展包，才需要添加这个参数

1 引入mosquitto仓库并更新

sudo apt-add-repository ppa:mosquitto-dev/mosquitto-ppa

sudo apt-get update

2 执行以下命令安装mosquitto包

sudo apt-get install mosquitto

3 安装mosquitto开发包

sudo apt-get install libmosquitto-dev

4 安装mosquitto客户端

sudoapt-get install mosquitto-clients

5 查询mosquitto是否正确运行

sudo service mosquitto status

6 本机测试

打开一个终端，执行以下命令订阅主题"mqtt"

mosquitto_sub -h localhost -t "mqtt" -v

打开另外一个终端，发布消息到主题 “mqtt”

mosquitto_pub -h localhost -t "mqtt" -m "Hello MQTT"

消息推送（Push）就是通过服务器把内容主动发送到客户端的过程。运营人员通过自己的产品或第三方工具对用户移动设备进行主动消息推送。完成推送后，消息通知会展示在移动设备的锁定屏幕及通知栏上，用户点击通知即可去往相应页面。

现在流行的消息推送实现方式，主要为长链接方式实现。其原理是客户端主动和服务器建立TCP长链接，长链接建立之后，客户端定期向服务器发送心跳包用于保持链接，当有消息要发送的时候，服务器可以直接通过这个已经建立好的长链接，将消息发送到客户端。

个推作为国内移动推送领域的早期进入者，于2010年推出个推消息推送SDK产品，十余年来持续为移动开发者提供稳定、高效、智能的消息推送服务，成功服务了人民日报、新华社、CCTV、新浪微博等在内的数十万APP客户。个推消息推送，也是运用长链接的方式实现消息推送的，其长链接稳定性高、存活好，消息送达率高。开发者通过集成个推消息推送SDK，即可简单、快捷地实现Android和iOS平台的消息推送功能，有效提高产品活跃度、增加用户留存。

如果您对个推消息推送感兴趣，欢迎前往个推开发者中心免费注册体验。

个推的合作客户

，MQTTfx 是目前主流的mqtt客户端，可以快速验证是否可以与IoT Hub 服务交流发布或订阅消息。设备将当前所处的状态作为MQTT主题发送给IoT Hub，每个MQTT主题topic具有不同等级的名称，如“建筑/楼层/温度。” MQTT代理服务器将接收到的主题topic发送给给所有订阅的客户端。

MQTT是一项消息传递技术，由IBM再2001年发布。

总结一下，机制就是使用一个代理服务器messagebroker，

客户端client连接上这个服务器，然后告诉服务器说，我可以接收哪些类型的消息，

同时，client也可以发布自己的消息，这些消息根据协议的内容，可以被其他client获取。

只要手机客户端，连上服务器，然后就可以接收和发布消息了，不用自己写socket什么了，

低带宽，低耗电量，代码量也少，很简单吧。

package compigtestmqtt;

import comibmmqttMqttClient;

import

comibmmqttMqttException;

import comibmmqttMqttSimpleCallback;

public class SubscribeClient {

private final static String

CONNECTION_STRING = "tcp://192168160:1883";

private final static boolean

CLEAN_START = true;

private final static short KEEP_ALIVE =

30;//低耗网络，但是又需要及时获取数据，心跳30s

private final static String CLIENT_ID =

"client1";

private final static String[] TOPICS =

{

"Test/TestTopics/Topic1",

"Test/TestTopics/Topic2",

"Test/TestTopics/Topic3",

"tokudu/client1"

};

private

final static int[] QOS_VALUES = {0, 0, 2,

0};

//////////////////

private MqttClient mqttClient =

null;

public SubscribeClient(String i){

try {

mqttClient =

new MqttClient(CONNECTION_STRING);

SimpleCallbackHandler

simpleCallbackHandler = new

SimpleCallbackHandler();

mqttClientregisterSimpleHandler(simpleCallbackHandler);//注册接收消息方法

mqttClientconnect(CLIENT_ID+i,

CLEAN_START, KEEP_ALIVE);

mqttClientsubscribe(TOPICS,

QOS_VALUES);//订阅接主题

/

完成订阅后，可以增加心跳，保持网络通畅，也可以发布自己的消息

/

mqttClientpublish(PUBLISH_TOPICS, "keepalive"getBytes(), QOS_VALUES[0],

true);

} catch (MqttException e) {

// TODO Auto-generated

catch block

eprintStackTrace();

}

}

/

简单回调函数，处理client接收到的主题消息

@author pig

/

class SimpleCallbackHandler implements MqttSimpleCallback{

/

当客户机和broker意外断开时触发

可以再此处理重新订阅

/

@Override

public void connectionLost() throws Exception {

//

TODO Auto-generated method

stub

Systemoutprintln("客户机和broker已经断开");

}

/

客户端订阅消息后，该方法负责回调接收处理消息

/

@Override

public void

publishArrived(String topicName, byte[] payload, int Qos, boolean retained)

throws Exception {

// TODO Auto-generated method

stub

Systemoutprintln("订阅主题: " +

topicName);

Systemoutprintln("消息数据: " + new

String(payload));

Systemoutprintln("消息级别(0,1,2): " +

Qos);

Systemoutprintln("是否是实时发送的消息(false=实时，true=服务器上保留的最后消息): " +

retained);

}

}

/

高级回调

@author pig

/

class AdvancedCallbackHandler implements MqttSimpleCallback{

@Override

public void connectionLost() throws Exception {

//

TODO Auto-generated method stub

}

@Override

public void publishArrived(String arg0, byte[] arg1, int

arg2,

boolean arg3) throws Exception {

// TODO Auto-generated

method stub

}

}

/

@param args

/

public static void main(String[] args) {

// TODO Auto-generated

method stub

new SubscribeClient("" + i);

}

}

broker服务器，MQTT的jar包，记得下载啊，没有就消息我咯~

到这里，如果完成IBM的MQTT协议实现push消息的实例的，

都会有个问题，好像没考虑到安全问题，如果客户端连上来作乱怎么办呢？

上面用的broker时rsmb的，mqtt的简单服务器。

IBM已经推出了MQTT V31版本，已经加入了安全验证机制，不要怕啦。

转载仅供参考，版权属于原作者。祝你愉快，哦