Я пытаюсь реализовать сервер RSocket на Java и клиент на JavaScript, но не могу вызвать ни один из методов в своем бэкэнде.
Java-сервер
public final class RawServer {
public static void main(String[] args) {
RSocketFactory.receive()
.acceptor((setup, sendingSocket) -> Mono.just(new DefaultSimpleService()))
.transport(WebsocketServerTransport.create("localhost", 8801))
.start()
.block()
.onClose()
.block();
}
private static final class DefaultSimpleService extends AbstractRSocket {
private ObjectMapper jsonMapper = new ObjectMapper();
@Override
public Flux<Payload> requestStream(Payload payload) {
return Mono.just(payload.getDataUtf8())
.map(json -> {
try {
return jsonMapper.readValue(json, Message.class);
} catch (IOException e) {
e.printStackTrace();
return null;
}
})
.doOnNext(msg -> System.out.println("got message " + msg.message))
.flatMapMany(msg -> Flux.range(0, 5)
.map(count -> msg.message + " #" + count))
.map(message -> DefaultPayload.create(message));
}
}
}
public class Message {
public final String message;
@JsonCreator
public Message(@JsonProperty("message") String message) {
this.message = message;
}
}
Клиент JavaScript
import { RSocketClient, JsonSerializers } from "rsocket-core";
import RSocketWebSocketClient from "rsocket-websocket-client";
const transport = new RSocketWebSocketClient({
url: "ws://localhost:8801"
});
const client = new RSocketClient({
// send/receive JSON objects instead of strings/buffers
serializers: JsonSerializers,
setup: {
// ms btw sending keepalive to server
keepAlive: 60000,
// ms timeout if no keepalive response
lifetime: 180000,
// format of `data`
dataMimeType: "application/json",
// format of `metadata`
metadataMimeType: "application/json"
},
transport
});
client.connect().subscribe({
onComplete: socket => {
socket.requestStream({
data: { message: "hello from javascript!" },
metadata: null
});
},
onError: error => {
console.log("got error");
console.error(error);
},
onSubscribe: cancel => {
/* call cancel() to abort */
console.log("subscribe!");
console.log(cancel);
// cancel.cancel();
}
});
Похоже, что соединение WebSocket установлено, но на сервер не отправляется сообщение. Как я могу это сделать?
Я также реализовал клиентскую часть на Java, и она отлично работает. Я нашел пример JavaScript: https://github.com/rsocket/rsocket-js/blob/master/docs/01-client-configuration.md, но я не могу заставить его работать.