我是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}");
}
}
任何帮助都是有用的。非常感谢。