stompserver - 클라우드에서 온라인

프로그램:

이름

stompserver - Stomp 프로토콜 메시징 서버

개요

스톰프서버 [옵션]

기술

파일/DBM/메모리/ActiveRecord 기반 FIFO 큐를 갖춘 Stomp 메시징 서버, 큐
모니터링 및 기본 인증.

옵션

-C, --구성=구성
구성 파일(기본값: stompserver.conf)

-p, --포트=PORT
포트를 변경하세요(기본값: 61613)

-b, --주인=ADDR
호스트 변경(기본값: localhost)

-q, --큐타입=큐타입
큐 유형(메모리|DBM|ActiveRecord|파일)(기본값: 메모리)

-w, --작업_디렉토리=DIR
작업 디렉토리 변경(기본값: 현재 디렉토리)

-s, --저장=DIR
저장 디렉토리를 변경합니다(기본값: .stompserver, working_dir을 기준으로 함)

-d, -디버그
디버그 메시지 켜기

-a, --인증
클라이언트 승인이 필요합니다

-c, --검문소=초
대기열을 체크포인트하는 데 걸리는 시간(초)(기본값: 0)

-h, --도움
이 메시지 표시

대기열

Stompserver는 메모리, 파일 또는 DBM 기반을 사용하여 기본 메시지 큐 처리를 처리합니다.
대기열. 메시지는 FIFO 순서로 전송되고 소비됩니다(클라이언트 오류가 발생하지 않는 한).
나중에 수정해야 합니다.) 주제는 메모리 전용 저장소입니다. 선택할 수 있습니다.
activerecord, 파일 또는 DBM 저장소 및 대기열은 이를 사용하지만 주제는 다음과 같습니다.
메모리에 저장됨.

메모리 큐는 물론 가장 빠른 큐이지만 다음을 보장하려는 경우에는 사용해서는 안 됩니다.
모든 메시지가 전달되었습니다.

DBM 대기열은 사용 가능한 경우 BerkeleyDB를 사용하고 그렇지 않은 경우 DBM 또는 GDBM을 사용합니다.
플랫폼. sdbm은 마샬링된 데이터와 잘 작동하지 않습니다. 이러한 대기열은
이 릴리스에서 테스트되었습니다.

파일 기반 저장의 경우 각 프레임은 단일 파일에 저장됩니다. 처음 8바이트
헤더 길이를 포함하고 다음 8바이트는 본문 길이를 포함하고 그 다음에 헤더가 있습니다.
마샬링된 객체로 저장되고 그 뒤에 문자열로 저장된 본문이 옵니다. 이 저장소는
현재 대기열은 메시지와 별도로 저장되므로 비효율적입니다.
데이터 보안상의 이유로 각 메시지에 이중 쓰기가 적용됩니다.

ActiveRecord 기반 저장소는 구성에서 database.yml 파일을 찾을 것으로 예상합니다.
디렉토리입니다. 가장 강력한 백엔드여야 하지만 가장 느린 백엔드여야 합니다. 데이터베이스는
다음 코드로 생성할 수 있는 ar_messages 테이블이 있습니다.
그렇게 할 책임이 있습니다):

ActiveRecord::Schema.define을 정의합니다
create_table 'ar_messages'는 |t|를 수행합니다.
t.column 'stomp_id', :string, :null => false
t.column '프레임', :text, :null => false
end
end

이 모델로 프레임을 읽을 수 있습니다:

클래스 ArMessage < ActiveRecord::Base
직렬화 :프레임
end

ar_message 구현은 앞으로 확실히 바뀔 것입니다.

이는 Rails 애플리케이션에서 쉽게 읽을 수 있도록 설계되었습니다.
(마이그레이션을 사용하여 ar_messages 테이블 생성).

ACCESS 통제

기본 클라이언트 권한 부여도 지원됩니다. stompserver에 -a 플래그가 전달되면
시작 및 실행 디렉토리에 .passwd 파일이 있는 경우 클라이언트는 다음을 수행해야 합니다.
유효한 로그인 정보와 비밀번호를 입력하세요. 비밀번호 파일 형식은 passwd.example을 참조하세요.

모니터링

대기열은 모니터 대기열을 통해 모니터링할 수 있습니다(이것은 아마도 지원되지 않을 것입니다.
(미래에 큐 네임스페이스를 오염시키지 않도록 하는 방법) 구독하는 경우
/queue/monitor를 사용하면 5초마다 각 항목을 표시하는 상태 메시지를 받게 됩니다.
대기열, 크기, 대기열에 추가된 프레임, 대기열에서 제거된 프레임. 통계는 동일한 형식으로 전송됩니다.
스톰프 헤더를 사용하면 구문 분석이 쉽습니다. 다음은 상태 메시지의 예입니다.
2개의 대기열에 대한 통계가 포함되어 있습니다.

대기열: /queue/client2 크기: 0 대기열에서 제거됨: 400 대기열에 추가됨: 400

대기열: /queue/test 크기: 50 대기열에서 제거됨: 250 대기열에 추가됨: 300

onworks.net 서비스를 사용하여 stompserver를 온라인으로 사용하세요