mqtt的java代码 mqtt协议编程

android中mqtt怎么做

MQTT连接建立mqtt的java代码的代码(SSL方式)

[java] view plain copy

public static void connect(Driver driver) {

ServerConfig serverConfig = UserModule.Instance.getServerConfig();

MqttConnectOptions conOpt = new MqttConnectOptions();

try {

SSLContext sslContext;

KeyStore ts = KeyStore.getInstance("BKS");

ts.load(context.getResources().openRawResource(R.raw.test_cert),

"123456".toCharArray());

TrustManagerFactory tmf = TrustManagerFactory.getInstance("X509");

tmf.init(ts);

TrustManager[] tm = tmf.getTrustManagers();

sslContext = SSLContext.getInstance("TLS");

sslContext.init(null, tm, null);

SocketFactory factory = sslContext.getSocketFactory();

conOpt.setSocketFactory(factory);

} catch (Exception e) {

e.printStackTrace();

}

span style="white-space:pre" /span

[java] view plain copy

span style="white-space:pre" /span//paho库得

IteratorMap.EntryString, Connection it = Connections

.getInstance(context).getConnections().entrySet().iterator();

while (it.hasNext()) {

MqttClientAndroidService detectClient = it.next().getValue()

.getClient();

try {

detectClient.disconnect();

} catch (MqttException e) {

e.printStackTrace();

}

it.remove();

}

// The basic client information

MqttClientAndroidService client;

client = Connections.getInstance(context).createClient(context,

serverConfig.getUri(), serverConfig.clientId);

Integer qos = Integer.parseInt(context.getResources().getString(

R.string.qos));

Boolean retained = Boolean.parseBoolean(context.getResources()

.getString(R.string.retained));

// connection options

int timeout = Integer.parseInt(context.getResources().getString(

(R.string.timeout)));

int keepalive = Integer.parseInt(context.getResources().getString(

R.string.keepalive));

Connection connection = new Connection(serverConfig.getClientHandle(),

serverConfig.clientId, serverConfig.server,

Integer.parseInt(serverConfig.port), context, client,

serverConfig.ssl);

// connection.registerChangeListener(changeListener);

// connect client

String[] actionArgs = new String[1];

actionArgs[0] = serverConfig.clientId;

connection.changeConnectionStatus(ConnectionStatus.CONNECTING);

boolean cleanSession = false;

conOpt.setCleanSession(cleanSession);

conOpt.setConnectionTimeout(timeout);

conOpt.setKeepAliveInterval(keepalive);

if (!TextUtils.isEmpty(serverConfig.user)) {

conOpt.setUserName(serverConfig.user);

}

if (!TextUtils.isEmpty(serverConfig.pwd)) {

conOpt.setPassword(serverConfig.pwd.toCharArray());

}

// conOpt.setPassword("1111".toCharArray());

final ActionListener callback = new ActionListener(context,

ActionListener.Action.CONNECT, driver.getMqttUtilsCallback(),

serverConfig.getClientHandle(), actionArgs);

boolean doConnect = true;

String message = ActivityConstants.message;

String topic = ActivityConstants.topic;

if ((!TextUtils.isEmpty(message) || !TextUtils.isEmpty(topic))) {

// need to make a message since last will is set

try {

conOpt.setWill(topic, message.getBytes(), qos.intValue(),

retained.booleanValue());

} catch (Exception e) {

e.printStackTrace();

doConnect = false;

callback.onFailure(null, e);

}

}

client.setCallback(new MqttCallbackHandler(context, serverConfig

.getClientHandle(), driver));

connection.addConnectionOptions(conOpt);

Connections.getInstance(context).addConnection(connection);

if (doConnect) {

try {

client.connect(conOpt, null, callback);

} catch (MqttException e) {

Log.e(TAG, "MqttException Occured", e);

}

}

}

发布(publish)代码

[java] view plain copy

public static void publish(String clientHandle, String topic,

JSONObject jsonObj, int qos) {

MqttClientAndroidService client = Connections.getInstance(context)

.getConnection(clientHandle).getClient();

if (!isConnected(context)) {

try {

client.connect();

} catch (MqttException e) {

e.printStackTrace();

}

Toast.makeText(context, "please try again", Toast.LENGTH_SHORT)

.show();

return;

}

if (topic == null) {

Toast.makeText(context, "can not get other's identity for now",

Toast.LENGTH_SHORT).show();

return;

}

String[] args = new String[2];

if (jsonObj.optLong("time") != 0) {

args[0] = String.valueOf(jsonObj.optLong("time"));

args[1] = topic;

}

Boolean retained = Boolean.parseBoolean(context.getResources()

.getString(R.string.retained));

try {

client.publish(topic, jsonObj.toString().getBytes(), qos, retained,

null, new ActionListener(context, Action.PUBLISH, null,

clientHandle, args));

} catch (MqttSecurityException e) {

Log.e(TAG,

"Failed to publish a messged from the client with the handle "

+ clientHandle, e);

} catch (MqttException e) {

Log.e(TAG,

"Failed to publish a messged from the client with the handle "

+ clientHandle, e);

}

}

订阅(subscribe)代码

[java] view plain copy

public static void subscribe(MqttUtilsCallback mqttUtilsCallback,

String clientHandle, String topic) {

MqttClientAndroidService client = Connections.getInstance(context)

.getConnection(clientHandle).getClient();

if (client == null || (client != null !client.isConnected())) {

Toast.makeText(context, "please connect to server first",

Toast.LENGTH_SHORT).show();

return;

}

if (TextUtils.isEmpty(topic)) {

topic = "hello";

}

String[] topics = new String[1];

topics[0] = topic;

try {

client.subscribe(topic, 1, null, new ActionListener(context,

ActionListener.Action.SUBSCRIBE, mqttUtilsCallback,

clientHandle, topics));

} catch (MqttSecurityException e) {

Log.e(TAG, "Failed to subscribe to" + topic

+ " the client with the handle " + clientHandle, e);

} catch (MqttException e) {

Log.e(TAG, "Failed to subscribe to" + topic

+ " the client with the handle " + clientHandle, e);

}

如何对java mqtt程序测试性能

Java编程下用JMeter Java Sampler进行多接口性能测试，使用方法如下：

/**

*JMeter Java Sampler介绍

*setupTest做些初始化的工作，每个线程只执行一次

*teardownTest做些清理工作，每个线程只执行一次

*runTest具体的测试执行工作，每个并发每次循环都将执行一次

**/

//继承AbstractJavaSamplerClient

public class hessianTest extends AbstractJavaSamplerClient{

//hessian调用地址

private static String url = "";

MyService collect = null;

HessianProxyFactory factory = new HessianProxyFactory();

public int id;

@Override

public void setupTest(JavaSamplerContext arg0) {

//获取jmeter传入参数

id=arg0.getIntParameter("id");

try {

collect = (MyService) factory.create(

MyService.class, url);

} catch (MalformedURLException e) {

e.printStackTrace();

}

}

@Override

public SampleResult runTest(JavaSamplerContext arg0) {

SampleResult sp = new SampleResult();

sp.sampleStart();

User rt = null;

try {

rt = collect.getUser(id);

} catch (Exception e) {

sp.sampleEnd();

sp.setSuccessful(false);

return sp;

}

sp.sampleEnd();

if(rt.getId()==id)

sp.setSuccessful(true);

else

sp.setSuccessful(false);

return sp;

}

@Override

public void teardownTest(JavaSamplerContext context) {

super.teardownTest(context);

}

}

如何写一个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 服务器搭建需要用到java吗

最近公司做的项目中有用到消息推送mqtt的java代码，经过多方面的筛选之后确定mqtt的java代码了使用MQTT协议，相对于XMPP，MQTT更加轻量级，并且占用用户很少的带宽。

MQTT是IBM推出的一种针对移动终端设备的基于TCP/IP的发布/预订协议，可以连接大量的远程传感器和控制设备。

MQTT的官网见：。其中里面提供mqtt的java代码了官方推荐的各种服务器和客户端使用的各种语言版本的API。

下面以服务器Apollo 1.6为例，之前尝试过使用ActiveMQ，效果很不理想，只能实现服务器和客户端一对一的通信，从官网上了解到Apollo属于activemq的一个子工程。先不管这些了，言归正传，以下在windows环境下。

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，下面开始客户端代码的编写，为了方便测试这里有android和j2se两个工程：

1、新建android工程MQTTClient

2、MainActivity代码如下：

mqtt的java代码的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于mqtt协议编程、mqtt的java代码的信息别忘了在本站进行查找喔。