Интеграция Spring RabbitMQ, идентификатор клиента, идентификатор пользователя и идентификатор приложения для идентификации уникального клиента

Question

В моем приложении я хотел бы отслеживать, какой пользователь/клиент/приложение подключен/отключен от брокера RabbitMQ.

Для подключения к клиенту Как установить уникальный идентификатор, чтобы я мог найти, к какому клиенту (как к производителю/потребителю) подключен, так и нет.

Кстати, я использую Spring Integration для работы с RabbitMQ/AMQP.

Answer 1

См. the documentation.

Начиная с версии 1.7, A ConnectionNameStrategy предназначена для введения в AbstractionConnectionFactory. Сгенерированное имя используется для идентификации целевого соединения RabbitMQ для конкретного приложения. Имя соединения отображается в интерфейсе управления, если сервер RabbitMQ поддерживает его. Это значение не обязательно должно быть уникальным и не может использоваться как идентификатор соединения, например. в запросах HTTP API. Это значение должно быть читаемым человек и является частью ClientProperties под connection_name .Can быть использован в качестве простого Lambda:

connectionFactory.setConnectionNameStrategy(connectionFactory -> "Connection from " + appName); 

С 1.4.5, вы можете также назвать потребитель, добавив ConsumerTagStrategy к контейнер слушателя.

См. Consumer Tags.