如何使用Spring Reactive WebSocket并将其转换为Flux流？
Spring documentation上有一些WebSocketClient示例： WebSocketClient client = new ReactorNettyWebSocketClient(); client.execute("ws://localhost:8080/echo"), session -> {...}).blockMillis(5000); 我不确定如何处理传入数
..
spring-websocket相关内容
Websockets、SockJs、Stomp、Spring、RabbitMQ，自动删除用户特定队列
我希望有人可以帮助我解决这个问题.我正在使用带有 SockJs 和 StompJs 的 Spring 的 Websocket 支持.我订阅了这样的队列: var socket = new SockJS(localhost + 'websocket');stompClient = Stomp.over(socket);stompClient.connect('', '', function(fr
..
Spring:向 websocket 客户端发送消息
我正在构建一个使用 Spring Boot、RabbitMQ 和 WebSocket 作为 POC 的网络聊天，但我被困在最后一点:WebSockets 我希望我的 ws 客户端连接到特定端点，例如 /room/{id} 并且当新消息到达时，我希望服务器将响应发送给客户端，但我搜索了类似的东西并没有找到. 目前，当消息到达时，我使用RabbitMQ对其进行处理，例如 container.
..
SockJS Python 客户端
我有一个依赖 Websockets 的网站 (Java + Spring) (Stomp over Websockets for Spring + RabbitMQ + SockJS) 用于某些功能. 我们正在创建一个基于 Python 的命令行界面，我们希望添加一些使用 websockets 已经可用的功能. 有谁知道如何使用 python 客户端以便我可以使用 SockJS 协议进
..
Java SockJS Spring 客户端和消息大小
使用 SockJS java 客户端，我正在尝试连接到 Spring sockjs 服务器，但对于 ~20Kb 的消息(没有标头)收到错误 1009.Javascript 库运行良好. Transport closed with CloseStatus[code=1009, reason=解码的短信太大了WebSocketClientSockJsSession 中的输出缓冲区和端点不支持部分消息
..
Wildfly 中的 Spring Boot Websockets
您好，我需要将 Spring Boot 应用程序部署到 Wildfly 8.1 中，但出现以下异常: Caused by: java.lang.RuntimeException: java.lang.ClassCastException: org.apache.tomcat.websocket.server.WsServerContainer cannot be cast to io.und
..
是否可以使用 Spring-WebSockets 通过 WebSockets 通过 STOMP 发送二进制数据?
我能够按照 spring 文档.然而，在高速率下性能很差，所以我想分析一下二进制消息的使用. Spring-WebSockets 4.0 在 Chrome 35 中运行的 JavaScript 客户端 stomp.js 1.7.1 发送 我使用 SimpMessageTemplate 和必要的代理中继发送消息 - 参见 spring 文档 @Controller公共类 De
..
Spring WebSocket:由于升级标头无效，握手失败:空
我正在使用 wss(安全 Web 套接字)与后端的 spring 和 STOMP 的 javascript 客户端. 有谁知道为什么要得到: 由于升级标头无效，握手失败:空 解决方案 我在 nginx https 代理 to tomcat 时遇到了同样的问题.这是因为我还没有支持 wss 请求.为了支持 wss 请求，我使用如下配置: # WebSocketSecure SSL 端点
..
如何为 spring sockjs websocket 服务器实现增加输出缓冲区
我使用了sockjs websocket server的spring实现，无法传输超过8KB的消息，错误如下 2014-02-12 19:36:29,990 - org.springframework.web.socket.sockjs.transport.session.WebSocketServerSockJsSession - DEBUG - SockJS session id=35n41
..
连接到 websocket 时我得到状态 200，但这是一个错误?
我的错误显示在浏览器的控制台中: “WebSocket 连接到 'ws://localhost:32768/DspClusterWebServices/myHandler' 失败:意外响应代码:200" 我正在使用 Spring Websockets 4.1.5 和 Tomcat 8.0.18.我的 WebSocketConfigurer 实现类如下所示: @Configuratio
..
Spring Websockets @SendToUser 无需登录?
我有一个带有 websocket 功能的简单 spring 应用程序，到目前为止一切正常.现在我想使用 @SendToUser 注释从我的服务器向特定客户端发送一条消息.这给了我错误“忽略消息，没有可用的主要信息".我知道我的服务器上没有任何登录信息，所以每个用户都是“匿名的"并且没有主体(我现在不使用 spring 安全性).但是每个用户都有一个会话 ID.是否可以以某种方式使用会话 ID 来区
..
如何正确地从 Spring WebFlux 中的多个 Fluxes (WebsocketSession::receive) 向 Sink 发出值?
在我的简化案例中，我想将 WebSocket 客户端发送的消息广播给所有其他客户端.该应用程序是使用响应式 websockets 和 Spring 构建的. 我的想法是使用单Sink 并且如果从客户端收到消息，则在此接收器上发出它.WebsocketSession::send 只是将这个 Sink 发出的事件转发给连接的客户端. @Component类 ReactiveWebSocketH
..
使用 Websockets 代替 RESTful HTTP 有哪些陷阱?
我目前正在处理一个项目，该项目需要客户端请求一个大作业并将其发送到服务器.然后服务器将作业划分并以一组 url 响应，以便客户端进行 GET 调用并将数据流回.我是该项目的新手，目前正在使用 Spring websockets 来提高效率.与客户端不断地 ping 服务器以查看它是否有准备回传的结果不同，websocket 现在将直接联系客户端万岁！ 让 websockets 从头到尾管理整
..
在 Spring Websocket 上向特定用户发送消息
如何仅从服务器向特定用户发送 websocket 消息? 我的 webapp 有 spring 安全设置并使用 websocket.我在尝试从服务器向仅特定用户发送消息时遇到了棘手的问题. 我对阅读的理解手册来自我们可以做的服务器 simpMessagingTemplate.convertAndSend("/user/{username}/reply", reply); 在客户端:
..
Spring websocket - 集群中的 sendToUser 在备份服务器上不起作用
我们有一个 spring mvc，配置了 spring websocket('spring-websocket'，版本:'4.1.0.RELEASE'). 我们有一个执行以下代码的简单类: @Autowired私人 SimpMessagingTemplate 模板；@覆盖public void push(Long userId, Object message, WebsocketQueu
..
无法使用 Spring Websocket 发送用户消息
我阅读了有关用户目的地的 Spring 文档.我想使用 convertAndSendToUser 方法只向特定用户发送消息. 这是java代码: @Controller公共类 WebsocketTest {@自动连线公共 SimpMessageSendingOperations 消息模板；@PostConstruct公共无效初始化(){ScheduledExecutorService st
..
如何对 Spring WebSocketStompClient 进行单元测试
我有一个 Stompclient，它连接到 Spring 引导服务器并执行一些订阅.此 websocket 客户端的代码覆盖率为 0%.我只能找到有关如何对 Spring Boot Websocket 服务器进行单元测试的代码示例.但这是客户端验证 Stompclient 工作正常.如果我的问题缺少任何细节，请告诉我. 这是我需要为其编写单元测试用例的示例连接方法. StompSessio
..
spring-mvc、websockets推送集成
我已经点击了这个链接 http://spring.io/guides/gs/messaging-stomp-websocket/ 并启动并运行应用程序. 我想要的远不止这些，我希望能够将数据推送回客户端，而客户端无需发送任何东西. 所以我用类似于下面的监听器设置了一个长时间运行的任务 GreetingController 实现 RunnableListener并且 Runnabl
..
Websockets:是否可以使用 SockJS 添加多个端点?
我想创建 2 个网络套接字端点.你能说有可能吗? 在那种情况下应该是什么配置? 解决方案 您的问题没有明确说明您使用的是普通 websocket 还是 STOMP 消息传递. 普通的 websocket API 如果您使用普通的 websocket API，注册 API 允许您添加任意数量的 websocket 处理程序. @Configuration@EnableWe
..
Spring websockets SockJS 回退协议不是开箱即用的吗?
我用 spring boot 制作了一个支持 websockets 的应用程序.一切都是工作得很好.我正在使用 SockJS + Stomp.不用担心.它只是工作.但现在我想支持 SockJS 使用其回退协议的能力.和似乎它不是开箱即用的. 这是我添加端点的方式: @Overridepublic void registerStompEndpoints(StompEndpointRegist
..