上一篇文章已經介紹了mqtt+activemq實現消息推送移動端的實現，也介紹了利用自帶的web console進行消息發布的方法。但是在具體的項目應用中，當我們將需要將該消息推送模塊嵌入到一個后臺管理系統當中，我們就需要在web端來訪問activeMQ來進行消息的發布。

同樣用的是org.eclipse.paho.client.mqttv3包，相信看過上一篇文章已經有了一定的了解，直接來看代碼@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 {

//獲取前臺傳過來的兩個參數

TOPIC=request.getParameter("topic");

MESSAGE=request.getParameter("message");

//new mqttClient

//MemoryPersistence設置clientid的保存形式，默認為以內存保存

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

//與activeMQ連接的方法

connect();

//new mqttMessage

message = new MqttMessage();

//設置服務質量

message.setQos(2);

//設置是否在服務器中保存消息體

message.setRetained(true);

//設置消息的內容

message.setPayload(MESSAGE.getBytes());

//發布

publish(topic, message);

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

return "result";

}

private void connect() {

// new mqttConnection 用來設置一些連接的屬性

MqttConnectOptions options = new MqttConnectOptions();

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

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

options.setCleanSession(false);

// 設置連接的用戶名和密碼

options.setUserName(userName);

options.setPassword(passWord.toCharArray());

// 設置超時時間

options.setConnectionTimeout(10);

// 設置會話心跳時間

options.setKeepAliveInterval(20);

try {

// 設置回調類

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 {

// 發布的方法

// new mqttDeliveryToken

MqttDeliveryToken token = topic.publish(message);

// 發布

token.waitForCompletion();

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

+ token.isComplete());

}

}

簡陋的效果圖

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。