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: messages
Message queue + how to ensure that messages are not lost + how to ensure the orderliness of messages + how to deal with message accumulation
1. Basic concepts of message queue The message queue model is divided into: queue model and publish/subscribe model. Introduction to the queue model: Producers send messages to queues. A queue can store messages sent by multiple producers, and a queue can also have multiple consumers. There is a competitive relationship between consumers, that is, each […]
kafka: partitioning strategy for producers to send messages
In order to increase the scalability of the system, Kafka introduces the concept of partitioning. The partitioning mechanism in Kafka refers to dividing each topic into multiple partitions (Partitions), and each partition is an ordered set of message logs. Each message under a topic will only be saved in a certain partition, and will not […]
[C++ rewriting the bottom layer of Skynet 03] skynet actual combat—insertion and pop-up of global message queue, imitating skynet sending messages, message transmission and message processing between services
Directory of series articles [C++ Rewriting Skynet Bottom Layer 01] Skynet Practical Combat-sunnet basic framework, create, open, wait for thread exit methods, imitate skynet to write message classes [C++ Rewrite Skynet Bottom Layer 02] Skynet Practical Combat-Imitating Skynet to write service classes, object management under multi-threading, spin lock mutex program writing, hash table management objects, […]
RabbitMQ delayed messages: dead letter exchange
Table of Contents 1. Dead letter switch 2. Delay message plug-in Declare delay switch Send delayed message Usage scenarios In the payment business of e-commerce, for some products with limited inventory, for a better user experience, the inventory of the product is usually deducted immediately when the user places an order. For example, when purchasing […]
Spring scheduled task + webSocket implements sending messages to specified users regularly
Life is guiltless, long live health, I am laity. Seven times I despised my soul: For the first time, when it could have been aggressive, it pretended to be humble; The second time, when it is empty, fill it with love; The third time, between difficulty and ease, it chose easy; The fourth time, it […]
Windows installs RocketMQ to send messages regularly at any time
System environment System: window 10 JDK: java version “11.0.21” ROCKETMQ: rocketmq-all-5.1.4-bin-release Installation steps rocketMq download address official website: http://rocketmq.apache.org/dowloading/releases/ Unzip the configuration environment variables, manually add the environment variable named ROCKETMQ_HOME, and index to the RocketMQ decompression directory 3.JDK11, you need to modify some configurations to start RocketMQ, modify %ROCKETMQ_HOME%/bin/runserver.cmd @echo off rem Licensed to […]
uniapp uses stomp+websocket to monitor messages in real time for voice broadcasting
Write a custom directory title here stompjs // Generated by CoffeeScript 1.7.1 /* Stomp Over WebSocket http://www.jmesnil.net/stomp-websocket/doc/ | Apache License V2.0 Copyright (C) 2010-2013 [Jeff Mesnil](http://jmesnil.net/) Copyright (C) 2012 [FuseSource, Inc.](http://fusesource.com) */ (function() {<!– –> var Byte, Client, Frame, Stomp, __hasProp = {<!– –>}.hasOwnProperty, __slice = [].slice; Byte = {<!– –> LF: ‘\x0A’, NULL: ‘\x00’ […]
Centos installs RabbitMQ, JavaSpring sends RabbitMQ delayed messages, and JavaSpring consumes RabbitMQ messages
1, Release Notes erlang and rabbitmq release notes https://www.rabbitmq.com/which-erlang.html Confirm the mq version that needs to be installed and the corresponding erlang version. 2, download the installation file RabbitMQ download address: https://packagecloud.io/rabbitmq/rabbitmq-server Erlang download address: https://packagecloud.io/rabbitmq/erlang RabbitMQ delayed message plug-in download https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases Download the file as shown in the figure 3, installation steps 3.1. Check […]
Springboot integrates webscoket to implement the system to send messages to designated users. There is a small bell notification in the upper right corner of the user interface.
Table of Contents 1. Introduce pom.xml, remember to add annotation when starting the class: @EnableWebSocket 2. Create a configuration class: WebSocketConfig 3. Semaphore related processing classes: SemaphoreUtils 4. Message processing class: MyWebSocket 5. The system sends information to the user 6.nginx configuration 7. 1) Front-end page: webscoket.html 7. 2) Front-end page: webscoket.vue 1. Introduce pom.xml, […]