- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在使用 Spring Integration 5.1.7.RELEASE
、Spring Boot 2.1.7.RELEASE
和 Spring Integration Test 5.0.11 开发一个项目.RELEASE
.
作为测试的一部分,我正在尝试单元测试
IntegrationFlow
,它执行对不同MessageHandlers
的调用,所以我mocking
它们使用来自 Spring Integration Test
的 MockIntegrationContext
。
我的代码在我们的 Jenkins 服务器上出现间歇性问题,这似乎与缓存的上下文有关。我有一个没有模拟的集成测试 (@SpringBootTest
) 和一个专门针对 IntegrationFlow
的测试类,其中模拟了 MessageHandlers
。
如果之前运行了集成测试并且缓存了上下文,则 MockIntegrationContext
执行的设置似乎没有效果,底层的 service-activator
被调用,甚至当日志显示它已取消订阅并且模拟已订阅该 channel 时。
下面是轮询器和句柄端点的定义:
@Configuration
public class FlowConfig {
@Bean
public IntegrationFlow fileFlow() {
return IntegrationFlows.from(
Files.inboundAdapter(new File(fileDir)).autoCreateDirectory(true).preventDuplicates(false),
e -> e.poller(Pollers.fixedDelay(pollingFrequency)).id("fileInboundSourceEndpoint").get())
...
.handle(fileParseHandler, e -> e.id("fileParseHandlerEndpoint"))
...
.get()
}
}
这是测试设置:
@RunWith(SpringRunner.class)
@ContextConfiguration(classes = FlowConfig.class)
@SpringIntegrationTest
@EnableIntegration
public class FlowConfigTest {
@Autowired
MockIntegrationContext mockIntegrationCtx;
@Test
public void test_fileFlow() throws IOException {
mockIntegrationCtx.substituteMessageHandlerFor("fileParseHandlerEndpoint",
MockIntegration.mockMessageHandler().handleNextAndReply(m -> m));
new File(fileDir + "test").createNewFile();
}
}
这是两组不同的日志,分别来自一次不成功和一次成功的测试执行:
2019-09-09 15:17:02.059 INFO 14462 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Removing {service-activator:fileParseHandlerEndpoint} as a subscriber to the 'fileFlow.channel#2' channel
2019-09-09 15:17:02.059 INFO 14462 --- [ main] o.s.integration.channel.DirectChannel : Channel 'org.springframework.context.support.GenericApplicationContext@51f95f0d.fileFlow.channel#2' has 0 subscriber(s).
2019-09-09 15:17:02.059 INFO 14462 --- [ main] o.s.i.endpoint.EventDrivenConsumer : stopped fileParseHandlerEndpoint
2019-09-09 15:17:02.062 INFO 14462 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {message-handler:fileParseHandlerEndpoint} as a subscriber to the 'fileFlow.channel#2' channel
2019-09-09 15:17:02.062 INFO 14462 --- [ main] o.s.integration.channel.DirectChannel : Channel 'org.springframework.context.support.GenericApplicationContext@51f95f0d.fileFlow.channel#2' has 1 subscriber(s).
2019-09-09 15:17:02.062 INFO 14462 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started fileParseHandlerEndpoint
...
2019-09-09 15:17:03.731 DEBUG 14462 --- [ scheduling-1] o.s.i.file.FileReadingMessageSource : Added to queue: [/tmp/file]
2019-09-09 15:17:03.732 DEBUG 14462 --- [ scheduling-1] o.s.i.e.SourcePollingChannelAdapter : Poll resulted in Message: GenericMessage [payload=/tmp/file, headers={file_originalFile=/tmp/file, id=4323b036-4edd-019e-2c61-6917c7970767, file_name=file, file_relativePath=file, timestamp=1568056623732}]
...
2019-09-09 15:17:03.732 DEBUG 14462 --- [ scheduling-1] o.s.integration.channel.DirectChannel : preSend on channel 'fileFlow.channel#2', message: GenericMessage [payload=/tmp/file, headers={file_originalFile=/tmp/file, errorChannel=error_channel, id=af997a89-40d6-9024-65fc-7ab3883c329b, file_name=file, file_relativePath=file, timestamp=1568056623732}]
2019-09-09 15:17:03.732 DEBUG 14462 --- [ scheduling-1] o.s.i.handler.ServiceActivatingHandler : ServiceActivator for [org.springframework.integration.handler.MethodInvokingMessageProcessor@7b4acdc2] (fileParseHandlerEndpoint) received message: GenericMessage [payload=/tmp/file, headers={file_originalFile=/tmp/file, errorChannel=error_channel, id=af997a89-40d6-9024-65fc-7ab3883c329b, file_name=file, file_relativePath=file, timestamp=1568056623732}]
[Fatal Error] file:1:1: Premature end of file.
13:41:05.126 [main] INFO o.s.i.endpoint.EventDrivenConsumer - Removing {service-activator:fileParseHandlerEndpoint} as a subscriber to the 'fileFlow.channel#2' channel
13:41:05.126 [main] INFO o.s.i.channel.DirectChannel - Channel 'org.springframework.context.support.GenericApplicationContext@6fb365ed.fileFlow.channel#2' has 0 subscriber(s).
13:41:05.126 [main] INFO o.s.i.endpoint.EventDrivenConsumer - stopped fileParseHandlerEndpoint
13:41:05.128 [main] INFO o.s.i.endpoint.EventDrivenConsumer - Adding {message-handler:fileParseHandlerEndpoint} as a subscriber to the 'fileFlow.channel#2' channel
13:41:05.128 [main] INFO o.s.i.channel.DirectChannel - Channel 'org.springframework.context.support.GenericApplicationContext@6fb365ed.fileFlow.channel#2' has 1 subscriber(s).
13:41:05.128 [main] INFO o.s.i.endpoint.EventDrivenConsumer - started fileParseHandlerEndpoint
...
13:41:06.775 [task-scheduler-1] DEBUG o.s.i.file.FileReadingMessageSource - Added to queue: [/tmp/file]
13:41:06.775 [task-scheduler-1] DEBUG o.s.i.e.SourcePollingChannelAdapter - Poll resulted in Message: GenericMessage [payload=/tmp/file, headers={file_originalFile=/tmp/file, id=3bb52d11-49ad-3ea8-eb67-7e6da721022a, file_name=file, file_relativePath=file, timestamp=1568050866775}]
...
13:41:06.788 [task-scheduler-1] DEBUG o.s.i.channel.DirectChannel - preSend on channel 'fileFlow.channel#2', message: GenericMessage [payload=/tmp/file, headers={file_originalFile=/tmp/file, errorChannel=error_channel, id=ec6b0213-8109-ae43-ac27-d17b1bbad8aa, file_name=file, file_relativePath=file, timestamp=1568050866777}]
13:41:06.789 [task-scheduler-1] DEBUG o.s.i.test.mock.MockMessageHandler - org.springframework.integration.test.mock.MockMessageHandler$MockitoMock$1634676946@76fb98a2 received message: GenericMessage [payload=/tmp/file, headers={file_originalFile=/tmp/file, errorChannel=error_channel, id=ec6b0213-8109-ae43-ac27-d17b1bbad8aa, file_name=file, file_relativePath=file, timestamp=1568050866777}]
我知道可能有 @DirtiesContext
的组合应该可以解决这个问题,但我仍在努力理解为什么 MockIntegrationContext
无法模拟 MessageHandlers
来自缓存的上下文。
有什么方法可以在不使用 @DirtiesContext
的情况下解决这个问题?
最佳答案
首先,当你使用Spring Boot时,你需要依赖它的版本管理。此外,当您按原样使用 Spring Integration 时,请考虑使用 spring-integration-bom
进行导入。这样你就不需要为单个模块指定版本。
我的观点是,spring-integration-core
和 spring-integration-test
有不同的版本。他们必须相同。否则,您可能会在运行时遇到一团糟。
现在谈谈这个主题。
我认为这不是缓存问题。
此测试套件的应用程序上下文启动与目标测试方法中的 mockIntegrationCtx.substituteMessageHandlerFor()
之间存在竞争条件。
问题来自于您从 e.poller(Pollers.fixedDelay(pollingFrequency)
开始流程这一事实。这个流程由后台的 TaskScheduler
处理,并且独立于测试套件的主线程生成消息。这就是您观察到意外行为的原因。
您可以通过类似autoStartup
的操作来解决这个问题。 @SpringIntegrationTest
为您准备了这个:
/**
* Specify a simple matching patterns ("xxx*", "*xxx", "*xxx*" or "xxx*yyy") for
* {@link org.springframework.integration.endpoint.AbstractEndpoint}
* bean names to mark them as {@code autoStartup = false}
* during context initialization.
* @return the endpoints name patterns to stop during context initialization
* @see IntegrationEndpointsInitializer
* @see org.springframework.util.PatternMatchUtils
*/
String[] noAutoStartup() default {};
所以,你这样做:
@SpringIntegrationTest(noAutoStartup = "fileInboundSourceEndpoint")
然后在测试中你自动连接一个 channel 适配器:
@自动连线private SourcePollingChannelAdapter fileInboundSourceEndpoint;
在 substituteMessageHandlerFor()
之后启动它:
this.fileInboundSourceEndpoint.start();
关于java - MockIntegrationMessage 在缓存上下文时不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57861091/
出现以下错误 Network access for Distributed Transaction Manager (MSDTC) has been disabled. Please enable D
在调试应用程序时出现以下错误。 The CLR has been unable to transition from COM context 0x3b2d70 to COM context 0x3b2
在 GAE Go 中,为了记录,我们需要使用 appengine.NewContext(r) 创建一个新的上下文,它返回 context.Context。 如何使用此上下文在请求范围内设置/获取变量?
我想使用 Puppeteer 从放置在页面上 iframe 内的选择器中获取数据,该页面在与其父框架域不同的域上运行。因此,我不是任何域的所有者 - 无法使用 frame.postMessage。 试
我正在尝试获取可用的应用程序上下文并想切换到 webview 上下文,但 appium 仅获取 Navive App。 应用程序还启用了 WebView。 Appium 版本:1.10.1 Chrom
这个问题在这里已经有了答案: How to fix this nullOk error when using the flutter_svg package? (7 个回答) 7 个月前关闭。 当我尝
我观看了关于 Core Data 的 2016 WWDC 视频并查看了各种教程。我见过使用 Core Data Framework 创建对象以持久保存到 managedObjectContext 中的
这是代码 obj = { a: 'some value'; m: function(){ alert(this.a); } } obj.m(); 结果是'som
我正在尝试做类似的事情 $(".className").click(function() { $(this).(".anotherClass").css("z-index","1");
var User = { Name: "Some Name", Age: 26, Show: function() { alert("Age= "+this.Age)}; }; fun
我目前正在使用我见过的常见 Context 模式,它允许子组件通过传递修饰函数来更新父组件的状态(即 Provider)通过共享的 Context。 我遇到的问题是,修改函数只引用原始状态,不引用最新
有没有办法让 React Context类型安全与流类型? 例如: Button.contextTypes = { color: React.PropTypes.string }; 最佳答案 不幸
我想知道是否有一种方法可以为不同的功能使用不同的上下文类。 我希望有一个功能使用 MinkExtensions 进行浏览器测试,另一个功能使用和 HTTP 客户端(如 Guzzle)进行 API 测试
我有这个配置文件 apiVersion: v1 clusters: - cluster: server: [REDACTED] // IP of my cluster name: stag
我在实现非抢先式调度时遇到了用于初始化TCB的代码。 typedef struct TCB_t { struct TCB_t *next; struct TCB_t
我想将一个函数设置为数组中每个元素的属性,但使用不同的参数调用它。我想我会使用匿名函数来解决它: for ( var i = 0; i < object_count; i++ ) { obje
这个问题已经有答案了: How to access the correct `this` inside a callback (15 个回答) 已关闭 7 年前。 我正在做一些练习,但我在管道方法中丢
我正在尝试通过 Java 和 Android Studio 学习和制作 Android 应用程序。我对Java的了解程度是两年前几个小时的youtube学习和大学基础类(class)。不过我确实知道如
我在(这个)上遇到了问题。错误ImageView无法应用。我在 fragment 类中执行此代码。 ViewFlipper v_flipper; @Nullable @Override public
我想使用 openGL 的某些功能,但与渲染视觉内容无关。有没有办法在没有任何依赖性的情况下创建它(不是对 Windows,也不是某些包[SDL,SFML,GLUT])?只允许使用没有外部库的库,就像
我是一名优秀的程序员,十分优秀!