publish-subscribe

-4열

2답변

나는 실시간 보안을 보장해야하는 동시에 publish.subscribe 통신 모델을 사용해야하는 응용 프로그램을 찾고 있습니다.

0열

1답변

PubSubClient가 Callback()을 사용하여받은 메시지를 표시하지 않음

subscribe()이 호출 될 때마다 nodemcu가 메시지를받는 데 문제가 있습니다. publish() 메시지를 보내는 동안 잘 작동합니다. 브로커는 모기입니다. 심지어 callback()을 사용했지만 응답이 없습니다. 여기에 코드가 있습니다. 실제로 카드 태그를 읽고 중개인에게 보냈고 보내진 카드 태그를 기반으로 리눅스의 다른 클라이언트가 subscr

0열

1답변

Vert.x MQTT 서버로부터 메시지를 수신 할 수 없습니다.

일부 Paho- 기반 클라이언트가 Vert.x MQTT 서버로 작업하려고합니다. 내 수신 클라이언트가 구독하는 테스트 주제에 게시하려고합니다. 내 고객 게시자가 내 고객에게 메시지를 전달하는 데 문제가 있습니다. 인터넷에서 보았던 훌륭한 예제를 사용하여 MQTT Broker를 작성했습니다. Vert.x MQTT 브로커 코드에 대한 코드는 다음과 같습니다 :

0열

1답변

Nanomsg 멀티 캐스트 대역폭 문제

nanomsg의 pub/sub 프로토콜에서 순수 멀티 캐스팅을 수행 할 수 있습니까? 단일 게시자에 대한 특정 데이터에 관심있는 N 명의 가입자가있을 수 있기 때문에 동일한 구독 데이터가 N 개의 다른 스트림으로 흐르고 있습니다. 단일 스트림에 대한 대역폭이 10MB이면 N 스트림에 필요한 총 대역폭은 10 * N이며, 따라서 대역폭의 증가가 있습니다. 우

0열

1답변

gcloud pubsub에서 topic 용 protobuf 파일을 추가하는 방법은 무엇입니까?

Google 클라우드의 pubsub에서 새로운 주제를 만들 때 새로운 메시지를 만들어야한다는 것을 알 수 있습니다. 키와 값의 쌍으로 메시지의 전체 구조를 작성해야하는 대신 protobuf 파일을 저장할 수 있습니까? 작성해야 할 protobuf 코드는 this입니다. 만약 protobuf isn gcloud pubsub에 넣어 의미, 어떻게 grpc 클라

0열

1답변

AWS IoT Python 용 MQTT 클라이언트 - 영원히 어떻게 구독하나요?

는 내가 메시지 콜백() 연결() 및 구독 어디 일부 파일 my_test_file.py이 useWebsocket=True 와 함께 샘플/basicPubSub/basicPubSub.py에서 예제를 사용하고 있습니다. 콜백이 일부 로그 파일에 기록한다고 가정 해 보겠습니다. 어떻게하면이 파일을 항상 실행하게 할 수 있습니까? 그래서 오늘, 내일, 오늘, 내일,

0열

1답변

Redis의 채널 팝업 메시지

특정 채널의 한 컴퓨터 (설정자)에 메시지를 게시하고 다른 컴퓨터 (처리기)에서 가져와야합니다. 문제는 각 처리기가 고유 한 메시지를 처리해야한다는 것입니다. documentation에서 볼 수 있듯이 채널에서 메시지를 팝업하는 표준 방법이 없으므로 잘못된 방법으로 사용해 보려고합니까? - 목록을 사용하여 조사 및 팝업을 차단 전화 import redis

1열

1답변

DDS 주제 이름이 주어지면 실행시 주제 유형 정보를 판별 할 수 있습니까?

C++에서 작동하는 RTI ConnextDDS를 평가 중입니다. 런타임에는 DDS 메시지를 읽고 항목 이름을 추출 할 때 해당 항목과 관련된 런타임 정보를 제공하는 API가 있습니까? 즉, 주제의 각 요소의 이름과 유형을 얻을 수 있습니까?

3열

2답변

게시 및 주제 교환과 함께

내가 이벤트 기반 아키텍처와 캐시 서버에서하고 있어요 , 그것은 것을 모델을 구독하는 것은 다음과 같은 일을합니다 : 나는 (모든 복제본에 전송 Set 작업 (팬 아웃 교환하고 싶습니다 ?)) 및 Get (임의의 단일 교환자 (기본 교환 (?)). 나는 Publish&Subscribe 패턴을 읽었으며 fanout exchange을 사용하여 모든 서버를 응답

1열

1답변

서비스 버스 여러 리스너 인스턴스

나는 각 노드는 microservice을 푸른 서비스 버스에서 메시지를 수신 실행, (이 상태가없는 안정적인 서비스)가하는 5 노드 클러스터 있습니다. my_topic (주제 이름)에 대해 하나의 my_Subscription (Subscription Name) 만 작성 했으므로 마이크로 서비스 인스턴스가 임의로 메시지를 수신하고 있습니다. 모든 인스턴스가