代码拉取完成，页面将自动刷新
本软件是移植开源软件 paho.mqtt.javascript 源码在OpenHarmony上进行功能适配，在OpenHarmony上已支持原库mqtt客户端的功能。 注意，该库底层使用的是websocket通信，因此只支持ws或wss开头的websocket连接方式的MQttBooker服务。 移植还参考了微信小程序版的paho.mqtt.wxapp，移植参考教程文档第三方开源js库移植适配指南.
ohpm install @yyz116/paho-mqtt
OpenHarmony ohpm 环境配置等更多内容，请参考如何安装 OpenHarmony ohpm 包
最新版本支持
import MQTT from '@yyz116/paho-mqtt'
import MQTT from '@yyz116/paho-mqtt'
let client = new MQTT.Client("broker.emqx.io",8083,"/mqtt", "mqttx_2");
client.trace = msg => {
console.log(msg.message);
hilog.info(0x0000, 'testTag',`mqtt trace msg: ${msg.message}`);
};
client.connect({
timeout: 10,
//userName: "username",
//password: "111111",
keepAliveInterval: 60,
cleanSession: true,
useSSL: false,
// invocationContext: {
// asdf: true,
// },
onSuccess: o => {
//console.log("connected: ", o.invocationContext.asdf);
hilog.info(0x0000, 'testTag',`mqtt trace msg: connect ok`);
},
mqttVersion: 3,
onFailure: e => {
console.error("could not connect: ", e.errorMessage);
},
//hosts: ["broker.emqx.io"],
//ports: [8083],
//mqttVersionExplicit: true,
reconnect: false,
});
console.log(`created new client on "${client.host}:${client.port}/${client.path}" with id "${client.clientId}"`);
client.onMessageArrived = msg => {
console.log(`arrived: ${msg.destinationName}: ${msg.payloadString}`);
console.log(
`len: ${msg.payloadBytes.byteLength}, retained: ${msg.retained}, dup: ${msg.duplicate}, qos: ${msg.qos}`,
);
};
client.onConnectionLost = err => {
console.log(`connection lost (code ${err.errorCode}): ${err.errorMessage}`);
};
client.onMessageDelivered = msg => {
console.log(`delivered: ${msg.destinationName}: ${msg.payloadString}`);
console.log(
`len: ${msg.payloadBytes.byteLength}, retained: ${msg.retained}, dup: ${msg.duplicate}, qos: ${msg.qos}`,
);
};
client.send("test/topic", "123456", 0, true);
client.subscribe("test/topic", {
qos: 0,
onSuccess: o => {
console.log(`subscribed: ${o.invocationContext.asdf}`);
},
onFailure: e => {
console.error("error subscribing: ", e.errorMessage);
},
timeout: 10,
});
client.unsubscribe("test/topic", {
//invocationContext: { asdf: true },
onSuccess: o => {
console.log(`subscribed: ${o.invocationContext.asdf}`);
},
onFailure: e => {
console.error("error subscribing: ", e.errorMessage);
},
timeout: 10,
});
client.send("test/topic2", "hello world,csdn.net/qq8864", 0, true);
client.send("test/topic3", "hello world 2!", 1);
client.send("test/topic4", new ArrayBuffer(3));
Paho.MQTT，本库则是MQTT.以下是原库的介绍内容
The Paho JavaScript Client is an MQTT browser-based client library written in Javascript that uses WebSockets to connect to an MQTT Broker.
The Paho project has been created to provide reliable open-source implementations of open and standard messaging protocols aimed at new, existing, and emerging applications for Machine-to-Machine (M2M) and Internet of Things (IoT). Paho reflects the inherent physical and cost constraints of device connectivity. Its objectives include effective levels of decoupling between devices and applications, designed to keep markets open and encourage the rapid growth of scalable Web and Enterprise middleware and applications.
A zip file containing the full and a minified version the Javascript client can be downloaded from the Paho downloads page
Alternatively the Javascript client can be downloaded directly from the projects git repository: https://raw.githubusercontent.com/eclipse/paho.mqtt.javascript/master/src/paho-mqtt.js.
Please do not link directly to this url from your application.
There are two active branches on the Paho Java git repository, master which is used to produce stable releases, and develop where active development is carried out. By default cloning the git repository will download the master branch, to build from develop make sure you switch to the remote branch: git checkout -b develop remotes/origin/develop
The project contains a maven based build that produces a minified version of the client, runs unit tests and generates it's documentation.
To run the build:
$ mvn
The output of the build is copied to the target directory.
The client uses the Jasmine test framework. The tests for the client are in:
src/tests
To run the tests with maven, use the following command:
$ mvn test
The parameters passed in should be modified to match the broker instance being tested against.
Reference documentation is online at: http://www.eclipse.org/paho/files/jsdoc/index.html
The client should work in any browser fully supporting WebSockets, http://caniuse.com/websockets lists browser compatibility.
The included code below is a very basic sample that connects to a server using WebSockets and subscribes to the topic World, once subscribed, it then publishes the message Hello to that topic. Any messages that come into the subscribed topic will be printed to the Javascript console.
This requires the use of a broker that supports WebSockets natively, or the use of a gateway that can forward between WebSockets and TCP.
// Create a client instance
var client = new Paho.MQTT.Client(location.hostname, Number(location.port), "clientId");
// set callback handlers
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
// connect the client
client.connect({onSuccess:onConnect});
// called when the client connects
function onConnect() {
// Once a connection has been made, make a subscription and send a message.
console.log("onConnect");
client.subscribe("World");
message = new Paho.MQTT.Message("Hello");
message.destinationName = "World";
client.send(message);
}
// called when the client loses its connection
function onConnectionLost(responseObject) {
if (responseObject.errorCode !== 0) {
console.log("onConnectionLost:"+responseObject.errorMessage);
}
}
// called when a message arrives
function onMessageArrived(message) {
console.log("onMessageArrived:"+message.payloadString);
}
Previously the Client's Namepsace was Paho.MQTT, as of version 1.1.0 (develop branch) this has now been simplified to Paho.
You should be able to simply do a find and replace in your code to resolve this, for example all instances of Paho.MQTT.Client will now be Paho.Client and Paho.MQTT.Message will be Paho.Message.
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手
