ecsimsw / daily-notes

val contents = myDailyNotes.filter { it.isPublic }
5 stars 0 forks source link

Tuya message service, About pulsar #48

Closed ecsimsw closed 2 months ago

ecsimsw commented 2 months ago

About pulsar

https://devocean.sk.com/blog/techBoardDetail.do?ID=164597&boardType=techBlog

Vs Kafka

image

Exclusive Mode

단일 Consumer에게만 Subscription이 가능함

image

Failover Mode

여러 Consumer가 동일한 Subscription에 연결할 수 있지만, 첫번째 연결된 Consumer가 Failure 되었을 때만 다음 연결된 Consumer에게 메시지가 전달됨.

image

Shared Mode

여러 Consumer가 동일한 Subscription에 연결 가능. 메시지 전달은 RR(Round Robin) Mode 순서로 각 메시지는 하나의 Consumer에게만 전달 됨

image

ecsimsw commented 2 months ago

Tuya Pulsar message broker

Tuya provides the message queue service to help you subscribe to and forward instant messages as required. For example, subscribe to real-time device logs that can be locally stored, or link log storage with other systems.

Get Push Messages by Pulsar

https://developer.tuya.com/en/docs/iot/Pulsar-SDK-get-message?id=Kan0klj9qbv3l

Tuya has customized and improved the message service based on the open source Pulsar. When a device has status changes, such as device registration, data reporting, and going offline, Tuya will send notifications of these changes. You can timely get device messages to analyze or store them. This topic describes how to use Tuya’s Pulsar SDK to receive messages.

How Apache Pulsar Helps Streamline Message System and Reduces O&M Costs at Tuya Smart

https://streamnative.io/success-stories/tuya-smart

ecsimsw commented 2 months ago

https://developer.tuya.com/en/docs/iot/MQTT-protocol?id=Kb65nphxrj8f1

Tuya MQTT broker

image

Tuya MQTT Standard Protocol

This topic describes the Tuya MQTT standard protocol, the underlying communication protocol adopted by the Tuya Developer Platform. This protocol can be integrated into any device, allowing you to develop embedded software as needed.

Does Tuya expose the MQTT service?

No. The HTTP API is used for device control, and message queues pulsar is used for real-time message receiving.