machbase-neo
MQTT API
JavaScript & WebSocket

JavaScript & WebSocket

JavaScript 클라이언트는 MQTT.js GitHub 저장소의 MQTT.js 라이브러리를 사용합니다.

Node.js

mqtt.js 라이브러리를 설치합니다.

npm install mqtt --save

main.js 파일을 생성합니다.

const mqtt = require("mqtt");

const client = mqtt.connect("mqtt://127.0.0.1:5653", {
    clean: true,
    connectTimeout: 3000,
    autoUseTopicAlias: true,
    protocolVersion: 5,
});

client.on("connect", () => {
    client.subscribe("db/reply/#", (err) => {
        if (!err) {
            const req = {
                q: "SELECT * FROM example where name = 'neo_cpu.percent' limit 3",
                format: "box",
                timeformat: "default",
                tz: "local",
                precision: 2
            };
            client.publish("db/query", JSON.stringify(req));
        }
    });
});

client.on("message", (topic, message) => {
    console.log(message.toString());
    client.end();
});

node 명령으로 main.js를 실행합니다.

$ node main.js

+-----------------+-------------------------+-------+
| NAME            | TIME                    | VALUE |
+-----------------+-------------------------+-------+
| neo_cpu.percent | 2024-09-06 14:46:19.852 | 69.40 |
| neo_cpu.percent | 2024-09-06 14:46:22.853 | 26.40 |
| neo_cpu.percent | 2024-09-06 14:46:25.852 | 42.80 |
+-----------------+-------------------------+-------+

WebSocket

Machbase Neo v8.0.28부터 WebSocket을 통한 MQTT를 지원합니다.

프로젝트에 MQTT.js를 포함하려면 다음과 같이 CDN 스크립트 태그를 추가합니다.

<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>

기본 WebSocket 엔드포인트는 Machbase Neo HTTP 서버가 제공하는 ws://127.0.0.1:5654/web/api/mqtt입니다.

<html>

<head>
    <script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
</head>

<body>
    <script type="text/javascript">
        const url = 'ws://localhost:5654/web/api/mqtt'

        // MQTT 클라이언트 인스턴스를 생성합니다.
        const options = {
            // 클린 세션
            clean: true,
            connectTimeout: 4000,
        }
        const client = mqtt.connect(url, options)
        client.on('connect', function () {
            console.log('Connected')
            // 쿼리 결과를 받기 위해 'db/reply' 토픽을 구독합니다.
            client.subscribe('db/reply', function (err) {
                if (!err) {
                    // 'db/query' 토픽으로 쿼리를 발행합니다.
                    const req = {q: "SELECT * FROM example limit 10", format:"box", precision: 2}
                    client.publish('db/query', JSON.stringify(req))
                }
            })
        })

        // 메시지를 수신합니다.
        client.on('message', function (topic, message) {
            // 수신한 메시지를 화면에 표시합니다.
            document.getElementById("rspQuery").innerHTML = '<pre>'+message.toString()+'</pre>'
            client.end()
        })

    </script>
    <div id="rspQuery"></div>
</body>

</html>
최근 업데이트
MQTT v5 데이터 쓰기