메시징 시스템 Pulsar 사용하기

개요



메시징 시스템에 대해 알아보고 찾았으므로 시도해 보겠습니다.

Yahoo! Inc.가 제공하는 OSS 메시징 시스템
htps : // 기주 b. 코 m / 야호오 / 푸 l사 r
상주형 프로세스를 사용하여 빠른 메시징 교환이 가능하다.

Pulsar란?



아래에 알기 쉽습니다.
htps : // / chbぉg. 야호오. 이. jp / 인 f 등 st 루트 얽힌 / 푸 l사 r_ 인 t 로즈 c 치온 /

자세한 것은, 상기의 기사를 봐 주시면 좋겠습니다.

거친 느낌으로
  • 메시징 시스템
  • 비동기식 교환 가능
  • 메시지는
  • producer => 메시지 발신자
  • consumer => 메시지 수신자
  • topic => 메시지를 관리하는 그룹

  • producer가 news라는 주제로 '엔저안'이라는 메시지를 보내면 news라는 주제를 받을 준비를 하고 있는 consumer가 '엔저안' 메시지를 수신한다.

    우선 사용해 본다



    tar.gz 파일을 삭제합니다 (현재 1.15.2가 최신입니다)
    $ wget https://github.com/yahoo/pulsar/releases/download/v1.15.2/pulsar-1.15.2-bin.tar.gz
    

    최신 버전은 아래에서 확인해보십시오.
    htps : // 기주 b. 코 m / 야호오 / Pulsa r / Ree Ase s

    해동
    $ tar xvfz pulsar-1.15.2-bin.tar.gz
    

    pulsar를 standalone 모드로 시작합니다.

    Pulsar는 Standalone (Broker, BookKeeper, Zookeeper가 하나의 서버에서 모두 시작) 모드를 제공합니다.
    $ cd pulsar-1.15.2
    $ bin/pulsar standalone
    

    그런 다음 Consumer 프로세스를 시작합니다.
    $ bin/pulsar-client consume -s 'sub' 'persistent://sample/standalone/ns1/my-topic'
    

    그런 다음 producer 프로세스에서 메시지를 보냅니다.
    $ bin/pulsar-client produce -m 'hello' 'persistent://sample/standalone/ns1/my-topic'
    

    그러면 producer에서 보낸 hello라는 메시지가 consumer 측에 도착했습니다.

    아래의 gif는 왼쪽 화면이 consumer, 오른쪽 화면이 producer입니다.


    요약


  • 쉽게 메시징 시스템을 실감할 수 있었다.
  • 서포트되고 있는 것은 아직 Java만.
  • 나중에 CLI가 아닌 Java에서도 시도해보십시오.
  • 비동기적인 시스템의 구축은 응답적인 부분으로서, 큐잉 시스템은 떨어뜨릴 수 없는 중요한 정보(결제 정보등?)에도 유용하게 활용할 수 있을까?
  • 다른 메시징 시스템과의 차이도 이해를 깊게하고 싶다.
  • 좋은 웹페이지 즐겨찾기