在分布式环境

Question

我有一个类似的问题，因为这后消费从Hazelcast队列消息仅一次： Consume message only once from Topic per listeners running in cluster

当我试图使用队列发布消息，并在两个不同的JVM中加入一个项目监听器，我我两次都收到这些消息。我想只在群集/分布式环境中收到消息一次。

这里是我的代码片段：

发布消息：

getQueue().add("some sample message"); 

我有两个不同的JVM配置了相同的监听器是这样的：

public HazelcastQueueListener(){ 
    HazelcastInstance instance = HazelcastClient.newHazelcastClient(HazelClientConfig.getClientConfig()); 
    IQueue<String> queue1 = instance.getQueue("SAMPLEQUEUE"); 
    queue1.addItemListener(this, false); 
} 

public static void main(String args[]){ 
    HazelcastQueueListener listener = new HazelcastQueueListener(); 
} 

@Override 
public void itemAdded(ItemEvent<String> arg0) { 
    // TODO Auto-generated method stub 
    if(arg0!=null){ 
     System.out.println("Item coming out of queue 1" +arg0); 
    } 
    else{ 
     System.out.println("null"); 
    } 

} 

Answer 1

你必须轮询队列，就像一个标准的java BlockingQueue为了消耗一个项目只有一次。

String item = queue1.take() 

AFAIK，Hazelcast不支持队列上的异步操作。 ItemListener不消耗该项目，它只通知项目可用。