Maison développement back-end tutoriel php 消息队列是什么意思?

消息队列是什么意思?

Jun 06, 2016 pm 08:19 PM
消息队列

消息队列就是一个队列结构的中间件,也就是说消息放入这个中间件之后就可以直接返回,并不需要系统立即处理,而另外会有一个程序读取这些数据,并按顺序进行逐次处理。

消息队列是什么意思?

消息队列是什么意思?

消息队列概念

  从本质上说消息对列就是一个队列结构的中间件,也就是说消息放入这个中间件之后就可以直接返回,并不需要系统立即处理,而另外会有一个程序读取这些数据,并按顺序进行逐次处理。

  也就是说当你遇到一个并发特别大并且耗时特别长同时还不需要立即返回处理结果,使用消息队列可以解决这类问题。

核心结构

f3302581a9319ca148e228b61fd198e.png

由一个业务系统进行入队,把消息逐次插入到消息队列中,插入成功之后直接返回成功的结果,后续会有一个消息处理系统,这个系统会把消息系统中的记录逐次进行取出并进行处理,完成一个出队的流程。

应用场景

  数据冗余:比如订单系统,后续需要严格的进行数据转换和记录,消息队列可以把这些数据持久化的存储在队列中,然后有订单,后续处理程序进行获取,后续处理完之后在把这条记录进行删除来保证每一条记录都能够处理完成。

  系统解耦:使用消息系统之后,入队系统和出队系统是分开的,也就说只要一天崩溃了,不会影响另外一台系统正常运转。

  流量削峰:例如秒杀和抢购,我们可以配合缓存来使用消息队列,能够有效的顶住瞬间访问量,防止服务器承受不住导致崩溃。

  异步通信:消息本身使用入队之后可以直接返回。

  扩展性:例如订单队列,不仅可以处理订单,还可以给其他业务使用。

  排序保证:有些场景需要按照产品的顺序进行处理比如单进单出从而保证数据按照一定的顺序处理,使用消息队列是可以的。

以上都是消息队列常见的使用场景,当然消息队列只是一个中间件,可以配合其他产品进行使用。

常见队列实现优缺点

  队列介质

    1、数据库,例如mysql(可靠性高,易实现,速度慢)

    2、缓存, 例如redis (速度快,单个消息报包过大时效率低)

    3、消息系统,例如rabbitMq (专业性强,可靠,学习成本高)

  消息处理触发机制

    1、死循环方式读取:易实现,故障时无法及时恢复;(比较适合做秒杀,比较集中,运维集中维护)

    2、定时任务:压力均分,有处理上限;目前比较流行的处理触发机制。(唯一的缺点是间隔和数据需要注意,不要等上一个任务没有完成下一个任务又开始了)

    3、守护进程:类似于php-fpm 和php-cg,需要shell基础

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Outils d'IA chauds

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

Video Face Swap

Video Face Swap

Échangez les visages dans n'importe quelle vidéo sans effort grâce à notre outil d'échange de visage AI entièrement gratuit !

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Pratique de développement Java Websocket : comment implémenter la fonction de file d'attente de messages Pratique de développement Java Websocket : comment implémenter la fonction de file d'attente de messages Dec 02, 2023 pm 01:57 PM

Pratique de développement Java Websocket : Comment implémenter la fonction de file d'attente de messages Introduction : Avec le développement rapide d'Internet, la communication en temps réel devient de plus en plus importante. Dans de nombreuses applications Web, des mises à jour et des capacités de notification en temps réel sont requises via la messagerie en temps réel. JavaWebsocket est une technologie qui permet la communication en temps réel dans les applications Web. Cet article explique comment utiliser JavaWebsocket pour implémenter la fonction de file d'attente de messages et fournit des exemples de code spécifiques. Concepts de base de la file d'attente de messages

Comment utiliser la file d'attente de messages pour le traitement des tâches asynchrones dans FastAPI Comment utiliser la file d'attente de messages pour le traitement des tâches asynchrones dans FastAPI Jul 30, 2023 pm 09:21 PM

Comment utiliser les files d'attente de messages pour le traitement asynchrone des tâches dans FastAPI Introduction : Dans les applications Web, il est souvent constaté que des tâches chronophages doivent être traitées, telles que l'envoi d'e-mails, la génération de rapports, etc. Si ces tâches sont placées dans un processus requête-réponse synchrone, les utilisateurs devront attendre longtemps, ce qui réduira l'expérience utilisateur et la vitesse de réponse du serveur. Afin de résoudre ce problème, nous pouvons utiliser la file d'attente de messages pour le traitement des tâches asynchrones. Cet article explique comment utiliser les files d'attente de messages pour traiter des tâches asynchrones dans le framework FastAPI.

Développement Golang : créez une file d'attente de messages fiable à l'aide de NATS Développement Golang : créez une file d'attente de messages fiable à l'aide de NATS Sep 21, 2023 am 11:21 AM

Développement Golang : Utilisation de NATS pour créer une file d'attente de messages fiable, des exemples de code spécifiques sont nécessaires Introduction : Dans les systèmes distribués modernes, la file d'attente de messages est un composant important utilisé pour gérer la communication asynchrone, découpler les composants du système et assurer une livraison fiable des messages. Cet article explique comment utiliser le langage de programmation Golang et NATS (le nom complet est « High Performance Reliable Messaging System ») pour créer une file d'attente de messages efficace et fiable, et fournit des exemples de code spécifiques. Qu’est-ce que le NATS ? NATS est un système de messagerie léger et open source.

La merveilleuse utilisation de Redis dans la file d'attente des messages La merveilleuse utilisation de Redis dans la file d'attente des messages Nov 07, 2023 pm 04:26 PM

L'utilisation merveilleuse de Redis dans les files d'attente de messages Les files d'attente de messages sont une architecture découplée courante utilisée pour transmettre des messages asynchrones entre applications. En envoyant un message dans une file d'attente, l'expéditeur peut continuer à effectuer d'autres tâches sans attendre une réponse du destinataire. Et le destinataire peut récupérer le message de la file d’attente et le traiter au moment opportun. Redis est une base de données en mémoire open source couramment utilisée, dotée de hautes performances et de capacités de stockage persistantes. Dans les files d'attente de messages, les multiples structures de données et les excellentes performances de Redis en font un choix idéal

Comment gérer les transactions distribuées et les files d'attente de messages dans le développement C# Comment gérer les transactions distribuées et les files d'attente de messages dans le développement C# Oct 09, 2023 am 11:36 AM

Comment gérer les transactions distribuées et les files d'attente de messages dans le développement C# Introduction : Dans les systèmes distribués d'aujourd'hui, les transactions et les files d'attente de messages sont des composants très importants. Les transactions distribuées et les files d'attente de messages jouent un rôle crucial dans la gestion de la cohérence des données et du découplage du système. Cet article explique comment gérer les transactions distribuées et les files d'attente de messages dans le développement C#, et donne des exemples de code spécifiques. 1. Transactions distribuées Les transactions distribuées font référence à des transactions qui s'étendent sur plusieurs bases de données ou services. Dans les systèmes distribués, assurer la cohérence des données est devenu un défi majeur. Voici deux types de

Compréhension approfondie du mécanisme de mise en œuvre sous-jacent de la file d'attente de messages Kafka Compréhension approfondie du mécanisme de mise en œuvre sous-jacent de la file d'attente de messages Kafka Feb 01, 2024 am 08:15 AM

Présentation des principes d'implémentation sous-jacents de la file d'attente de messages Kafka Kafka est un système de file d'attente de messages distribué et évolutif qui peut gérer de grandes quantités de données et présente un débit élevé et une faible latence. Kafka a été initialement développé par LinkedIn et constitue désormais un projet de haut niveau de l'Apache Software Foundation. Architecture Kafka est un système distribué composé de plusieurs serveurs. Chaque serveur est appelé un nœud et chaque nœud est un processus indépendant. Les nœuds sont connectés via un réseau pour former un cluster. K

Comment implémenter une file d'attente de messages simple à l'aide de Redis et Golang Comment implémenter une file d'attente de messages simple à l'aide de Redis et Golang Aug 01, 2023 am 08:09 AM

Comment utiliser Redis et Golang pour implémenter une file d'attente de messages simple Introduction Les files d'attente de messages sont largement utilisées dans divers scénarios d'application, tels que le découplage des composants du système, l'écrêtage des pics et le remplissage des vallées, la communication asynchrone, etc. Cet article expliquera comment utiliser Redis et Golang pour implémenter une file d'attente de messages simple, aidant les lecteurs à comprendre les principes de base et les méthodes d'implémentation des files d'attente de messages. Introduction à Redis Redis est une base de données open source en mémoire écrite en langage C, qui fournit des fonctions de stockage et de traitement de paires clé-valeur pour d'autres structures de données couramment utilisées. Redis est connu pour ses hautes performances,

Comment implémenter une file d'attente de messages à l'aide d'opérations de script Linux en Java Comment implémenter une file d'attente de messages à l'aide d'opérations de script Linux en Java Oct 05, 2023 am 08:09 AM

Comment utiliser les opérations de script Linux pour implémenter des files d'attente de messages en Java nécessite des exemples de code spécifiques. Les files d'attente de messages sont un mécanisme de communication courant utilisé pour transférer des données entre différents processus. En Java, nous pouvons implémenter des files d'attente de messages à l'aide d'opérations de script Linux afin de pouvoir facilement envoyer ou recevoir des messages depuis la file d'attente. Dans cet article, nous détaillerons comment implémenter des files d'attente de messages à l'aide de scripts Java et Linux, et fournirons des exemples de code spécifiques. Pour démarrer avec Java et Lin

See all articles