Spring Boot: обмен сообщениями, JMS, поддержка Artemis

Поддержка Artemis

Spring Boot может автоматически настраивать ConnectionFactory, когда он обнаруживает, что Artemis доступен на пути к классам. Если посредник (broker) присутствует, встроенный посредник (embedded broker) автоматически запускается и настраивается (если свойство mode не было явно установлено). Поддерживаемыми режимами являются embedded (чтобы явно указать, что требуется встроенный посредник и что должна возникнуть ошибка, если посредник недоступен на пути к классам), и native (для подключения к посреднику с использованием транспортного протокола netty). Когда последний настроен, Spring Boot настраивает ConnectionFactory, который подключается к посреднику, работающему на локальном компьютере, с настройками по умолчанию.

Если вы используете spring-boot-starter-artemis, предоставляются необходимые зависимости для подключения к существующему экземпляру Artemis, а также инфраструктура Spring для интеграции с JMS. Добавление org.apache.activemq:artemis-jms-server в ваше приложение позволяет использовать встроенный режим (embedded mode).

Конфигурация Artemis контролируется внешними конфигурационными свойствами в spring.artemis.*. Например, вы можете объявить следующий раздел в application.properties:

spring.artemis.mode=native
spring.artemis.host=192.168.1.210
spring.artemis.port=9876
spring.artemis.user=admin
spring.artemis.password=secret

При встраивании посредника вы можете выбрать, хотите ли вы включить постоянство, и перечислить места назначения, которые должны быть доступны. Они могут быть указаны в виде списка через запятую, чтобы создать их с параметрами по умолчанию, или вы можете определить bean-компонент типа org.apache.activemq.artemis.jms.server.config.JMSQueueConfiguration или org.apache.activemq.artemis.jms.server.config.TopicConfiguration, для расширенных конфигураций очереди (queue) и topic, соответственно.

По умолчанию CachingConnectionFactory оборачивает собственный ConnectionFactory разумными настройками, которыми вы можете управлять с помощью внешних свойств конфигурации в spring.jms.*:

spring.jms.cache.session-cache-size=5

Если вы предпочитаете использовать собственный пул, вы можете сделать это, добавив зависимость к org.messaginghub:pooled-jms и настроив JmsPoolConnectionFactory соответствующим образом, как показано в следующем примере:

spring.artemis.pool.enabled=true
spring.artemis.pool.max-connections=50

Поиск JNDI не задействован, и адресаты сопоставляются с их именами, используя либо атрибут name в конфигурации Artemis, либо имена, предоставленные в конфигурации.

Использование JNDI ConnectionFactory

Если вы запускаете приложение на сервере приложений, Spring Boot пытается найти JMS ConnectionFactory с помощью JNDI. По умолчанию расположение java:/JmsXA и java:/XAConnectionFactory проверяется. Вы можете использовать свойство spring.jms.jndi-name, если вам нужно указать альтернативное расположение, как показано в следующем примере:

spring.jms.jndi-name=java:/MyConnectionFactory

Читайте также:


Комментарии

Отправить комментарий

Популярные сообщения из этого блога

Методы класса Object в Java

Изображение
Класс Object является корнем иерархии классов. У каждого класса есть Object как суперкласс. Все объекты, включая массивы, реализуют методы этого класса. Методы класса Object Метод getClass() public final Class getClass() Возвращает класс времени исполнения (runtime class) этого Object. Возвращенный объект Class - это объект, который заблокирован статическими синхронизированными методами представленного класса. Фактический тип результата - Class<? extends |X|> где |X| заменяется статическим типом выражения, для которого вызывается getClass. Например, в этом фрагменте кода не требуется приведение: Number n = 0; Class c = n.getClass(); Метод getClass() возвращает: Объект Class, представляющий класс времени исполнения (runtime class) этого объекта. Метод hashCode public int hashCode() Возвращает значение хэш-кода для объекта. Этот метод поддерживается для использования хэш-таблиц, таких как те, что предоставляются HashMap. Основной контракт метода hashCo
Далее...

Как получить текущий timestamp в Java

Изображение
Чтобы получить текущий timestamp в Java : package main; import java.sql.Timestamp; public class Main { public static void main(String[] args){ Timestamp timestamp = new Timestamp(System.currentTimeMillis()); System.out.println(timestamp); } } Вывод: 2019-10-03 10:09:21.61 Вот еще два более подробных примера как получить текущий timestamp в Java: 1. java.sql.Timestamp Есть два метода получить текущий java.sql.Timestamp package main; import java.sql.Timestamp; import java.text.SimpleDateFormat; import java.util.Date; public class Main { private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy.MM.dd.HH.mm.ss"); public static void main(String[] args) { // Метод 1 Timestamp timestamp = new Timestamp(System.currentTimeMillis()); System.out.println(timestamp); // Метод 2 - через Date Date date = new Date(); System.out.println(new Timestamp(date.getTime()
Далее...

Основные опции JVM для повышения производительности и отладки

Изображение
Если вы являетесь Java-разработчиком или администратором Java приложения, вам поможет в работе знание того, что означают опции JVM, а также их важность и как они влияют на ваше приложение. Обзор параметров JVM Если говорить о параметрах JVM, то есть три типа параметров, которые вы можете включить в JVM: стандартные, нестандартные и расширенные параметры. Если вы используете расширенную опцию, вы всегда используете опцию с -XX. Точно так же, если вы применяете нестандартную опцию, вы используете -X. Стандартные опции ничего не добавляют к опции. Какие параметры JVM используются вашим приложением? Если приложение работает в Linux, вы можете использовать ps -ef | grep java для идентификации процесса Java и просмотра параметров JVM, напечатанных как аргументы процесса. Если в системе выполняется более одного Java-процесса, вам может потребоваться использовать ключевое слово, уникальное для вашего Java-приложения. Если ваш аргумент слишком длинный, попробуйте использовать ps
Далее...