上一篇文章已經(jīng)介紹了mqtt+activemq實(shí)現(xiàn)消息推送移動(dòng)端的實(shí)現(xiàn)，也介紹了利用自帶的web console進(jìn)行消息發(fā)布的方法。但是在具體的項(xiàng)目應(yīng)用中，當(dāng)我們將需要將該消息推送模塊嵌入到一個(gè)后臺(tái)管理系統(tǒng)當(dāng)中，我們就需要在web端來訪問activeMQ來進(jìn)行消息的發(fā)布。

同樣用的是org.eclipse.paho.client.mqttv3包，相信看過上一篇文章已經(jīng)有了一定的了解，直接來看代碼@Controller

public class HelloController{

private static final String HOST = "tcp://127.0.0.1:1883";

private String TOPIC;

private String MESSAGE;

private static final String clientid = "server";

private MqttClient client;

private MqttTopic topic;

private String userName = "admin";

private String passWord = "password";

private MqttMessage message;

@RequestMapping(value="/redirect")

public String doPublish(HttpServletRequest request) throws MqttException {

//獲取前臺(tái)傳過來的兩個(gè)參數(shù)

TOPIC=request.getParameter("topic");

MESSAGE=request.getParameter("message");

//new mqttClient

//MemoryPersistence設(shè)置clientid的保存形式，默認(rèn)為以內(nèi)存保存

client = new MqttClient(HOST, clientid, new MemoryPersistence());

//與activeMQ連接的方法

connect();

//new mqttMessage

message = new MqttMessage();

//設(shè)置服務(wù)質(zhì)量

message.setQos(2);

//設(shè)置是否在服務(wù)器中保存消息體

message.setRetained(true);

//設(shè)置消息的內(nèi)容

message.setPayload(MESSAGE.getBytes());

//發(fā)布

publish(topic, message);

System.out.println("已發(fā)送");

return "result";

}

private void connect() {

// new mqttConnection 用來設(shè)置一些連接的屬性

MqttConnectOptions options = new MqttConnectOptions();

// 設(shè)置是否清空session,這里如果設(shè)置為false表示服務(wù)器會(huì)保留客戶端的連接記錄，這里設(shè)置為true表示每次連接到服務(wù)器都以新的身份連接

// 換而言之，設(shè)置為false時(shí)可以客戶端可以接受離線消息

options.setCleanSession(false);

// 設(shè)置連接的用戶名和密碼

options.setUserName(userName);

options.setPassword(passWord.toCharArray());

// 設(shè)置超時(shí)時(shí)間

options.setConnectionTimeout(10);

// 設(shè)置會(huì)話心跳時(shí)間

options.setKeepAliveInterval(20);

try {

// 設(shè)置回調(diào)類

client.setCallback(new PushCallback());

// 連接

client.connect(options);

// 獲取activeMQ上名為TOPIC的topic

topic = client.getTopic(TOPIC);

} catch (Exception e) {

e.printStackTrace();

}

}

public void publish(MqttTopic topic, MqttMessage message) throws MqttPersistenceException, MqttException {

// 發(fā)布的方法

// new mqttDeliveryToken

MqttDeliveryToken token = topic.publish(message);

// 發(fā)布

token.waitForCompletion();

System.out.println("message is published completely! "

+ token.isComplete());

}

}

簡(jiǎn)陋的效果圖

總結(jié)

以上是生活随笔為你收集整理的mqtt消息推送 java_MQTT+ActiveMQ实现消息推送（服务器端java实现）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。