messagebroker

0열

1답변

Kafka는 네트워크를 통해 메시지를 전송하기 위해 응용 프로그램 계층에서 이진 프로토콜을 사용한다는 것을 알고 있겠지만,이 알 수없는 프로토콜은 고도로 보안 된 네트워크에서 문제가됩니다. HTTP 프로토콜을 통한 Kafka의 대안이 될 수있는 메시지 중개 도구가 있습니까? 우리의 임무는 MAN 네트워크를 통해 여러 출처의 데이터를 단일 대상으로 보내는 것

0열

1답변

RabbitMQ를 사용하는 소비자 그룹에 가입 하시겠습니까?

이것이 적절한 장소라고 확신하지는 않지만 게시/가입 메시징 시스템을 구현하는 RabbitMQ의 기능에 대한 질문이 있습니다. 나는 그것이 내가 일하는 회사의 요구에 맞는 있는지 확인하기 위해 RabbitMQ를 조사하고, 나는 공식 문서 또는 인터넷에 하나 이러한 질문에 대한 답변을 찾을 수 없습니다 : 것은 그것을 가능 소비자가 게시자 그룹에 가입 하시겠습

0열

2답변

IBM Integration Bus 및 xsd : anyType

IIB v9 mxsd 메시지 정의로 작업하고 있습니다. xsd : anyType 유형으로 XML 요소 중 하나를 정의하고 싶습니다. 그러나 선택할 수있는 유형 목록에서 anySimpleType 및 anyUri 만 가능합니다 (문자열, 정수 등의 다른 모든 유형 외에). 이 제한 사항을 어떻게 해결할 수 있습니까?

0열

1답변

기존 큐를 CompositeQueue로 변환하는 ActiveMQ

가능한 한 최선을 설명하려고합니다. ActiveMQ 큐에서받은 데이터를 여러 위치에 저장하기 때문에 각 큐브마다 데이터를 개별적으로 처리 할 수 있도록 복합 대기열을 작성하기로 결정했습니다. 현재 실행중인 문제는 현재 프로덕션 환경에서 큐가 있음을 나타냅니다. A라는 대기열을 B 및 C라는 가상 목적지가있는 A라고도하는 복합 대기열로 변경하면 기존 대기

0열

1답변

MQTT를 사용하면 localhost 이외의 모든 사용자를 대상으로 발행물을 차단하고 모든 사람에게 구독을 허용 할 수 있습니까?

내가 원하는 것은 로컬 호스트에서만 데이터를 게시하는 것입니다. 그러나 웹의 모든 사용자가 MQTT를 사용하여이 주제에 등록 할 수 있도록 허용해야합니까? 방법? 그렇지 않은 경우이 세부 사항을 채우기위한 다른 옵션이 있습니까? 추가 정보 : 게시 MQTT 프로토콜을 사용. 웹 소켓을 사용하여 구독하십시오. 브로슈어로 Mosquitto 사용.

1열

1답변

Kafka의 _transaction_state 주제에서 데이터 읽기 0.11.0.1

특정 트랜잭션 ID에 대한 트랜잭션이 커밋되었는지 또는 트랜잭션 ID에 대한 트랜잭션이 커밋 되었는가를 파악할 수 있도록 트랜잭션에 대한 메타 데이터 (Kafka 0.11.0.1에서 지원됨)를 읽으 려합니다. 아니. 현재 _transactional_state 주제에서 키와 값을 얻고 있지만 인코딩 된 형식입니다. 키 = 10000000mmm, 값 = ��

0열

1답변

rabbit mq 용 데이터베이스와 같은 지속성 저장소 옵션

우리 프로젝트에서 메시징 브로커로 토끼 MQ를 사용하고 있습니다. Rabbit MQ의 퍼시스턴스 스토어에 대한 블로그와 문서를 살펴 보았습니다. 디스크의 메모리, 큐 인덱스 및 플랫 파일과 같은 메시지 저장소의 기본 옵션이 있습니다. 우리는 메시지 내구성에 더 관심이 많기 때문에 토끼 mq가있는 데이터 저장소에 대한 최선의 방법을 찾고 있습니다. 또 다른

1열

1답변

Masstransit/RabbitMQ에서 대기열을 구성하는 방법은 무엇입니까?

메시지를 소비하는 모범 사례를 알고 싶습니다. MassTransit 문서를 읽었으며 이에 대해 조사했지만 어떤 결론에 도달하지는 않습니다. 게시 메시지 인 api (버스 인스턴스 호스팅)가 하나 있습니다. 이 API는 마이크로 서비스 (구매, 판매 등을위한 메시지)가 아니기 때문에 다양합니다. 소비자/대기열을 어떻게 구성해야합니까? 큐 유형에 대해 하나의

0열

1답변

Qpid Proton : 두 목적지에 메시지 보내기

현재 하나의 큐 "devQueue"로 메시지를 보낼 수 있습니다. 메시지가 "devQueue"에 도착하면 "localQueue"로 보내야합니다. 나는이 구현이 어렵다는 것을 알고있다. "local1"클래스에서 "local_send"라는 다른 클래스를 호출하여 "localQueue"(아래 코드에서와 같이)이지만 다른 행운과 연결할 수 있습니다. 유용한 양성자

0열

1답변

XMLNS 용 XMLNSC에서 속성을 XML 배열로 설정

반복 요소의 배열이 아닌 XML 요소에 name="xxxxxx" 속성을 추가하는 데 성공합니다. 예를 들어, 나는> 다음 줄에 A 원소 <Broker name="xxxxxx"를 만들 수 있습니다 SET OutputRoot.XMLNSC.SystemDetails.BrokerDetails.Broker.(XMLNSC.Attribute)name = FIELDVAL