STOMP を使用する SockJS Java クライアントが 1 つあります。このhttps://github.com/rstoyanchev/spring-websocket-portfolio/blob/master/src/test/java/org/springframework/samples/portfolio/web/load/StompWebSocketLoadTestClient.javaに基づいています。
私のコード:
package mx.intercommunication.websocket.stompclient;
import org.springframework.messaging.converter.StringMessageConverter;
import org.springframework.messaging.simp.stomp.StompCommand;
import org.springframework.messaging.simp.stomp.StompHeaders;
import org.springframework.messaging.simp.stomp.StompSession;
import org.springframework.messaging.simp.stomp.StompSessionHandlerAdapter;
import org.springframework.web.socket.client.WebSocketClient;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import org.springframework.web.socket.sockjs.client.SockJsClient;
import org.springframework.web.socket.sockjs.client.Transport;
import org.springframework.web.socket.sockjs.client.WebSocketTransport;
public class StompClient {
public StompClient(){
cliente();
}
public void cliente() {
String host = "localhost";
int port = 8080;
String stompUrl = "ws://{host}:{port}/Server/chat";
StandardWebSocketClient webSocketClient = new StandardWebSocketClient();
List<Transport> transports = new ArrayList<>(2);
/*
* The WebSocketTransport can be configured with:
* + StandardWebSocketClient in a JSR-356 runtime
* + JettyWebSocketClient using the Jetty 9+ native WebSocket API
* + Any implementation of Spring’s WebSocketClient
*/
transports.add(new WebSocketTransport(webSocketClient));
SockJsClient sockJsClient = new SockJsClient(transports);
WebSocketStompClient stompClient = new WebSocketStompClient(sockJsClient);
//Configure a scheduler to use for heartbeats and for receipt tracking.
//stompClient.setTaskScheduler(taskScheduler);
//stompClient.setDefaultHeartbeat(new long[] {0, 0});
/*
* Set the MessageConverter to use to convert the payload of incoming and
* outgoing messages to and from byte[] based on object type and the "content-type" header.
* By default, SimpleMessageConverter is configured.
*/
stompClient.setMessageConverter(new StringMessageConverter());
ProducerStompSessionHandler producer = new ProducerStompSessionHandler();
/*
* Connect to the given WebSocket URL and notify the given
* org.springframework.messaging.simp.stomp.StompSessionHandler when connected on
* the STOMP level after the CONNECTED frame is received.
*
* Parameters:
* url the url to connect to
* handler the session handler
* uriVars URI variables to expand into the URL
* Returns:
* ListenableFuture for access to the session when ready for use
*
*/
stompClient.connect(stompUrl, producer, host, port);
}
private static class ProducerStompSessionHandler extends StompSessionHandlerAdapter {
//private final AtomicReference<Throwable> failure;
private StompSession session;
@Override
public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
this.session = session;
try {
Thread.sleep(6000);
} catch (InterruptedException e) {
e.printStackTrace();
}
Json m = Json.object()
.set("from", "cliente1")
.set("text", "KIKO");
String message = m.toString();
//byte messageByteArr[] = message.getBytes();
/*
* Send a message to the specified destination, converting the payload to a
* byte[] with the help of a MessageConverter.
*
* Parameters:
* destination: the destination to send a message to
* payload: the message payload
* Returns:
* a Receiptable for tracking receipts
*/
try {
session.send("/app/chatchannel", message);
//session.send("/app/chatchannel", messageByteArr);
System.out.println("Sending message HELLO: "+message);
} catch (Throwable t) {
System.out.println("Message sending failed: "+t);
//logger.error("Message sending failed at " + i, t);
//failure.set(t);
}
}
/**
* This implementation returns String as the expected payload type
* for STOMP ERROR frames.
*/
@Override
public Type getPayloadType(StompHeaders headers) {
return String.class;
}
@Override
public void handleFrame(StompHeaders headers, Object payload) {
Exception ex = new Exception(headers.toString());
System.out.println("STOMP ERROR frame: "+ex);
}
@Override
public void handleException(StompSession session, StompCommand command, StompHeaders headers,
byte[] payload, Throwable exception) {
System.out.println("Handling exception: "+exception);
}
@Override
public void handleTransportError(StompSession session, Throwable exception) {
System.out.println("Transport error: "+exception);
}
@Override
public String toString() {
//return "ConsumerStompSessionHandler[messageCount=" + this.messageCount + "]";
return "ConsumerStompSessionHandler to String....";
}
}
}
次のように構成するときに確認してくださいstompClient。
stompClient.setMessageConverter(new StringMessageConverter());
そして私はメッセージを送ります：
session.send("/app/chatchannel", message);
ここで、message は String クラス オブジェクトであり、サーバー側は次の変換エラーをスローしました。
08:51:06,746 ERROR [org.springframework.web.socket.messaging.WebSocketAnnotationMethodMessageHandler] (clientInboundChannel-4) Unhandled exception from message handler method: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [[B] to [org.gasmart.websocket.Message] for GenericMessage [payload=byte[33], headers={simpMessageType=MESSAGE, stompCommand=SEND, nativeHeaders={destination=[/app/chatchannel], content-type=[text/plain;charset=UTF-8], content-length=[33]}, simpSessionAttributes={ip=/127.0.0.1:59629}, simpHeartbeat=[J@147a2bf, contentType=text/plain;charset=UTF-8, lookupDestination=/chatchannel, simpSessionId=79431feb8b5f4a9497492ccc64f8965f, simpDestination=/app/chatchannel}]
at org.springframework.messaging.handler.annotation.support.PayloadArgumentResolver.resolveArgument(PayloadArgumentResolver.java:124)
at org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:112)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:138)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:107)
at org.springframework.messaging.handler.invocation.AbstractMethodMessageHandler.handleMatch(AbstractMethodMessageHandler.java:502)
at org.springframework.messaging.simp.annotation.support.SimpAnnotationMethodMessageHandler.handleMatch(SimpAnnotationMethodMessageHandler.java:497)
at org.springframework.messaging.simp.annotation.support.SimpAnnotationMethodMessageHandler.handleMatch(SimpAnnotationMethodMessageHandler.java:87)
at org.springframework.messaging.handler.invocation.AbstractMethodMessageHandler.handleMessageInternal(AbstractMethodMessageHandler.java:461)
at org.springframework.messaging.handler.invocation.AbstractMethodMessageHandler.handleMessage(AbstractMethodMessageHandler.java:399)
at org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask.run(ExecutorSubscribableChannel.java:135)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
エラーを観察します。
MessageConversionException: GenericMessage [payload=byte[33]、headers={simpMessageType=MESSAGE、stompCommand=SEND、nativeHeaders={destination=[/app/chatchannel] の [[B] から [org.gasmart.websocket.Message] に変換できません。 ]、content-type=[text/plain;charset=UTF-8]、content-length=[33]}、simpSessionAttributes={ip=/127.0.0.1:59629}、simpHeartbeat=[J@147a2bf、contentType=text /plain;charset=UTF-8, lookupDestination=/chatchannel, simpSessionId=79431feb8b5f4a9497492ccc64f8965f, simpDestination=/app/chatchannel}]
content-typeヘッダーが SockJS Java クライアントによって作成されていることを確認してください。
次のように構成stompClientした場合:
stompClient.setMessageConverter(new SimpleMessageConverter());
そして私はメッセージを送ります：
...
String message = m.toString();
byte messageByteArr[] = message.getBytes();
session.send("/app/chatchannel", message);
メッセージがバイト配列である場合、サーバーはエラーをスローしません。しかし、送信する前にすべての文字列をバイト配列に変換する必要があります。サーバーが SimpleMessageConverter で送信された同じ JSON オブジェクトと、StringMessageConverter で送信された 1 つの JSON オブジェクトを変換できる理由を理解したいと思います。
JavaScript クライアントと Java クライアントから送信された JSON を比較します。どちらも同じ JSON メッセージを送信します。次に、ChannelInterceptor を実装して、メッセージが対応するコントローラーに送信される前に受信したメッセージを出力します。
public class WebSocketTraceChannelInterceptor extends ChannelInterceptorAdapter {
@Override
public void afterSendCompletion(Message<?> message, MessageChannel channel, boolean sent, Exception ex) {
String payload = new String((byte[]) message.getPayload());
System.out.println("WebSocketTraceChannelInterceptor::afterSendCompletion!! payload: "+payload);
}
}
対応するサーバー コントローラーは次のとおりです。
@MessageMapping("/chatchannel")
@SendTo("/topic/messages")
public OutputMessage send(SimpMessageHeaderAccessor ha,@Payload Message message) throws Exception {
.....
}
Java 出力:
message: GenericMessage [payload=byte[33], headers={simpMessageType=MESSAGE, stompCommand=SEND, nativeHeaders={destination=[/app/chatchannel], **content-type=[text/plain;charset=UTF-8]**, content-length=[33]}, simpSessionAttributes={ip=/127.0.0.1:59629}, simpHeartbeat=[J@147a2bf, contentType=text/plain;charset=UTF-8, simpSessionId=79431feb8b5f4a9497492ccc64f8965f, simpDestination=/app/chatchannel}]
JavaScript: SockJS + Stomp.js:
message: GenericMessage [payload=byte[33], headers={simpMessageType=MESSAGE, stompCommand=SEND, nativeHeaders={destination=[/app/chatchannel], content-length=[33]}, simpSessionAttributes={ip=/127.0.0.1:57890}, simpHeartbeat=[J@d154f0, simpSessionId=innyvfme, simpDestination=/app/chatchannel}]
違いを観察してください: content-type=[text/plain;charset=UTF-8]
Spring メッセージングには、さらに多くのコンバーターがあります。
このパッケージで SimpleMessageConverter と StringMessageConverter を確認できます。しかし、ByteArrayMessageConverter、CompositeMessageConverter、SmartMessageConverter などがあります。このコンバーターはどのように機能しますか?
Java クライアントから文字列を送信したい場合、どのコンバーターが必要ですか?
JScript クライアントから送信されたときにサーバーが JSON メッセージ {"from":"cliente1","text":"KIKO"} を変換できるのに、Java クライアントから送信されたときに変換できないのはなぜですか?