WildFly Swarm настроить Messaging Remote - PullRequest
Новая
       6

WildFly Swarm настроить Messaging Remote

0 голосов
/ 14 мая 2018

Я настрою два удаленных сервера wildfly-swarm (Версия 2018.5.0). Первый сервер должен отправлять сообщения (через обмен сообщениями от wildfly-swarm) на второй сервер. На втором сервере работает клиент для обмена сообщениями.

Прочитав много (устаревших) уроков, я пришел к выводу, что я тупой.

Я создаю тестовый проект с передачей сообщений wildfly-swarm на одном сервере.

проект-default.yaml 

swarm:
  messaging-activemq:
    servers:
      default:
        jms-queues:
          my-queue: {}
        jms-topics:
          my-topic: {}
  logging:
      pattern-formatters:
        LOG_FORMATTER:
          pattern: "%p [%c] %s%e%n"
      periodic-rotating-file-handlers:
        FILE:
          file:
            path: pathtolog/swarm.log
          suffix: .yyyy-MM-dd
          named-formatter: LOG_FORMATTER
          level: ALL
      root-logger:
        handlers:
        - FILE

MyApplication.java 

import javax.ws.rs.ApplicationPath;
import javax.ws.rs.core.Application;

@ApplicationPath("/")
public class MyApplication extends Application
{
}

MyResource.java 

import javax.annotation.Resource;
import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;
import javax.jms.JMSContext;
import javax.jms.Topic;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import java.util.logging.Level;
import java.util.logging.Logger;


@ApplicationScoped
@Path("/")
public class MyResource
{
    Logger LOG = Logger.getLogger(MyResource.class.getName());

    public static final String MY_TOPIC = "/jms/topic/my-topic";

    @Inject
    private JMSContext context;

    @Resource(lookup = MY_TOPIC)
    private Topic topic;

    @GET
    @Produces("text/plain")
    public String get()
    {
        LOG.log(Level.INFO, "Send Message Hello JMS!");
        context.createProducer().send(topic, "Hello JMS!");
        return "send!";
    }

}

MyTopicMDB.java 

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import java.util.logging.Level;
import java.util.logging.Logger;


@MessageDriven(name = "MyTopicMDB", activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = MyResource.MY_TOPIC),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
})
public class MyTopicMDB implements MessageListener
{
    Logger LOG = Logger.getLogger(MyResource.class.getName());

    @Override
    public void onMessage(Message message)
    {
        try
        {
            LOG.log(Level.INFO, "received Message " + ((TextMessage) message).getText());
            System.out.println("received: " + ((TextMessage) message).getText());
        }
        catch (JMSException e)
        {
            LOG.log(Level.INFO, "Fehler: " + e);
            e.printStackTrace();
        }
    }
}

Есть идеи, как мне настроить project-default.yaml для серверов (один отправитель и один потребитель)?

1 Ответ

0 голосов
/ 15 июня 2018

У нас была та же проблема, и вы были почти у цели: единственное, чего не хватало, было бы это в проекте по умолчанию сервера Swarm (теперь Thorntail), который будет подключаться к удаленному серверу обмена сообщениями: 

swarm:
  network:
    socket-binding-groups:
      standard-sockets:
        outbound-socket-bindings:
          remote-activemq-socket-binding:
            remote-host: <address of remote server>
            remote-port: <port of remote server, likely going to be 61616>

  messaging-activemq:
    servers:
      default:
        [...]
        remote-connectors:
          remote-activemq-connector:
            socket-binding: remote-activemq-socket-binding
        pooled-connection-factories:
          remote-connection-factory:
            # if authentication is required
            user: <user>
            password: <password>
            connectors:
              - remote-activemq-connector
            entries:
              - 'java:/jms/remote-mq'
              - 'java:/DefaultJMSConnectionFactory'

Затем на стороне отправителя вы вводите свою фабрику соединений следующим образом: 

@Inject
@JMSConnectionFactory("java:/jms/remote-mq")
private JMSContext context;

Или, на стороне потребителя, вы можете пометить свой MDB с помощью 

@ResourceAdapter("remote-connection-factory")
...