- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
这是我的代码,它仅适用于我所在的选项卡。我收到了回复,似乎一切正常,但我仍然不完全了解该技术的操作,这就是我去找你的原因。
它以“responseHanlder”结尾
connect() {
// backend ws endpoint
const wsURL = "ws://localhost:6565/rsocket";
// rsocket client
const client = new RSocketClient({
serializers: {
data: JsonSerializer,
metadata: IdentitySerializer,
},
setup: {
keepAlive: 60000,
lifetime: 180000,
dataMimeType: "application/json",
metadataMimeType: "message/x.rsocket.routing.v0",
},
transport: new RSocketWebSocketClient({
url: wsURL,
}),
});
client.connect()
.then((sock) => {
document.getElementById("connect")
.addEventListener("click", (event) => {
numberRequester(sock);
});
}, errorHanlder);
/*Aquí comienza el código del primer socket para insertar un producto
antes de enviar la notificación primero realiza una acción*/
const numberRequester = (socket) => {
socket
.requestResponse({
data: {
id: null,
subscriber: retrieveData.id,
titulo: "Se insertó un nuevo producto",
descripcion:
"Aquí se agrega una descripcion breve de lo que se acaba de hacer (opcional)",
fecha_inicio: today,
fecha_final: final,
leido: false,
},
metadata:
String.fromCharCode("insert.notification".length) +
"insert.notification",
})
.subscribe({
onComplete: responseHanlder,
onError: errorHanlder,
onNext: responseHanlder,
onSubscribe: (subscription) => {
//subscription.request(100); // set it to some max value
},
});
}
// error handler
const errorHanlder = (e) => console.log(e);
// response handler
const responseHanlder = (payload) => {
this.sendNotification(payload.data);
};
}
发送数据后,我的 rsocket 接收信息,然后我收到包含所需数据的响应。目前,它仅适用于运行它的选项卡,但我需要在其他选项卡中反射(reflect)该信息,因为它是通知的原型(prototype)。
最佳答案
RSocket 是有状态的、面向 session 的应用协议(protocol)
这意味着,每次您的 RSocket 客户端连接到服务器时,它都会打开一个连接并通过它与您的服务器进行通信。
如果客户端是浏览器,出于安全原因,其他浏览器 session 将无法访问您的连接。
如何通过 rsocket 广播消息
实际上,在浏览器的情况下,您可以使用 2 个选项:
经纪人类型的消息传递
您始终可以连接到单个中介服务器,这将确保您的消息被广播到所有目的地。
您可以在 Spring Tutorials 找到这样的应用示例。
使用 WebRTC 传输的 Brokerless 消息传递(实验性的,未正式发布)
我们进行了几次将 WebRTC(以及普通的 WebSocket)传输引入浏览器通信的实验。
请找到那些实验here .如果您认为需要,请尝试并在我们的问题跟踪器上分享您对此传输支持的反馈/投票。
关于vue.js - 如何将 RSocket 数据检索到不同的选项卡?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/69089492/
如何设置路由元数据(在服务器使用 Spring Boot Rsocket 时仅使用 RSocket-Java 的有效负载。Flux s = connection.flatMapMany(request
好的,我是 RSocket 的新手。我正在尝试创建一个简单的 RSocket 客户端和简单的 RSocket 服务器。从我所做的研究来看,RSocket 支持恢复: 它特别有用,因为当发送包含有关最后
我对 RSocket 完全陌生。 我阅读了常见问题解答和动机页面(并浏览了协议(protocol)页面)并了解 RSocket 可以在 TCP、WebSocket 和 Aeron 之上使用。但是我不明
我正在尝试在 Vue 中创建一个站点并在 Spring 上创建后端。我想使用 rsocket 来传输数据,但是只要我在 spring 中添加 rsocket seurity,我就会得到: 'metad
我在通过 TCP 连接到 Spring Boot RSocket 应用程序时遇到问题。使用 RSocketRequester 时的客户端工作正常,但是当我尝试使用 RSocketFactory 客户端
Is it somehow possible to use Spring's RSocket integration in a "traditional" servlet-b
目录 0. RSocket 简介 1. 服务端 1.1 SETUP阶段 - 处理客户端发起的连接请求
Source Code: https://github.com/joexu01/rsocket-demo 0. 四种通信模式 让我们来简单复习一下 RSocket 的四种通信模式:
1. 编写客户端接收请求的逻辑 我们可以在初始化 Rsocket 实例的时候指定客户端可以被调用的方法,使用 acceptor() 指定可被调用的方法和方法使用的通信模型类型:
rsocket 似乎是个很酷的主意。我有这个问题,但找不到更好的答案。 让我们考虑这个初始设置。客户端依次向server-1发送多个请求。 client --> server-1 server-1 正
我已经使用rsocket编写了简单的客户端和服务器程序-使用以下版本的librdmacm-dev和librdmacm1软件包(使用Ubuntu 14.04)的RDMA套接字API: librdmacm
在我的项目中,我希望有多个客户端连接到一个服务。我正在使用 java Rsocket 实现。 服务应该为每个客户端维护一个状态。现在在这一点上,我可以通过一些标识符来管理客户端。这个选项我已经实现了。
这是我的代码,它仅适用于我所在的选项卡。我收到了回复,似乎一切正常,但我仍然不完全了解该技术的操作,这就是我去找你的原因。 它以“responseHanlder”结尾 connect() {
有人可以告诉我或使用 提供现成的 CRUD 示例吗? WebFlux、RScoket 和 Spring(或 SpringBoot) ? 我研究了 RSocket 文档, WebFlux ,也写了我的简
我必须再次回到 Symbian 中的套接字。建立与远程服务器的连接的代码如下所示: TInetAddr serverAddr; TUint iPort=111; TRequestStatus iS
我似乎无法在 RSocket 上找到任何资源/教程,除了阅读他们在 GitHub 上的代码,我不明白。 我的服务器上有一个文件路径:String serverFilePath; 我希望能够从我的客户端
假设我有这个用于聊天消息的简单 Websocket 处理程序: @Override public Mono handle(WebSocketSession webSocketSession) {
我正在尝试为我的服务器编写一个客户端(在 Kotlin 和使用 Spring Reactive Web 中)。我在尝试使用 RSocket 时遇到了这个问题。如何使用 RSocket 获得 Flux?
我正在使用 Spring 对 RSocket 的支持,特别是请求流模型。 IE。: @MessageMapping("stream") Flux stream(final SubscriptionMe
解决摘要: 在目前的大多数 RSocket 示例中,即使在 SpringBoot 相关教程中,服务器端接受器也被简单地构造为一个新对象(如下面的 new MqttMessageService() )。
我是一名优秀的程序员,十分优秀!