0

Artemis 服务器的持续时间寻址和队列设置为：

<address-settings>
    <address-setting match="#">
        <auto-create-addresses>false</auto-create-addresses>
        <auto-delete-addresses>false</auto-delete-addresses>
        <auto-create-queues>false</auto-create-queues>
        <auto-delete-queues>false</auto-delete-queues>
    </address-setting>
</address-settings>
<addresses>
    <address name="test">
        <anycast>
            <queue name="abc.filter"/>
        </anycast>
    </address>
</addresses>

用于连接队列和订阅消息的 javascript 客户端是：

<script src="jquery-3.5.1.min.js"></script>
<script src="stomp.js"></script>
<script>
    $(document).ready(function() {
        let client = Stomp.client("ws://127.0.0.1:61613");
        // this allows to display debug logs directly on the web page
        client.debug = function (str) {
            console.log(str);
        };
        // the client is notified when it is connected to the server.
        // let headers = {"ack": "client", "selector": "location = 'Europe'"};
        let connected = function(frame) {
            client.subscribe("/test", function(message) {
                $("#messages").append("<p>" + message.body + "</p>\n");
            }, {"durable-subscription-name": "filter", "selector": "tag = 'aaa'"});
        };
        client.connect({"client-id": "abc"}, connected);
    });
</script>

虽然客户端设置了selector过滤消息，但客户端可以接收带有其他标签的消息，例如bbb： 选择器无效

然而，类似的选择器在 Java 中是有效的：

class Consumer {
    ActiveMQConnectionFactory factory;
    Connection connection;
    Session session;
    Queue queue;
    MessageConsumer consumer;

    public Consumer() {
        try {
            factory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
            connection = factory.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            queue = session.createQueue("test::abc.filter");
            consumer = session.createConsumer(queue, "tag='aaa'");
            consumer.setMessageListener(new MessageListener() {
                @Override
                public void onMessage(Message message) {
                    try {
                        System.out.println("C-" + tag + " RECEIVING > " + ((TextMessage) message).getText());
                    } catch (JMSException e) {
                        e.printStackTrace();
                    }
                }
            });
            connection.start();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

我想问为什么selector在 stomp-websocket 中不起作用？

发送消息的代码是：

    public Producer() {
        try {
            factory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
            connection = factory.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            queue = session.createQueue("test::abc.filter");
            producer = session.createProducer(queue);
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void send(String tag, String msg) {
        try {
            TextMessage message = session.createTextMessage(msg);
            message.setStringProperty("tag", tag);
            producer.send(message);
            System.out.println("SENDING > " + message.getText());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
4

0 回答 0