This is just one of them, and it is a superficial method of receiving and sending messages. The synchronization mechanism needs to be communicated and confirmed with colleagues engaged in the Internet of Things to see if it can be implemented. Or if there are many devices, the synchronization mechanism will not be used. First, […]
Tag: mqtt
ESP32-DHT11 temperature and humidity data upload to MQTT server
ESP32-DHT11 temperature and humidity data uploaded to MQTT server Introduction ESP32 DHT11 experiment Experiment instructions wiring MQTT server establish connection Add subscription ESP32 drives DHT11 ESP32 sends data to MQTT server Upload temperature and humidity data Experimental results Introduction ESP32 Click on the image to purchase The ESP32 series modules integrate Wi-Fi, traditional Bluetooth and […]
Application example of upgrading related functions based on ESP32 development board using MiSiQi application WIFI (key/advanced)+EEPROM+MQTT+OTA
I am an amateur electronics enthusiast and can use Chinese programming such as Yi Language and e4a. I have recently played with several microcontroller development boards and used MiSiQi for programming. I found that MiSiQi is good at simple programming but has more complex functions. Programming is difficult to use, especially for friends like me […]
MQTT protocol message broker service public network remote connection
Article directory Preface 1. Building Mosquitto on Linux 2. Install Cpolar on Linux 3. Create the MQTT service public network connection address 4. The client remotely connects to the MQTT service 5. Code calls MQTT service 6. Fixed connection TCP public network address 7. Fixed address connection test Foreword Mosquitto is an open source message […]
19. W5100S/W5500+RP2040 Raspberry Pi Pico＜MQTT and MQTTX debugging example＞
1. Preface With the rapid development of IoT technology, the MQTT (Message Queuing Telemetry Transport) protocol has become a widely used communication protocol. It is suitable for low-bandwidth, high-latency, and unreliable network communication between devices. W5500 is an embedded Ethernet controller that integrates a full hardware TCP/IP protocol stack and is also an industrial-grade Ethernet […]
Raspberry Pi connects to ordinary Mqtt server
Raspberry Pi connects to ordinary Mqtt server This article introduces how to use Python language to connect to a common MQTT server on the Raspberry Pi and perform dual-threaded message publishing and subscription. This tutorial will use the paho-mqtt library to complete communication tasks under the MQTT protocol, and is suitable for IoT projects and […]
19. W5100S/W5500+RP2040 Raspberry Pi Pico＜MQTT and MQTTX debugging example＞
Article directory 1 Introduction 2. Introduction 2.1 What is MQTT? 2.2 Features 2.3 MQTT protocol implementation 2.4 Will information 2.5 Application scenarios 3 WIZnet Ethernet chip 4 MQTTClient network setting example overview and usage 4.1 Flowchart 4.2 Core preparation work 4.3 Connection method 4.4 Main code overview 4.5 Results demonstration 5 things to note 6 […]
Paho MQTT Python
Paho MQTT Python Paho is an open source MQTT client project that provides MQTT client implementations in multiple languages, including C, C++, C#, Java, Python, JavaScript, etc., and fully supports MQTT v3.1 and v3.1.1. Paho Python Client is its Python language version and supports Python 2.7 and 3.x. More features can be found at http://www.eclipse.org/paho/clients/python/, […]
QT5.9 ported MQTT, QT for Android ported MQTT
MQTT porting source code package download https://github.com/qt/qtmqtt 1. Transplantation on QT 1. Use qt to open the source code package Compile using the suite, then transplant after compilation 2. Copy all header files under the qtmqtt-5.12.8\src\mqtt file of the source code package to the Mqtt file created in include 3. 4. Copy these two files […]
flink accesses mqtt data source
Flink does not have a native mqtt data source, but you can add mqtt data sources through custom data sources. package com.agioe.flink.source.mqtt; import org.apache.flink.streaming.api.functions.source.RichSourceFunction; import org.eclipse.paho.mqttv5.client.*; import org.eclipse.paho.mqttv5.client.persist.MemoryPersistence; import org.eclipse.paho.mqttv5.common.MqttException; import org.eclipse.paho.mqttv5.common.MqttMessage; import org.eclipse.paho.mqttv5.common.packet.MqttProperties; import java.io.ByteArrayOutputStream; import java.io.ObjectOutputStream; import java.io.Serializable; import java.nio.charset.StandardCharsets; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; public class MqttSource extends RichSourceFunction<String> { //storage service private […]