Activemq Successfully connected to tcp в логах?

Question

Алексей @Age1mar

DevOps a little

Activemq Successfully connected to tcp в логах?

Добрый день! Может быть кто то сталкивался с записью в логах Successfully connected to tcp ?
У нас 2 брокера, конечное приложение ( использует Camel), использует строку jms.url=failover:(tcp://server1.domain.local:31616,tcp://server2.domain.local:31616) для подключения к брокерам.
Каждые 2-3 минуты прилетает сообщение в логи:
2018-10-23T08:55:31,854 | INFO | ActiveMQ Task-1 | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Successfully connected to tcp://server1.domain.local:31616
Хочется понять, почему возникает данная запись в логах. Происходит переподключение к брокеру ? обрыв связи ?
Читал интернет, прописал keepAlive - ничего не помогает.

Вопрос задан более трёх лет назад
193 просмотра

Комментировать

Подписаться 1 Средний Комментировать

Пригласить эксперта

Ответы на вопрос 1

3 комментария

Алексей @Age1mar Автор вопроса

Спасибо большое! Посмотрим настройки на стороне брокеров.

Написано более трёх лет назад
Алексей Черемисин @leahch

Алексей, я там вроде бы log.debug видел, попробуйте включить, может яснее будет.

Написано более трёх лет назад
Алексей @Age1mar Автор вопроса

Алексей Черемисин, спасибо! Действительно, debug логи помогли. Судя по всему, не верно настроен failover на самих брокерах:
лог:
spoiler

2019-01-29T08:05:56,827 | DEBUG | Camel (adapter-context) thread #26 - timer://adapter-status | TaskRunnerFactory | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Initialized TaskRunnerFactory[ActiveMQ Task] using ExecutorService: java.util.concurrent.ThreadPoolExecutor@3af38efb[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
2019-01-29T08:05:56,827 | DEBUG | Camel (adapter-context) thread #26 - timer://adapter-status | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Reconnect was triggered but transport is not started yet. Wait for start to connect the transport.
2019-01-29T08:05:56,827 | DEBUG | Camel (adapter-context) thread #26 - timer://adapter-status | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Started unconnected
2019-01-29T08:05:56,827 | DEBUG | Camel (adapter-context) thread #26 - timer://adapter-status | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Waking up reconnect task
2019-01-29T08:05:56,827 | DEBUG | ActiveMQ Task-1 | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | urlList connectionList:[tcp://server1.domain.local:31616, tcp://server2.domain.local:31616], from: [tcp://server1.domain.local:31616, tcp://server2.domain.local:31616]
2019-01-29T08:05:56,827 | DEBUG | ActiveMQ Task-1 | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Attempting 0th connect to: tcp://server1.domain.local:31616
2019-01-29T08:05:57,202 | DEBUG | ActiveMQ InactivityMonitor WriteCheckTimer | AbstractInactivityMonitor | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | WriteChecker: 10000ms elapsed since last write check.
2019-01-29T08:05:57,202 | DEBUG | ActiveMQ InactivityMonitor Worker | AbstractInactivityMonitor | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Running WriteCheck[tcp://192.168.12.91:31616]
2019-01-29T08:05:57,655 | DEBUG | ActiveMQ InactivityMonitor WriteCheckTimer | AbstractInactivityMonitor | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | WriteChecker: 10000ms elapsed since last write check.
2019-01-29T08:05:57,655 | DEBUG | ActiveMQ InactivityMonitor Worker | AbstractInactivityMonitor | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Running WriteCheck[tcp://192.168.12.91:31616]
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Connect fail to: tcp://server1.domain.local:31616, reason: {}
java.net.ConnectException: Connection refused: connect
at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) ~[?:?]
at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source) [?:?]
at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source) [?:?]
at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source) [?:?]
at java.net.AbstractPlainSocketImpl.connect(Unknown Source) [?:?]
at java.net.PlainSocketImpl.connect(Unknown Source) [?:?]
at java.net.SocksSocketImpl.connect(Unknown Source) [?:?]
at java.net.Socket.connect(Unknown Source) [?:?]
at org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:525) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:488) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:169) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.transport.InactivityMonitor.start(InactivityMonitor.java:52) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:64) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1017) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:148) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133) [65:org.apache.activemq.activemq-osgi:5.14.5]
at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48) [65:org.apache.activemq.activemq-osgi:5.14.5]
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) [?:?]
at java.lang.Thread.run(Unknown Source) [?:?]
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | TcpTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Stopping transport tcp://server1.domain.local:31616
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | TaskRunnerFactory | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Initialized TaskRunnerFactory[ActiveMQ Task] using ExecutorService: java.util.concurrent.ThreadPoolExecutor@2e77d584[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | TcpTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Closed socket Socket[unconnected]
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | ThreadPoolUtils | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Forcing shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@2e77d584[Running, pool size = 1, active threads = 0, queued tasks = 0, completed tasks = 1]
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Attempting 0th connect to: tcp://server2.domain.local:31616
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | WireFormatNegotiator | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Sending: WireFormatInfo { version=12, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, ProviderName=ActiveMQ, StackTraceEnabled=true, PlatformDetails=JVM: 1.8.0_162, 25.162-b12, Oracle Corporation, OS: Windows Server 2016, 10.0, amd64, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000, ProviderVersion=5.14.5}, magic=[A,c,t,i,v,e,M,Q]}
2019-01-29T08:05:57,843 | DEBUG | ActiveMQ Task-1 | FailoverTransport | 65 - org.apache.activemq.activemq-osgi - 5.14.5 | Connection established

Написано более трёх лет назад

Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации

Похожие вопросы

Java

+3 ещё

Средний
Пытаюсь подключиться к postgresql 16 через docker-compose, использую spring-boot 3.2.4, что не так?
- 1 подписчик
- вчера
- 123 просмотра
3

ответа
Java

+1 ещё

Простой
Как правильно внедрять зависимости в классы, зависящие от не-бинов?
- 1 подписчик
- 16 апр.
- 60 просмотров
1

ответ
Python

+1 ещё

Простой
Возможно ли соединить работающий java код и так же работающий скрипт python?
- 1 подписчик
- 15 апр.
- 203 просмотра
3

ответа
Java

+2 ещё

Простой
Как заставить Tomcat работать c utf-8 и кириллицей?
- 1 подписчик
- 14 апр.
- 53 просмотра
0

ответов
Java

+2 ещё

Простой
Как правильно вывести подблок с данными на странице?
- 1 подписчик
- 14 апр.
- 28 просмотров
1

ответ
PHP

+1 ещё

Простой
Как понять, что все сообщения в очереди обработаны?
- 2 подписчика
- 11 апр.
- 142 просмотра
0

ответов
Linux

+2 ещё

Средний
Можно ли задать различные права пользователя и java приложения в Linux?
- 1 подписчик
- 10 апр.
- 114 просмотров
2

ответа
Java

+1 ещё

Простой
Запуск Minecraft (1.12.2 Forge OptiFine из TLauncher) из консоли/командной строки/shell и т.д?
- 1 подписчик
- 10 апр.
- 78 просмотров
1

ответ
Java

+2 ещё

Простой
Каким образом формировать graphql запрос из кода (java, spring) используя dsl решения?
- 1 подписчик
- 09 апр.
- 39 просмотров
2

ответа
Java

+1 ещё

Простой
Почему отладчик Java в VS Cod после повторного запуска добавляет некорректный путь и автоматически вводит символ в терминал?
- 1 подписчик
- 08 апр.
- 57 просмотров
0

ответов
Показать ещё Загружается…

Lead Java

Bell Integrator • Ульяновск

До 400 000 ₽

Lead Java

Bell Integrator • Хабаровск

До 400 000 ₽

Lead Java

Bell Integrator • Ижевск

До 400 000 ₽

Спарсить ссылки на все товары конкретного продавца в озон

18 апр. 2024, в 20:13

2000 руб./за проект

Устранить проблемы с парсерами и отображением новостей

18 апр. 2024, в 20:08

7000 руб./за проект

Установить Windows и терминалы RDP на Dedicated Server (без лицензии)

18 апр. 2024, в 20:07

2000 руб./за проект

Answer 1 · 2019-01-28 16:34:58

Судя по коду, происходит создание коннекта. Скорее всего коннект закрывается, по каким причинам не знаю, и создается заново. Причем создается как "первое подключение" - https://github.com/apache/activemq/blob/0b71b06ac8... - строка 1052.

Activemq Successfully connected to tcp в логах?

Войдите, чтобы написать ответ

Минуточку внимания

Войдите на сайт