publish-subscribe

3열

1답변

동일한 컴퓨터에서 실행되는 Akka Pub/Sub를 구성하는 방법은 무엇입니까?

Akka의 Distributed Publish Subscribe in Cluster 예제를 따르고 있습니다. 그러나, 나는 동일한 노드 (내 노트북)에서 모든 배우 (게시자 및 가입자)를 실행하고 싶습니다. 나는 그것을 구성하는 방법을 이해할 수 있는지 모르겠다. 누군가 나를 도울 수 있을까? runOn을 사용할 수 있습니까? 아니면 구성 파일에서 선언해야

0열

1답변

자주 업데이트되는 GUI WxPYTHON

나는 100ms마다 실행되고 GUI를 업데이트해야하는 코드 조각이 있습니다. GUI를 업데이트 할 때 - 스레드를 호출하고 차례로 대상 함수를 호출하는 버튼을 누르면됩니다. 대상 함수는 다음과 같이 pub sub를 사용하여 GUI 스레드에 메시지를 되돌립니다. 내 READEVENT을 볼 수있는 wx.CallAfter(pub.sendMessage, "READ

1열

1답변

Akka의 "Distributed Publish Subscribe in Cluster"에서 어떤 주제의 메시지를 받았는지 알 수 있습니까?

센서를 나타내는 액터가있는 Akka 시스템이 있습니다. 센서가 관찰을 할 때마다 해당 액터가 내부 pub/sub 주제에 대해이 관찰을 게시합니다. 이것은 관측의 용도를 쉽게 확장 할 수있게 해준다 (한 액터가 DB에 저장하고 다른 MQTT 브로커에 공개하는 등) 수신자가 어떤 토픽에 메시지를 수신했는지 알 수있게하는 가능한 해결책 메시지에 주제를 포함시키는

2열

2답변

카프카 제작자 별 주제

여러 장치가 있다고 가정 해 보겠습니다. 각 장치에는 다른 유형의 센서가 있습니다. 이제 각 센서의 각 장치에서 카프카로 데이터를 보내려고합니다. 그러나 나는 카프카 주제에 대해 혼란 스럽다. 이 실시간 데이터를 처리하려면 장치별로 kafka 항목을 포함하면 해당 장치의 모든 센서가 특정 카프카 항목으로 데이터를 보내거나 하나의 항목을 만들어 모든 장치에

1열

1답변

SNS에 대한 대체 http pubsub 플랫폼

클라이언트에 http 메시지를 게시하기 위해 플랫폼으로 SNS를 사용하려고했지만 두 가지 주요 문제점이 있습니다. 가입자 아이디/엔드 포인트를 동적으로 보낼 수 없습니다. 모든 조합에 대해 주제를 만들어야하지만 조합은 매우 자주 변경되는 특정 메시지 매개 변수에 따라 매번 변경됩니다. 1 문제를 해결하기 위해 노력하고있는 주제를 런타임에 생성하는 서비스를

0열

1답변

RTI DDS 경고 충돌 프로그램

나는 일정한 프로그램이 충돌과 함께 다음과 같은 경고 메시지가 표시 RTI DDS를 사용하고 유지 프로그램을 실행하고 있습니다 : No transport available to reach locator shmem://0000:0202:0402:0000:0000:0000:0000:0000:7411 위의 문제의 원인이 될 수 무엇 과는 무엇을 문제의 가능한 해

0열

1답변

ejabberd - MUC 대 PubSub 대 최대 참가자 수

개인 및 공용 룸을 모두 지원하는 모바일 채팅 플랫폼을 구축 중입니다. 개인 실용으로 서버에서 ejabberd를 사용하고 iOS 클라이언트에서 XMPPFramework를 사용하여 MUC 기능을 이미 성공적으로 구현했습니다. 그러나 공공 방의 경우 PubSub이 더 합리적인지 여부를 평가하고 싶습니다. 유스 케이스를 세부적으로 정의하려면 모든 공용 룸 멤버가

0열

1답변

헤드 라인 XMPP 메시지 수신/사용

사용자가 보낸 XMPP 메시지를 구독 또는 소비하는 방법. 이 메시지의 유형은 "회선"입니까? 친절하게 해결책을주세요. OpenFire 서버와 Smack 라이브러리를 사용하고 있습니다.

3열

1답변

대부분의 비동기식 마이크로 서비스 아키텍처에서의 동기식 통신

주로 모의 실험용 애완 동물 프로젝트에서 일부 학습 활동으로 서비스를 추출하려고합니다. AMQP (RabbitMQ)를 사용하여 서비스 간의 통신을 처리하고 있습니다. 그러나 웹 프론트 엔드를 나머지 응용 프로그램과 분리하는 데 문제가 있습니다. 웹 서비스는 뷰와 UI 로직을 처리하지만 주요 데이터에 대한 백엔드 "코어"서비스를 쿼리해야합니다. 프론트 엔드

0열

1답변

MQTT 클라이언트가 메시지를 수신하지 않음

MQTT Paho 프로젝트의 다음 코드를 사용하여 내 mqtt 브로커의 메시지를 구독합니다. mosquitto_sub을 사용하여 연결을 테스트했으며 거기에 메시지가 표시됩니다. 그러나 다음 코드를 실행하면 메시지가 수신되지 않고 출력이 인쇄되지 않습니다. 나는 주제와 주인을 검사했다. import paho.mqtt.client as mqtt # The