Невозможно использовать встроенный брокер сообщений Spring для тестирования - PullRequest
Новая
       36

Невозможно использовать встроенный брокер сообщений Spring для тестирования

0 голосов
/ 18 сентября 2018

У меня есть следующий компонент, который используется для отправки сообщений брокеру (kafka), а также получения StreamListener из spring-cloud. Теперь мне нужно написать тест, в котором я отправляю сообщение встроенному брокеру, а также проверяю, получено ли сообщение. Вот мой компонент: 

@Component
public class FooMessaging {

    @Autowired
    private Processor processor;

    public void sendMsg(FooMsg msg) {        
        // some logic
        processor.output().send(MessageBuilder.withPayload(msg).build());
        // some logic
    }

    // and handler:

    @StreamListener(value = Processor.INPUT)
    public void handler(FooMsg msg) {
       threadSafeMap.put(msg.getId(), msg.getBody());
    }
}

конфиг: 

@EnableBinding(Processor.class)
public class BrokerConfig {
}

А вот мой пример теста, где я попробовал просто проверить, не является ли моя автопроводка нулевой, и затем я хочу отправить сообщение в выходной канал и получить его через встроенный брокер сообщений поддержки весеннего тестирования облака. Можете ли вы сказать мне, как это сделать? Я просто попытался запустить следующий код: 

@RunWith(SpringRunner.class)
@SpringBootTest(classes = {BrokerConfig.class})
public class BokerTest {
    @Autowired
    private Processor processor;

    @Test
    public void sampleTest() {
        assertNotNull(processor);
    }
}

но я получил это исключение, и я не могу продолжить: 

java.lang.IllegalStateException: Failed to load ApplicationContext

    at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:124)
    at org.springframework.test.context.support.DefaultTestContext.getApplicationContext(DefaultTestContext.java:83)
    at org.springframework.test.context.web.ServletTestExecutionListener.setUpRequestContextIfNecessary(ServletTestExecutionListener.java:189)
    at org.springframework.test.context.web.ServletTestExecutionListener.prepareTestInstance(ServletTestExecutionListener.java:131)
    at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:230)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:228)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:287)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.methodBlock(SpringJUnit4ClassRunner.java:289)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:247)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
    at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191)
    at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
    at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
    at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47)
    at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
    at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
Caused by: org.springframework.context.ApplicationContextException: Failed to start bean 'outputBindingLifecycle'; nested exception is org.springframework.cloud.stream.binder.BinderException: Exception thrown while building outbound endpoint
    at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:176)
    at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:50)
    at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:346)
    at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:149)
    at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:112)
    at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:880)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546)
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693)
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:303)
    at org.springframework.boot.test.context.SpringBootContextLoader.loadContext(SpringBootContextLoader.java:121)
    at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContextInternal(DefaultCacheAwareContextLoaderDelegate.java:98)
    at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:116)
    ... 25 more
Caused by: org.springframework.cloud.stream.binder.BinderException: Exception thrown while building outbound endpoint
    at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:137)
    at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:66)
    at org.springframework.cloud.stream.binder.AbstractBinder.bindProducer(AbstractBinder.java:138)
    at org.springframework.cloud.stream.binding.BindingService.bindProducer(BindingService.java:124)
    at org.springframework.cloud.stream.binding.BindableProxyFactory.bindOutputs(BindableProxyFactory.java:238)
    at org.springframework.cloud.stream.binding.OutputBindingLifecycle.start(OutputBindingLifecycle.java:57)
    at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:173)
    ... 37 more
Caused by: org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 10000
    at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1232)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:156)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:130)
    at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:76)
    at kafka.utils.ZkUtils$.apply(ZkUtils.scala:58)
    at kafka.utils.ZkUtils.apply(ZkUtils.scala)
    at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopicAndPartitions(KafkaTopicProvisioner.java:171)
    at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopicsIfAutoCreateEnabledAndAdminUtilsPresent(KafkaTopicProvisioner.java:153)
    at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:108)
    at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:60)
    at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:119)
    ... 43 more

У меня также есть эта зависимость в pom.xml: 

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-test-support</artifactId>
        <scope>test</scope>
    </dependency>

EDIT: Я узнаю, когда у меня запущен образ докера с zookeeper и тестами kafka. Так что проблема в том, что пружина не использует встроенный, но ищет пульт.

1 Ответ

0 голосов
/ 18 сентября 2018

Если вы хотите провести тестирование со встроенным брокером Kafka, вы можете проверить, как выполняется тестирование / настройка в KafkaBInder .Простое добавление spring-cloud-stream-test-support не сработает.

Однако вы также можете добавить новый (упрощенный) TestBinder.Вот инструкции о том, как настроить его в вашем Pom / Gradle https://github.com/spring-cloud/spring-cloud-stream/pull/1241

ПРИМЕЧАНИЕ. Удалите поддержку spring-cloud-stream-test-support из вашего POM / Gradle

.,и вот фрагмент кода для вашего теста: `` `открытый класс DemoRabbit174ApplicationTests {

@Test
public void test() {
    ApplicationContext context = SpringApplication.run(new Class[] {MyConfiguration.class, 
            TestChannelBinderConfiguration.class}, new String[] {});
    InputDestination source = context.getBean(InputDestination.class);
    source.send(new GenericMessage<byte[]>("Hello".getBytes()));
}

@EnableAutoConfiguration
@EnableBinding(Sink.class)
public static class MyConfiguration {

    @StreamListener("input")
    private void sink(String string) {
        System.out.println(string);
    }
}

}` ``

...