手机版mqtt服务器_mqtt服务器地址

文章目录：

• 1、如何采用MQTT协议实现android消息推送
• 2、android推送xmpp和mqtt单台服务器支持连接多少，并发多少，求两种协议比较，有测试过的吗？
• 3、如何写一个MQTT连接的android客户端
• 4、如何采用mqtt协议实现android消息推送
• 5、在云服务器上搭建了mqtt，为什么手机连接不上mqtt，要怎么做才能连接上？求求大神帮忙
• 6、如何设置mqtt服务器的账号密码

如何采用MQTT协议实现android消息推送

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

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

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

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

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

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

package com.pig.test.mqtt;

import com.ibm.mqtt.MqttClient;

import

com.ibm.mqtt.MqttException;

import com.ibm.mqtt.MqttSimpleCallback;

public class SubscribeClient {

private final static String

CONNECTION_STRING = "tcp://192.168.1.60: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();

mqttClient.registerSimpleHandler(simpleCallbackHandler);//注册接收消息方法

mqttClient.connect(CLIENT_ID+i,

CLEAN_START, KEEP_ALIVE);

mqttClient.subscribe(TOPICS,

QOS_VALUES);//订阅接主题

/**

*

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

*/

mqttClient.publish(PUBLISH_TOPICS, "keepalive".getBytes(), QOS_VALUES[0],

true);

} catch (MqttException e) {

// TODO Auto-generated

catch block

e.printStackTrace();

}

}

/**

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

* @author pig

*

*/

class SimpleCallbackHandler implements MqttSimpleCallback{

/**

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

* 可以再此处理重新订阅

*/

@Override

public void connectionLost() throws Exception {

//

TODO Auto-generated method

stub

System.out.println("客户机和broker已经断开");

}

/**

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

*/

@Override

public void

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

throws Exception {

// TODO Auto-generated method

stub

System.out.println("订阅主题: " +

topicName);

System.out.println("消息数据: " + new

String(payload));

System.out.println("消息级别(0,1,2): " +

Qos);

System.out.println("是否是实时发送的消息(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 V3.1版本，已经加入了安全验证机制，不要怕啦。

android推送xmpp和mqtt单台服务器支持连接多少，并发多少，求两种协议比较，有测试过的吗？

根据实地观察，单台mqtt服务如果并发达到5w以上，就经常出故障；在2w左右内网访问服务器就比较卡了。

注：配置是4核 16G内存，虚机。配置有点差。对CPU的消耗比较高，内存基本没啥消耗，所以建议把CPU整好点。

如何写一个MQTT连接的android客户端

MQTT是一个轻量级的消息发布/订阅协议，它是实现基于手机客户端的消息推送服务器的理想解决方案。 我们可以从这里下载该项目的实例代码，并且可以找到一个采用PHP书写的服务器端实现。 架构如下所示：wmqtt.jar 是IBM提供的MQTT协议的实现。你可以从如下站点下载它。你可以将该jar包加入你自己的Android应用程序中。 Really Small Message Broker (RSMB) ，他是一个简单的MQTT代理，同样由IBM提供。缺省打开1883端口，应用程序当中，它负责接收来自服务器的消息并将其转发给指定的移动设备。 SAM是一个针对MQTT写的PHP库。你可以从这个下载它. send_mqtt.php是一个通过POST接收消息并且通过SAM将消息发送给RSMB的PHP脚本。 实例代码：Ø 采用XMPP协议实现Android推送 这是我在项目中采用的方案。事实上Google官方的C2DM服务器底层也是采用XMPP协议进行的封装。 XMPP(可扩展通讯和表示协议)是基于可扩展标记语言（XML）的协议，它用于即时消息（IM）以及在线探测。这个协议可能最终允许因特网用户向因特网上的其他任何人发送即时消息。 androidpn是一个基于XMPP协议的java开源Android push notification实现。它包含了完整的客户端和服务器端。经过源代码研究我发现，该服务器端基本是在另外一个开源工程openfire基础上修改实现的，不过比较郁闷的是androidpn的文档是由韩语写的，所以整个研究过程基本都是读源码。它的实现示意图如下：androidpn客户端需要用到一个基于java的开源XMPP协议包asmack，这个包同样也是基于openfire下的另外一个开源项目smack，不过我们不需要自己编译，可以直接把androidpn客户端里面的asmack.jar拿来使用。客户端利用asmack中提供的XMPPConnection类与服务器建立持久连接，并通过该连接进行用户注册和登录认证，同样也是通过这条连接，接收服务器发送的通知。 androidpn服务器端也是java语言实现的，基于openfire开源工程，不过它的Web部分采用的是spring框架，这一点与openfire是不同的。Androidpn服务器包含两个部分，一个是侦听在5222端口上的XMPP服务，负责与客户端的XMPPConnection类进行通信，作用是用户注册和身份认证，并发送推送通知消息。另外一部分是Web服务器，采用一个轻量级的HTTP服务器，负责接收用户的Web请求。服务器架构如下：最上层包含四个组成部分，分别是SessionManager，Auth Manager，PresenceManager以及Notification Manager。SessionManager负责管理客户端与服务器之间的会话，Auth Manager负责客户端用户认证管理，Presence Manager负责管理客户端用户的登录状态，NotificationManager负责实现服务器向客户端推送消息功能。 服务器端界面如下，分别对应了上述的几个功能模块：发送以后，我们可以在手机端看到接收的消息：

如何采用mqtt协议实现android消息推送

使用一个代理服务器message broker，客户端client连接上这个服务器，然后告诉服务器，可以接收哪些类型的消息，同时client也可以发布自己的消息，这些消息根据协议的内容，可以别的client获取。这样就实现了消息推送。

消息推送是通过一定的技术标准或协议，在互联网上通过定期传送用户需要的信息来减少信息过载的一项新技术。

如果想要使用消息推送，推荐使用深圳极光的消息推送系统。深圳极光是国内首个为移动应用开发者提供专业、高效的消息推送服务的产品。品牌成长的过程，就是与客户肩并肩迈向成功的过程。极光将以市场为导向，以创新为动力，以技术为支持，不断用心努力，为每一位尊贵的客户提供极致的服务。

在云服务器上搭建了mqtt，为什么手机连接不上mqtt，要怎么做才能连接上？求求大神帮忙

MQTT协议是广泛应用的物联网协议，使用测试MQTT协议需要MQTT的代理。有两种方法使用MQTT服务，一是租用现成的MQTT服务器，如阿里云，百度云，华为云等公用的云平台提供的MQTT服务，使用公用的MQTT服务器的好处是省事，但如果仅仅用于测试学习还需要注册帐号，灵活性差些，有的平台还需要付费。另一方法是自己使用开源的MQTT组件来搭建。

MQTT服务器非常多，如apache的ActiveMQ，emtqqd，HiveMQ，Emitter，Mosquitto，Moquette等等。

这里介绍的是用轻量级的mosquitto开源项目来搭建一个属于自己的MQTT服务器。

第一步：需要安装一台linux主机，这不多介绍，可以使用真机安装也可以使用虚拟机安装。如果仅仅是自己测试使用都可以。

第二步：下载mosquitto需要的依赖

sudo apt-get install libssl-devsudo apt-get install uuid-devsudo apt-get install cmake

第三步：下载mosquitto并解压，现在mosquitto官网最新的版本是1.5.1

tar xzvf mosquitto-1.5.1.tar.gz

第四步：编译

cd mosquitto-1.5.1/

make

make install

第五步：启动mosquitto

./mosquitto -v

1535473957: mosquitto version 1.5.1 starting

1535473957: Using default config.

1535473957: Opening ipv4 listen socket on port 1883.

1535473957: Opening ipv6 listen socket on port 1883.

这时候mosquitto就会以默认的参数启动。如果需要带配置文件可以修改配置文件mosquitto.conf，

启动时候加上参数 -c，

./mosquitto -c mosquitto.conf

可以看到，mosquitto监听的端口为1883.

这时候我们的MQTT服务器就搭建好了。可找一个mqtt客户端来测试一下。

先发布一个主题“home/garden/fountain/2”

内容是“hello world”

这时候在mosquitto会打印出下面的log

535474247: New connection from 192.168.1.105 on port 1883.

1535474247: New client connected from 192.168.1.105 as MQTT_FX_Client (c1, k60).

1535474247: No will message specified.

1535474247: Sending CONNACK to MQTT_FX_Client (0, 0)

1535474307: Received PINGREQ from MQTT_FX_Client

1535474307: Sending PINGRESP to MQTT_FX_Client

1535474339: Received PUBLISH from MQTT_FX_Client (d0, q0, r0, m0, 'home/garden/fountain/2', ... (12 bytes))

1535474367: Received PINGREQ from MQTT_FX_Client

1535474367: Sending PINGRESP to MQTT_FX_Client

订阅主题“home/garden/fountain/2”

可以看到收到了自己发布的消息。

用wireshark抓包

可以看到抓到了一个MQTT的publish的报文。

如何设置mqtt服务器的账号密码

1、在这里下载Apollo服务器，下载后解压，然后运行apache-apollo-1.6\bin\apollo.cmd，输入create mybroker（名字任意取，这里是根据官网介绍的来取的）创建服务器实例，服务器实例包含了所有的配置，运行时数据等，并且和一个服务器进程关联。

2、create mybroker之后会在bin目录下生成mybroker文件夹，里面包含有很多信息，其中etc\apollo.xml文件下是配置服务器信息的文件，etc\users.properties文件包含连接MQTT服务器时用到的用户名和密码，后面会介绍，可以修改原始的admin=password，可以接着换行添加新的用户名密码。

3、打开cmd，运行…apache-apollo-1.6\bin\mybroker\bin\apollo-broker.cmd run 开启服务器，可以在浏览器中输入查看是否安装成功，该界面展示了topic，连接数等很多信息。

经过上面的简单步骤，服务器基本上就已经完成，下一篇将介绍Android客户端的编写和注意事项。

客户端使用的API，开始我使用的是mqtt-client，使用过后发现问题百出，不能很好的满足要求，后来使用了官方推荐的Eclipse Paho