RocketMq 메시지 필터링
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_EXAMPLE");
consumer.subscribe("TOPIC", "TAGA || TAGB || TAGC");소비자들은 TAGA 또는 TAGB 또는 TAGB가 포함된 메시지를 받게 됩니다.그러나 제한은 하나의 메시지에 하나의 탭만 있을 수 있으며 복잡한 상황에서는 무효일 수 있습니다.이 경우 SQL 표현식을 사용하여 메시지를 필터링할 수 있습니다.
* 번호로 모든 tag 메시지를 표시하는 2 sql 방식으로 필터를 하고 생산자와 소비자는 오류가 발생하면 서버에 설치된 RocketMq 디렉터리에 있는 프로필brock을 검사해야 합니다.conf, 속성 enable PropertyFilter=true가 설정되어 있지 않을 수 있습니다.
//
Message msg = new Message("topicList", "tag_a",i + "", (" -" + i).getBytes(RemotingHelper.DEFAULT_CHARSET));
//
msg.putUserProperty("idhao",String.valueOf(i));
SendResult result = producer.send(msg);
####################################################################################################
####################################################################################################
//
DefaultMQPushConsumer xiaofeizhe_group1 = new DefaultMQPushConsumer("xiaofeizhe_group1");
//
xiaofeizhe_group1.subscribe("topicList", MessageSelector.bySql("idhao between 2 and 3"));이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Rails Turbolinks를 페이지 단위로 비활성화하는 방법원래 Turobolinks란? Turbolinks는 링크를 생성하는 요소인 a 요소의 클릭을 후크로 하고, 이동한 페이지를 Ajax에서 가져옵니다. 그 후, 취득 페이지의 데이터가 천이 전의 페이지와 동일한 것이 있...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
