首页 > 解决方案 > 使用空手道 DSL 重用 websocket 连接

问题描述

使用 Websocket,您通常不会连续打开和关闭连接,这就是为什么我尝试对功能文件中的所有测试使用相同的 Websocket + 我的编程逻辑也需要这样做,因为我目前不支持逻辑会话网络套接字。

我尝试了以下不同的变体(callcallonce),但它对我不起作用。

Feature: Notify about created fixtures

    Background:
        * def openWs = call read ('classpath:openWebsocket.js')
        * def ws = callonce openWs

    Scenario: Request a new session
        * def createSessionRequest = { 'action': 'POST', 'resource': 'sessions', 'requestId': 'df9a64de-3c22-40f8-807a-7eba5a432c95', 'version': 1 }

        * string createSessionRequest = createSessionRequest
        * eval ws.send(createSessionRequest)

        * json response = karate.listen(5000)
        * match response == { requestId: 'df9a64de-3c22-40f8-807a-7eba5a432c95', status: 201, version: 1, payload: { sessionId: '#string' } }

    Scenario: Subscribe for fixture updates
        * def subscribeFixtureRequest = { 'action': 'SUB', 'resource': 'fixtures', 'requestId': 'fa9eb7a5-d658-4f4b-bfa5-bc3bf2909cf3', 'version': 1 }

        * string subscribeFixtureRequest = subscribeFixtureRequest
        * eval ws.send(subscribeFixtureRequest)

        * json response = karate.listen(5000)
        * match response == { requestId: 'fa9eb7a5-d658-4f4b-bfa5-bc3bf2909cf3', status: 200, version: 1 }

看起来它缓存了 websocket 实例,但在第一个场景之后它仍然关闭它,因此第二个场景失败。

日志如下所示(删除了一些不相关的行):

19:42:13.003 [main] TRACE com.intuit.karate - callonce waiting for lock: openWs
19:42:13.003 [main] INFO  com.intuit.karate - >> lock acquired, begin callonce: openWs
19:42:13.083 [nioEventLoopGroup-3-1] DEBUG c.i.k.netty.WebSocketClientHandler - websocket client connected
19:42:13.083 [main] INFO  com.intuit.karate - << lock released, cached callonce: openWs
19:42:13.092 [main] TRACE c.i.karate.netty.WebSocketClient - sent: {"action":"POST","resource":"sessions","requestId":"df9a64de-3c22-40f8-807a-7eba5a432c95","version":1}
19:42:13.093 [main] TRACE com.intuit.karate - entered listen wait state
19:42:13.169 [nioEventLoopGroup-3-1] TRACE c.i.k.netty.WebSocketClientHandler - websocket received text
19:42:13.169 [nioEventLoopGroup-3-1] TRACE com.intuit.karate - signal called: {"payload":{"sessionId":"ee542db6-808c-4100-b009-f9e22dce28db"},"requestId":"df9a64de-3c22-40f8-807a-7eba5a432c95","status":201,"version":1}
19:42:13.170 [main] TRACE com.intuit.karate - exit listen wait state, result: {"payload":{"sessionId":"ee542db6-808c-4100-b009-f9e22dce28db"},"requestId":"df9a64de-3c22-40f8-807a-7eba5a432c95","status":201,"version":1}
19:42:13.203 [nioEventLoopGroup-3-1] DEBUG c.i.k.netty.WebSocketClientHandler - websocket closing
19:42:13.204 [nioEventLoopGroup-3-1] DEBUG c.i.k.netty.WebSocketClientHandler - websocket client disconnected
19:42:13.249 [main] TRACE com.intuit.karate - callonce cache hit for: openWs
19:42:13.256 [main] TRACE c.i.karate.netty.WebSocketClient - sent: {"action":"SUB","resource":"fixtures","requestId":"fa9eb7a5-d658-4f4b-bfa5-bc3bf2909cf3","version":1}
19:42:13.257 [main] TRACE com.intuit.karate - entered listen wait state
19:42:18.257 [main] TRACE com.intuit.karate - exit listen wait state, result: null

有没有办法自己控制websocket的打开和关闭?

编辑:我检查了源代码,不幸的是它非常紧密地绑定到ScenarioExecutionUnit,这在Scenario. 似乎有必要对空手道进行代码更改来支持这一点。

标签: websocketkarate

解决方案


空手道将来会支持这个:https ://github.com/intuit/karate/issues/718


推荐阅读