我是websockets的新手,我创建了一个使用Camel接收websocket消息的spring-boot应用程序。websocket服务器是使用Python创建的。我已经在Chrome上使用PieSocket测试了服务器,并能够接收消息。然而,我在接收camel应用程序上的消息时遇到了问题。下面是我的服务器和客户端代码。
Websocket服务器
import asyncio import websockets # create handler for each connection async def handler(websocket, path): while True: greeting = f"Hello user!" await websocket.send(greeting) print(f"> {greeting}") await asyncio.sleep(10) start_server = websockets.serve(handler, "localhost", 8000) asyncio.get_event_loop().run_until_complete(start_server) asyncio.get_event_loop().run_forever()
Java客户端
package example.org.websocket.route; import org.apache.camel.builder.RouteBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; @Component public class DataRoute extends RouteBuilder { @Override public void configure() { from("websocket://localhost:8000") .log("Received message: ${body}"); } }
任何帮助都是有用的。非常感谢。