ActiveMQ重复消息检测(Wildfly，Java EE）

Question

首先，对不起我的英语！我有一个使用JMS和ActiveMQ的项目

@Stateless
@LocalBean
public class Producer {

public void produceMessage(List<String> entityIds) {
  try {
    InitialContext initialContext = new InitialContext();
    ConnectionFactory connectionFactory = (ConnectionFactory) initialContext.lookup("java:/JmsXA");
    Destination destination = (Destination) initialContext.lookup("jms/queue/cachedAttrs");

    Connection connection = connectionFactory.createConnection();
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    MessageProducer producer = session.createProducer(destination);
    producer.setDeliveryMode(DeliveryMode.PERSISTENT);

    entityIds.forEach(entityId -> {                 
                TextMessage message = session.createTextMessage(entityId);
                message.setStringProperty("_AMQ_DUPL_ID", entityId);
                producer.send(message);                     
        }
    );

    connection.close();
    session.close();
    initialContext.close();
  } catch (Exception e) {
    throw new IllegalStateException("..." + e.getMessage());
  }
 }
}

@MessageDriven(
  name = "Consumer",
  activationConfig = {
    @ActivationConfigProperty(propertyName = "destination", propertyValue = 
"jms/queue/cachedAttrs"),
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = 
  "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "useDLQ", propertyValue = "false")
  }
)
public class Consumer implements MessageListener {  

@PersistenceContext
private EntityManager entityManager;

@Override
public void onMessage(Message message) {
  TextMessage id = (TextMessage) message;
}
}

producer.produceMessage（）可以同时在项目的许多地方调用。我需要检查重复的ID和不调用消费者的ID，如果这个ID包含在队列中。

我阅读https://activemq.apache.org/artemis/docs/1.0.0/duplicate-detection.html并执行以下操作

message.setStringProperty("_AMQ_DUPL_ID", entityId);

呼叫制片人：

producer.produceMessage(Arrays.asList("1", "2", "1", "3", "2"));

和获取异常：

原因：ActiveMqDuplicateIdException[errorType=Duplicate_ID_Rejected message=Duplicate message=True，UserID=0C03AADC-C07A-11E8-9FB7-775C9C2BDFEB,Priority=4,Bodysize=225,TUE Sep 25 11:18:25 GMT+07:002018,Expiration=0,Durable=True,Address=JMS.Queue.DeviceCachedTRS,Properties=TypedProperties[__AMQ_CID]=F627A880-C079-11E8-9FB7-775C9C2BDFEB,_AMQ_DUPL_ID=1]]@1895765804]在org.apache.activemq.artemis.core.protocol.core.impl.channelimpl.sendblock(channelimpl.java:406)在org.apache.activemq.artemis.core.protocol.core.impl.channelimpl.sendblock(channelimpl.java:304)在）在org.apache.activemq.artemis.core.client.impl.clientsessionimpl.prepare（clientsessionimpl.java:1241)

我做错了什么？我可以在服务中注入我的生产者吗？或者我需要创建新的对象吗？THNX！

Answer 1

据我所知，你没有做错什么。根据您所说的，您需要代理来拒绝重复的消息。您已经在消息中设置了重复的ID，代理检测到了一个重复的消息，并拒绝了该消息。注意，异常说，“检测到重复的消息-消息将不会被路由。”