[Android实例] MQTT消息推送，即时通讯

该篇文章从eoeAndroid搬迁过来的，原文地址：[Android实例] MQTT消息推送，即时通讯

前几天刚学习了MQTT服务器搭建和如何使用MQTT进行消息推送，不清楚的同学可以查看[Android实例] MQTT协议，Android消息推送

MQTT不仅可以做消息推送，还能够实现即时通讯，今天没事做了个DEMO贡献个大家

主要代码：

接收消息展示：

@Override
public void onStart(Intent intent, int startId) {
// TODO Auto-generated method stub
try {
mqttClient = new MqttClient(Constant.MQTT_SERVERURL, Constant.CLIENT_ID,
new MemoryPersistence());
mqttClient.setCallback(new MqttCallback() {

@Override
public void messageArrived(String topicName, MqttMessage message)
throws Exception {
// TODO Auto-generated method stub
String str = new String(message.getPayload());
if (str != null && !str.equals("")) {
if (MainActivity.handler != null) {
Message msg = new Message();
msg.obj = str;
msg.what = 0;
MainActivity.handler.sendMessage(msg);
}
}
}

@Override
public void deliveryComplete(IMqttDeliveryToken token) {
// TODO Auto-generated method stub

}

@Override
public void connectionLost(Throwable cause) {
// TODO Auto-generated method stub

}
});
mqttClient.connect();
mqttClient.subscribe(Constant.CLIENT_TOPIC);
} catch (MqttException e) {
// TODO Auto-generated catch block
Log.i("Log", e.getMessage());
e.printStackTrace();
}
}

handler = new Handler() {
@Override
public void handleMessage(Message msg) {
// TODO Auto-generated method stub
super.handleMessage(msg);
textView.setText(textView.getText().toString() + "\n"
+ Constant.SERVER_ID + "：" + msg.obj);
}
};

发送消息：

String msg = editText.getText().toString();
if (msg == null || msg.equals("")) {
Toast.makeText(MainActivity.this, "输入内容不能为空",
Toast.LENGTH_SHORT).show();
return;
}
try {
MqttClient client = new MqttClient(Constant.MQTT_SERVERURL,
MqttClient.generateClientId(),
new MemoryPersistence());
client.connect();
MqttTopic temperatureTopic = client
.getTopic(Constant.SERVER_TOPIC);
MqttMessage message = new MqttMessage(msg.getBytes());
temperatureTopic.publish(message);
client.disconnect();
textView.setText(textView.getText().toString() + "\n"
+ "===>本地增加---" + Constant.CLIENT_ID + "：" + msg);
editText.setText("");
} catch (MqttException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

由于是简易demo，这里有一点要注意的是，用两个模拟器测试的时候，demo里面的Constant.java类需要进行根据不同的模拟器有选择去注释

public static String MQTT_SERVERURL = “tcp://192.168.0.79:1883”;

/***************************用户二安装的时候注释掉************************************/
public static String CLIENT_ID = "用户一";
public static String CLIENT_TOPIC = "接受用户二信息";

public static String SERVER_ID = "用户二";
public static String SERVER_TOPIC = "接受用户一信息";

/***************************用户一安装的时候注释掉***********************************/

// public static String CLIENT_ID = “用户二”;

// public static String CLIENT_TOPIC = “接受用户一信息”;

//

// public static String SERVER_ID = “用户一”;

// public static String SERVER_TOPIC = “接受用户二信息”;

代码里面如果有不合理的地方敬请见谅，毕竟是个简易Demo，各位看官别太在意







下载地址：项目代码