publish-subscribe

    1

    1답변

    우리는 많은 라이브 데이터에 소켓 I/O를 사용하고 있습니다. 사용자는 소켓을 사용하여 데이터를 보내고받습니다. 로드 밸런서를 사용함에 따라 소켓 i/o의 네임 스페이스 모델을 사용할 수없고 소켓 대신 redis 'pub/sub를 사용할 수 없습니다. 지금까지 채널당 사용자 당 구독에 대해 별도의 다시 연결을 만들려고했습니다. 그러나 최근에 우리는 홍조에

    2

    1답변

    필자는 각 메시지에서 최소 구문 분석 만 수행하면됩니다 (토큰 화, 쉼표로 변환, int로 변환). 필자는 파이썬 스크립트를 소비자로 작성하고 규모를 늘릴 필요가있는 경우이를 컨테이너에서 실행하려고합니다. 나는 술집 서브 엔진을 위해 Google Pub/sub를 사용할 가능성이 높지만 Kafka로 전환하면 같은 질문을하게 될 것이라고 생각합니다. 내가 가지

    9

    2답변

    GC pubsub에서 테스트 항목을 만들었고 끌어 오기 구독을 만들 수 있지만 URL 끝점 구독을 만들 자마자 "pubsub error INVALID_ARGUMENT"가 표시됩니다 에 Params 가입 이름 : testingsub 엔드 포인트 URL : https://requestb.in/1iztlqt1 내가 잘못 뭐하는 거지 어떤 아이디어가

    1

    1답변

    빠른 질문을 당겨 : 내가 명령 줄 도구를 통해 pubsub 구독에서 메시지를 당길 때 gcloud beta pubsub subscriptions pull MY_SUB 내가 (모든 세부 사항 등) 문자열 (이미 디코딩) 같은 데이터 테이블을 얻고있다 그러나 나는 그것을 사용하고 싶다 : gcloud beta pubsub subscriptions pull

    0

    1답변

    Redis Pub/Sub에서 사용 가능한 모든 채널 (및 구독자)을 확인하고 싶습니다. 내가 현재 게시/하위 상태를 표시 할 UI를 만들 수 있도록하고 싶습니다. 레디 스 찾고에서 및 어떤 아이디어가 도움이 될 것입니다 ... 난 아무것도 찾을 수 없습니다 패키지를 ioredis, 감사합니다!

    0

    1답변

    나는 실제로 여기서 무슨 일이 일어나고 있는지 모르기 때문에이 질문을 공식적으로 진술하는 법을 모른다. 내 게시물에 대한 사용자의 의견이있을 때마다 페이스 북은 아무 것도하지 않고 해당 댓글을 표시하도록 아래 요청을합니다. 어떻게합니까? 그들은 지속적으로 끌어 오기 요청을하는대로 https://0-edge-chat.facebook.com/pull?chann

    2

    1답변

    페이지로드 클라이언트에서 채널을 구독 한 다음 게시자가 사용자 별 채널에 게시하고 SSE를 통해 클라이언트에 알림이 전송되는 알림 시스템에 nchan를 사용할 계획입니다. 그래서이 솔루션에 직면하는 문제는 채널에 가입하기 전에 게시 된 nchan의 첫 구독에도 처음으로 구독하는 것입니다. 오래된 메시지를 걸러 내기 위해 timestamp 기반의 메시지 id

    0

    1답변

    /image_pub 항목에서 단일 이미지를 수신하는 ros 게시자/구독자 노드를 실행하고 일부 처리를 수행 한 다음 결과를/결과 항목에 게시합니다. image_pub 주제는 20Hz에서 게시 중이지만 내 게시자/구독자 노드는 12hz에서 실행됩니다 (검색 결과를 사용하여 찾았습니다). 속도를 향상 시키거나 내 프로그램이 20Hz로 작동하도록 지시 할 수있는

    1

    1답변

    다음은 내 C++ 프로그램에서 수행중인 작업의 기본 인스턴스입니다. 나는 청취자 목록이 모두 std::function입니다. 저는 청취자가 어떤 종류의 데이터에 관심이 있는지를 의미하는 개념 DataType을 가지고 있습니다. 여기의 아이디어는 publish-subscribe 패턴과 같습니다. 특정 종류의 데이터에 관심이있는 메소드는 AddListener을

    1

    2답변

    게시 중에 redis pub/sub 메시지에 만료 시간을 설정하려고합니다. nodeJS에서 어떻게합니까? var redis = require('redis'); redis.createClient().publish('some channel', 'some message', function(err) { if (err) { console.err