찾다
웹 프론트엔드JS 튜토리얼노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

메시지 대기열이란 무엇인가요? 다음 문서에서는 메시지 대기열의 기본 개념을 안내하고 노드에서 메시지 대기열을 사용하는 방법을 소개합니다. 도움이 되기를 바랍니다.

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

1. 메시지 큐

메시지 큐란 무엇입니까

메시지 큐는 메시지 전송 과정에서 메시지를 저장하는 컨테이너입니다. 먼저)

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

메시지는 전송해야 하는 데이터를 나타내며 텍스트, 문자열 또는 개체 및 기타 정보일 수 있습니다. 消息指的是需要传输的数据,可以是一些文本,字符串,或者是对象等信息。

消息队列则是两个应用间的通信服务,消息的产生者将数据存放到消息队列中就可以立即返回,不需要等待消息的接收者应答。即:生产者保证数据插入队列,谁来取这条消息不需要管。消息的接收者则只专注于接受消息并处理。【相关教程推荐:nodejs视频教程编程教学

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

消息队列能做什么

  • 解耦 上面介绍了,消息队列将消息的生产者和消息的接收者分开,彼此都不受影响。

  • 异步 异步就是为了减少请求的响应时间,消息的生产者只需要处理简单的逻辑,并将数据放到消息队列中即可返回,复杂的逻辑,比如:数据库操作,IO操作由消息的接收者处理。

  • 削峰 消息队列应用在服务时,能将瞬时大量涌入的请求信息保存到消息队列中,并立即返回。再由消息的接收者根据数据处理请求。

  • 应用场景 游戏活动,秒杀活动,下单等会造成瞬时流量暴增的应用。

2.消息队列的概念

介绍完消息队列的基本信息,在开发消息队列之前先介绍一下消息队列的一些基本概念~

消息的生产者(producer)与消费者(customer)

上文提到的生产者消费者,提供的是

链接,通道与队列

  • 链接(connection):表示服务程序与消息队列之间的一条链接。一个服务程序可以创建多条链接

  • 通道(channel):消息队列链接之间的一个通,一个链接可以有多个通道

  • 队列(queue):消息队列中存放数据的队列,一个消息队列服务可以有多个队列。

总结一下,链接,通道队列之间的关系是这样的

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

交换机(exchange)

消息队列发送消息必须要有一个交换机,如果没有指定则用的是默认的交换机。交换机的作用就是将消息才推到对应的队列中。消息队列中一共有4种交换机

  • Direct: 指定队列模式,消息来了,只发给指定的Queue,其他Queue都收不到。

  • fanout: 广播模式,消息来了,就会发送给所有的队列。

  • topic: 模糊匹配模式,通过模糊匹配的方式进行相应转发。

  • header: 与Direct模式类似。

3.node使用rabbitMQ

安装rabbitMQ

  • 安装rabbitMQ可以通过官网上进行下载安装,传送门
  • MAC可以直接用brew命令安装
    brew install rabbitmq
  • 安装完成后启动rabbitmq服务

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

然后再本地中访问 http://localhost:15672/ 就可以看到rabbitmq服务的后台。初始的账号密码均为 guest

메시지 대기열은 두 애플리케이션 간의 통신 서비스입니다. 메시지의 생성기는 메시지수신자가 응답합니다. 즉, Producer는 데이터가 대기열에 삽입되도록 하며 누가 메시지를 받는지는 중요하지 않습니다. 메시지의 수신자는 메시지 수신 및 처리에만 집중합니다. [권장 관련 튜토리얼: nodejs 동영상 튜토리얼, 프로그래밍 교육

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

메시지 큐는 무엇을 할 수 있나요

  • 🎜🎜Decoupling🎜 위에서 소개한 것처럼 메시지 큐는 생산자와 생산자를 결합합니다. 메시지의 수신자는 분리되어 있으며 서로 영향을 받지 않습니다. 🎜
  • 🎜🎜Asynchronous🎜 비동기식은 요청의 응답 시간을 줄이는 것입니다. 메시지 생성자는 간단한 논리만 처리하고 반환할 데이터를 메시지 대기열에 넣으면 됩니다. IO 작업은 🎜메시지 수신자🎜에 의해 처리됩니다. 🎜
  • 🎜🎜Peak Shaving🎜 메시지 큐 애플리케이션이 서비스 중일 때 순간적으로 유입되는 요청 정보를 메시지 큐에 저장하고 즉시 반환할 수 있습니다. 그런 다음 데이터를 기반으로 메시지 수신자가 요청을 처리합니다. 🎜
  • 🎜🎜응용 시나리오🎜 게임 활동, 깜짝 세일 활동, 주문 등 순간적인 트래픽 급증을 일으킬 수 있는 응용 프로그램입니다. 🎜

🎜2. 메시지 큐의 개념🎜🎜🎜메시지 큐의 기본 정보를 소개한 후, 메시지를 개발하기 전에 메시지 큐에 대해 소개하겠습니다. 몇 가지 기본 개념~🎜🎜🎜🎜메시지의 생산자와 소비자🎜🎜🎜🎜위에 언급된 Producerconsumer는 🎜🎜🎜🎜 링크로 제공됩니다. 채널 및 대기열 🎜🎜🎜
  • 🎜링크(연결): 서비스 프로그램과 메시지 대기열 간의 링크를 나타냅니다. 🎜서비스 프로그램은 여러 링크를 생성할 수 있습니다🎜. 🎜
  • 🎜채널(채널): 메시지 대기열 링크 사이의 채널 🎜링크에는 여러 채널이 있을 수 있습니다🎜. 🎜
  • 🎜큐(queue): 메시지 큐에 데이터를 저장하는 큐입니다. 메시지 큐 서비스는 여러 개의 큐를 가질 수 있습니다. 🎜
🎜결론적으로 링크와 채널 큐의 관계는 이렇습니다🎜🎜노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사🎜🎜🎜🎜스위치(교환)🎜🎜🎜🎜Message Queue🎜메시지를 보낼 때🎜 스위치가 있어야 합니다. 지정하지 않으면 기본 스위치가 사용됩니다. 스위치의 역할은 해당 대기열에 메시지를 푸시하는 것입니다. 메시지 대기열에는 총 4가지 유형의 스위치가 있습니다🎜
  • 🎜직접: 메시지가 오면 지정된 대기열로만 전송되고 다른 대기열에서는 메시지가 수신되지 않습니다. . 🎜
  • 🎜fanout: 방송 모드, 메시지가 오면 모든 대기열로 전송됩니다. 🎜
  • 🎜주제: 퍼지 매칭 모드, 퍼지 매칭을 통해 그에 따라 전달됩니다. 🎜
  • 🎜헤더: 다이렉트 모드와 유사합니다. 🎜

🎜3.node는 RabbitMQ를 사용합니다🎜🎜🎜🎜🎜rabbitMQ 설치🎜🎜🎜
  • rabbitMQ 설치는 다음을 통해 수행할 수 있습니다. 공식 웹사이트 다운로드 및 설치, 포털
  • MAC Brew 명령을 사용하여
    /** product.js 消费者 */
    
    
    const amqplib = require('amqplib');
    const config = require('./config');
    
    const { connectUrl } = config;
    
    (async () => {
      const connection = await amqplib.connect(connectUrl);
    
      const channel = await connection.createChannel();
      const exchangeName = 'testExchange';
      const key = 'testQueue';
      const sendMsg = 'hello rabbitmq';
        
      // 知道交换机类型
      await channel.assertExchange(exchangeName, 'fanout', {
        durable: true,
      });
        
      // 指定一个队列
      await channel.assertQueue(key);
    
      for (let i = 0; i < 100; i++) {
        channel.publish(exchangeName, key, Buffer.from(`${sendMsg} ${i}`));
      }
    
      await channel.close();
      await connection.close();
    })();
    를 직접 설치할 수 있습니다.
  • 설치가 완료된 후 Rabbitmq 서비스를 시작하세요.
🎜노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사🎜🎜그런 다음 로컬에서 http://localhost:15672/를 방문하여 Rabbitmq 서비스의 배경을 확인하세요. 초기 계정 비밀번호는 guest🎜🎜🎜🎜🎜🎜🎜node 프로젝트 설치 amqplib🎜🎜🎜입니다.

amqplib是node中使用消息队列的一套工具,可以让我们快速地使用消息队列

地址:https://www.npmjs.com/package/amqplib

创建生产者

/** product.js 消费者 */


const amqplib = require(&#39;amqplib&#39;);
const config = require(&#39;./config&#39;);

const { connectUrl } = config;

(async () => {
  const connection = await amqplib.connect(connectUrl);

  const channel = await connection.createChannel();
  const exchangeName = &#39;testExchange&#39;;
  const key = &#39;testQueue&#39;;
  const sendMsg = &#39;hello rabbitmq&#39;;
    
  // 知道交换机类型
  await channel.assertExchange(exchangeName, &#39;fanout&#39;, {
    durable: true,
  });
    
  // 指定一个队列
  await channel.assertQueue(key);

  for (let i = 0; i < 100; i++) {
    channel.publish(exchangeName, key, Buffer.from(`${sendMsg} ${i}`));
  }

  await channel.close();
  await connection.close();
})();

运行后在后台可以看到新增了一个有100条消息的队列

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

创建消费者

/** customer.js 消费者 */

const amqplib = require(&#39;amqplib&#39;);
const config = require(&#39;./config&#39;);

const { connectUrl } = config;

(async () => {
  let connection = await amqplib.connect(connectUrl);
  const exchangeName = &#39;testExchange&#39;;
  const key = &#39;testQueue&#39;;
  // 创建两个通道
  const channel1 = await connection.createChannel();
  const channel2 = await connection.createChannel();
  // 指定一个交换机
  await channel1.assertExchange(exchangeName, &#39;fanout&#39;, {
    durable: true,
  });
  // 指定一个队列
  await channel1.assertQueue(key);
  await channel1.bindQueue(key, exchangeName, key);
  channel1.consume(key, (msg) => {
    console.log(&#39;channel 1&#39;, msg.content.toString());
  });

  await channel2.assertExchange(exchangeName, &#39;fanout&#39;, {
    durable: true,
  });
  await channel2.assertQueue(key);
  await channel2.bindQueue(key, exchangeName, key);
  channel2.consume(key, (msg) => {
    console.log(&#39;channel 2&#39;, msg.content.toString());
  });
})();

执行后可以看到,两个通道可以同时工作接收消息

노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사

更多node相关知识,请访问:nodejs 教程

위 내용은 노드에서 메시지 큐를 사용하는 방법을 간략하게 분석한 기사의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명
이 기사는 掘金社区에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제
JavaScript가 C로 작성 되었습니까? 증거를 검토합니다JavaScript가 C로 작성 되었습니까? 증거를 검토합니다Apr 25, 2025 am 12:15 AM

예, JavaScript의 엔진 코어는 C로 작성되었습니다. 1) C 언어는 효율적인 성능과 기본 제어를 제공하며, 이는 JavaScript 엔진 개발에 적합합니다. 2) V8 엔진을 예를 들어, 핵심은 C로 작성되며 C의 효율성 및 객체 지향적 특성을 결합하여 C로 작성됩니다.

JavaScript의 역할 : 웹 대화식 및 역동적 인 웹JavaScript의 역할 : 웹 대화식 및 역동적 인 웹Apr 24, 2025 am 12:12 AM

JavaScript는 웹 페이지의 상호 작용과 역학을 향상시키기 때문에 현대 웹 사이트의 핵심입니다. 1) 페이지를 새로 고치지 않고 콘텐츠를 변경할 수 있습니다. 2) Domapi를 통해 웹 페이지 조작, 3) 애니메이션 및 드래그 앤 드롭과 같은 복잡한 대화식 효과를 지원합니다. 4) 성능 및 모범 사례를 최적화하여 사용자 경험을 향상시킵니다.

C 및 JavaScript : 연결이 설명되었습니다C 및 JavaScript : 연결이 설명되었습니다Apr 23, 2025 am 12:07 AM

C 및 JavaScript는 WebAssembly를 통한 상호 운용성을 달성합니다. 1) C 코드는 WebAssembly 모듈로 컴파일되어 컴퓨팅 전력을 향상시키기 위해 JavaScript 환경에 도입됩니다. 2) 게임 개발에서 C는 물리 엔진 및 그래픽 렌더링을 처리하며 JavaScript는 게임 로직 및 사용자 인터페이스를 담당합니다.

웹 사이트에서 앱으로 : 다양한 JavaScript 애플리케이션웹 사이트에서 앱으로 : 다양한 JavaScript 애플리케이션Apr 22, 2025 am 12:02 AM

JavaScript는 웹 사이트, 모바일 응용 프로그램, 데스크탑 응용 프로그램 및 서버 측 프로그래밍에서 널리 사용됩니다. 1) 웹 사이트 개발에서 JavaScript는 HTML 및 CSS와 함께 DOM을 운영하여 동적 효과를 달성하고 jQuery 및 React와 같은 프레임 워크를 지원합니다. 2) 반응 및 이온 성을 통해 JavaScript는 크로스 플랫폼 모바일 애플리케이션을 개발하는 데 사용됩니다. 3) 전자 프레임 워크를 사용하면 JavaScript가 데스크탑 애플리케이션을 구축 할 수 있습니다. 4) node.js는 JavaScript가 서버 측에서 실행되도록하고 동시 요청이 높은 높은 요청을 지원합니다.

Python vs. JavaScript : 사용 사례 및 응용 프로그램 비교Python vs. JavaScript : 사용 사례 및 응용 프로그램 비교Apr 21, 2025 am 12:01 AM

Python은 데이터 과학 및 자동화에 더 적합한 반면 JavaScript는 프론트 엔드 및 풀 스택 개발에 더 적합합니다. 1. Python은 데이터 처리 및 모델링을 위해 Numpy 및 Pandas와 같은 라이브러리를 사용하여 데이터 과학 및 기계 학습에서 잘 수행됩니다. 2. 파이썬은 간결하고 자동화 및 스크립팅이 효율적입니다. 3. JavaScript는 프론트 엔드 개발에 없어서는 안될 것이며 동적 웹 페이지 및 단일 페이지 응용 프로그램을 구축하는 데 사용됩니다. 4. JavaScript는 Node.js를 통해 백엔드 개발에 역할을하며 전체 스택 개발을 지원합니다.

JavaScript 통역사 및 컴파일러에서 C/C의 역할JavaScript 통역사 및 컴파일러에서 C/C의 역할Apr 20, 2025 am 12:01 AM

C와 C는 주로 통역사와 JIT 컴파일러를 구현하는 데 사용되는 JavaScript 엔진에서 중요한 역할을합니다. 1) C는 JavaScript 소스 코드를 구문 분석하고 추상 구문 트리를 생성하는 데 사용됩니다. 2) C는 바이트 코드 생성 및 실행을 담당합니다. 3) C는 JIT 컴파일러를 구현하고 런타임에 핫스팟 코드를 최적화하고 컴파일하며 JavaScript의 실행 효율을 크게 향상시킵니다.

자바 스크립트 행동 : 실제 예제 및 프로젝트자바 스크립트 행동 : 실제 예제 및 프로젝트Apr 19, 2025 am 12:13 AM

실제 세계에서 JavaScript의 응용 프로그램에는 프론트 엔드 및 백엔드 개발이 포함됩니다. 1) DOM 운영 및 이벤트 처리와 관련된 TODO 목록 응용 프로그램을 구축하여 프론트 엔드 애플리케이션을 표시합니다. 2) Node.js를 통해 RESTFULAPI를 구축하고 Express를 통해 백엔드 응용 프로그램을 시연하십시오.

JavaScript 및 웹 : 핵심 기능 및 사용 사례JavaScript 및 웹 : 핵심 기능 및 사용 사례Apr 18, 2025 am 12:19 AM

웹 개발에서 JavaScript의 주요 용도에는 클라이언트 상호 작용, 양식 검증 및 비동기 통신이 포함됩니다. 1) DOM 운영을 통한 동적 컨텐츠 업데이트 및 사용자 상호 작용; 2) 사용자가 사용자 경험을 향상시키기 위해 데이터를 제출하기 전에 클라이언트 확인이 수행됩니다. 3) 서버와의 진실한 통신은 Ajax 기술을 통해 달성됩니다.

See all articles

핫 AI 도구

Undresser.AI Undress

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

Video Face Swap

Video Face Swap

완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

뜨거운 도구

에디트플러스 중국어 크랙 버전

에디트플러스 중국어 크랙 버전

작은 크기, 구문 강조, 코드 프롬프트 기능을 지원하지 않음

Dreamweaver Mac版

Dreamweaver Mac版

시각적 웹 개발 도구

메모장++7.3.1

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

맨티스BT

맨티스BT

Mantis는 제품 결함 추적을 돕기 위해 설계된 배포하기 쉬운 웹 기반 결함 추적 도구입니다. PHP, MySQL 및 웹 서버가 필요합니다. 데모 및 호스팅 서비스를 확인해 보세요.

드림위버 CS6

드림위버 CS6

시각적 웹 개발 도구