Адаптеры Hono не могут подключиться к enmasse

В настоящее время я устанавливаю hono вместе с enmasse поверх openshift / okd. Все идет нормально, кроме связи переходников с комплектом. Когда я, например, развертываю адаптер amqp (также происходит с адаптерами http и mqtt), я получаю следующие записи от адаптера hono:

12:25:45.404 [vert.x-eventloop-thread-0] DEBUG o.e.hono.client.impl.HonoClientImpl - starting attempt [#5] to connect to server [messaging-hono-default.enmasse-infra.svc:5672]
12:25:45.404 [vert.x-eventloop-thread-0] DEBUG o.e.h.c.impl.ConnectionFactoryImpl - connecting to AMQP 1.0 container [amqp://messaging-hono-default.enmasse-infra.svc:5672]
12:25:47.720 [vert.x-eventloop-thread-0] DEBUG o.e.h.c.impl.ConnectionFactoryImpl - can't connect to AMQP 1.0 container [amqp://messaging-hono-default.enmasse-infra.svc:5672]: connection timed out: messaging-hono-default.enmasse-infra.svc.cluster.local/172.30.83.158:5672
12:25:47.720 [vert.x-eventloop-thread-0] DEBUG o.e.hono.client.impl.HonoClientImpl - connection attempt failed
io.netty.channel.ConnectTimeoutException: connection timed out: messaging-hono-default.enmasse-infra.svc.cluster.local/172.30.83.158:5672
    at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:267)
    at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
    at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:125)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    at java.lang.Thread.run(Thread.java:748)
12:25:47.720 [vert.x-eventloop-thread-0] DEBUG o.e.h.c.impl.ConnectionFactoryImpl - can't connect to AMQP 1.0 container [amqp://messaging-hono-default.enmasse-infra.svc:5672]: connection timed out: messaging-hono-default.enmasse-infra.svc.cluster.local/172.30.83.158:5672
12:25:47.720 [vert.x-eventloop-thread-0] DEBUG o.e.hono.client.impl.HonoClientImpl - connection attempt failed
io.netty.channel.ConnectTimeoutException: connection timed out: messaging-hono-default.enmasse-infra.svc.cluster.local/172.30.83.158:5672
    at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:267)
    at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
    at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:125)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    at java.lang.Thread.run(Thread.java:748)

Журналы Enmasse следующие:

2019-01-07 12:36:24.962160 +0000 SERVER (info) [160]: Accepted connection to 0.0.0.0:5672 from 10.128.0.1:44664
2019-01-07 12:36:24.962258 +0000 SERVER (info) [160]: Connection from 10.128.0.1:44664 (to 0.0.0.0:5672) failed: amqp:connection:framing-error No valid protocol header found

Дополнительная информация:

  • Версия Hono: 0.8.x
  • Версия Enmasse: 0.24.1

Может кто-нибудь сказать мне, что мне не хватает?
Спасибо! PS: было бы неплохо, если бы кто-то с достаточной репутацией мог добавить новый тег "enmasse".


person Bob Claerhout    schedule 07.01.2019    source источник
comment
Вы следовали инструкциям на веб-сайте Hono по развертыванию в OpenShift / enMasse? Работает ли он с enMasse 0.20.0, как указано там?   -  person Kai Hudalla    schedule 08.01.2019
comment
Я выполнил инструкции на eclipse.org/hono/deployment/openshift_s2i. Я тестировал enmasse 0.24.0 (как указано на сайте). Можете ли вы предоставить ссылку, где упоминается использование 0.20.0?   -  person Bob Claerhout    schedule 08.01.2019


Ответы (1)


Я нашел решение этой проблемы.
Прежде всего: ошибки кадрирования - это не входящие соединения от hono. Я уже вижу это ведение журнала, когда enmasse устанавливается без установки hono. Я не знаю, откуда они. Если у кого-то есть идея, сообщите мне.
Что касается настоящей проблемы: похоже, мне нужно было разрешить связь между двумя проектами (enmasse-infra и hono). Это описано в документации Openshift.
< strong> TL; DR

  • Используемое решение: oc adm pod-network make-projects-global enmasse-infra. Я использовал это, потому что фреймворк enmasse должен быть доступен для всех проектов (включая hono, но также и наше настраиваемое серверное приложение).
  • Также должно работать (не тестировалось): oc adm pod-network join-projects --to=enmasse-infra hono
person Bob Claerhout    schedule 08.01.2019