Stompserver - 클라우드에서의 온라인

프로그램:

이름

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

개요

스톰프 서버 [옵션]

기술

파일/dbm/메모리/활성 레코드 기반 FIFO 대기열을 갖춘 Stomp 메시징 서버
모니터링 및 기본 인증.

옵션

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

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

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

-q, --대기열 유형=대기열 유형
대기열 유형(memory|dbm|activerecord|file)(기본값: 메모리)

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

-s, --저장=DIR
저장소 디렉터리 변경(기본값: .stompserver, Working_dir 기준)

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

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

-c, --검문소=초
대기열 검사 사이의 시간(초)(기본값: 0)

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

대기열

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

물론 메모리 큐는 가장 빠른 것이지만 보장하려는 경우에는 사용하면 안 됩니다.
모든 메시지가 전달됩니다.

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

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

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

ActiveRecord::Schema.define 수행
create_table 'ar_messages' do |t|
t.column 'stomp_id', :string, :null => 거짓
t.column '프레임', :text, :null => false
end
end

이 모델을 사용하여 프레임을 읽을 수 있습니다.

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

ar_message 구현은 앞으로 확실히 변경될 것입니다.

이는 Rails 애플리케이션(다음을 처리할 수 있는)에서 쉽게 읽을 수 있도록 의도되었습니다.
마이그레이션을 통한 ar_messages 테이블 생성).

ACCESS 통제

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

모니터링

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

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

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

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