Объявите и используйте RabbitMQ с веб-сокетами Spring 4

в нашем текущем приложении мы используем Spring AMQP следующим образом:

<rabbit:connection-factory  id="cachingConnectionFactory" 
                            username="${rabbitmq.connection.username}"
                            password="${rabbitmq.connection.password}"
                            host="${rabbitmq.connection.host}" 
                            port="${rabbitmq.connection.port}"
                            executor="rabbitmqPoolTaskExecutor"
                            requested-heartbeat="${rabbitmq.connection.requested-heartbeat}"
                            channel-cache-size="${rabbitmq.connection.channel-cache-size}"
                            virtual-host="${rabbitmq.connection.virtual-host}" />

<rabbit:admin   id="adminRabbit" 
                connection-factory="cachingConnectionFactory"
                auto-startup="true" />

<rabbit:template    id="rabbitTemplate"
                    connection-factory="cachingConnectionFactory"
                    exchange="v1.general.exchange"
                    message-converter="jsonMessageConverter" 
                    encoding="${rabbitmq.template.encoding}"
                    channel-transacted="${rabbitmq.template.channel-transacted}" />

<rabbit:queue id="v1.queue.1" name="v1.queue.1"  />
<rabbit:queue id="v1.queue.2" name="v1.queue.2" />
<rabbit:queue id="v1.queue.3" name="v1.queue.3" />

<fanout-exchange name="v1.general.exchange" xmlns="http://www.springframework.org/schema/rabbit" >
    <bindings>
        <binding queue="v1.queue.1" />
        <binding queue="v1.queue.2" />
        <binding queue="v1.queue.3" />
    </bindings>
</fanout-exchange>

<listener-container xmlns="http://www.springframework.org/schema/rabbit"
                    connection-factory="cachingConnectionFactory" 
                    message-converter="jsonMessageConverter" 
                    task-executor="rabbitmqPoolTaskExecutor"
                    auto-startup="${rabbitmq.listener-container.auto-startup}"
                    concurrency="${rabbitmq.listener-container.concurrency}"
                    channel-transacted="${rabbitmq.listener-container.channel-transacted}"
                    prefetch="${rabbitmq.listener-container.prefetch}"
                    transaction-size="${rabbitmq.listener-container.transaction-size}" >

    <listener id="v1.listener.queue.1" ref="listener1" method="handleMessage" queues="v1.queue.1" />
    <listener id="v1.listener.queue.2" ref="listener2" method="handleMessage" queues="v1.queue.2" />
    <listener id="v1.listener.queue.3" ref="listener3" method="handleMessage" queues="v1.queue.3" />

</listener-container>

<bean id="amqpServerConnection" class="com.sub1.sub2.RabbitGatewayConnectionImpl">
    <property name="rabbitTemplate" ref="rabbitTemplate" />
</bean>

Когда я настраиваю веб-сокет в новом приложении на основе Spring 4, я не знаю, как/где объявлять обмены, очереди и т. д.

registry.enableStompBrokerRelay("/example1/", "/example2/")
            .setApplicationLogin("guest")
            .setApplicationPasscode("guest")
            .setAutoStartup(true)
            .setRelayHost("localhost")
            .setRelayPort(5672)
            .setSystemHeartbeatReceiveInterval(10000)
            .setSystemHeartbeatSendInterval(10000);

Этот материал должен быть реализован с помощью AMPQ?


person Antonio Acevedo    schedule 23.01.2014    source источник


Ответы (1)


По сути, клиенты устанавливают сеанс WebSocket и используют STOMP для обмена сообщениями (STOMP через WebSocket), а не AMQP. В STOMP все управляется заголовком назначения, и брокеры сообщений должны определить, что это означает. Например, посетите страницу плагина RabbitMQ STOMP, чтобы увидеть, как Rabbit сопоставляет места назначения STOMP с очередями и обменами.

Поэтому, если вы думаете о RabbitMQ как о своем брокере сообщений, где вы уже управляете очередями, обменами и т. д. На стороне веб-приложения протокол обмена сообщениями — STOMP, клиенты могут отправлять сообщения в места назначения STOMP, сопоставленные с @MessageMapping методами контроллера, или в места назначения, поддерживаемые RabbitMQ. . Кроме того, контроллеры или любой другой компонент, внедренный с помощью SimpMessagingTemplate, может отправлять сообщения брокеру (Rabbit), которые затем будут транслироваться подключенным веб-клиентам.

Надеюсь это поможет.

person Rossen Stoyanchev    schedule 23.01.2014