北京通州区网站制作,电子商务有限公司有哪些,北京公司提供注册地址,纯静态 网站stomp java客户端问题#xff1a; 为了分析问题#xff0c;我不得不编写一个简单的Java Web套接字客户端站点代码#xff0c;并使用基于stomp的Web套接字代理连接到服务器端基于Spring的应用程序。 解决方案#xff1a; pom.xml ?xml version1.0 encodi… stomp java客户端 问题 为了分析问题我不得不编写一个简单的Java Web套接字客户端站点代码并使用基于stomp的Web套接字代理连接到服务器端基于Spring的应用程序。 解决方案 pom.xml ?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.rnd/groupIdartifactIdSockWebsocketClient/artifactIdversion1.0-SNAPSHOT/versionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.0.3.RELEASE/version/parentdependenciesdependencygroupIdorg.springframework/groupIdartifactIdspring-messaging/artifactIdversion5.0.7.RELEASE/version/dependencydependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-databind/artifactIdversion2.9.5/version/dependencydependencygroupIdorg.apache.tomcat.embed/groupIdartifactIdtomcat-embed-websocket/artifactIdversion9.0.8/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-dependencies/artifactIdversion2.0.2.RELEASE/versiontypepom/type/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.0.7.RELEASE/version/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-websocket/artifactIdversion5.0.7.RELEASE/version/dependency/dependencies
/projectSock JS客户端 它是主要的班级是做基础工作的简单班级。 由于当今大多数Web套接字都打算使用SSL因此尝试通过创建虚拟TrustManager来传递信任管理器问题。 此代码的输入是您要订阅的主题字符串。 另外不要在运行前更改代码中的URL字符串指向您的Web套接字url。 package com.client;import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.messaging.converter.MessageConverter;
import org.springframework.messaging.converter.SimpleMessageConverter;
import org.springframework.messaging.converter.StringMessageConverter;
import org.springframework.messaging.simp.stomp.StompHeaders;
import org.springframework.web.socket.WebSocketHttpHeaders;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import org.springframework.web.socket.messaging.WebSocketStompClient;
import org.springframework.web.socket.sockjs.client.Transport;
import org.springframework.web.socket.sockjs.client.WebSocketTransport;
import org.springframework.web.socket.sockjs.frame.Jackson2SockJsMessageCodec;import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import java.net.URI;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;public class SockJsClient {public static void main(String[] args) {try {StandardWebSocketClient simpleWebSocketClient new StandardWebSocketClient();TrustManager[] trustAllCerts new TrustManager[] {new X509TrustManager() {public X509Certificate[] getAcceptedIssuers() {return null;}public void checkClientTrusted(X509Certificate[] certs, String authType) {}public void checkServerTrusted(X509Certificate[] certs, String authType) {}}};SSLContext sc SSLContext.getInstance(SSL);sc.init(null, trustAllCerts, new java.security.SecureRandom());HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());MapString, Object properties new HashMap();properties.put(org.apache.tomcat.websocket.SSL_CONTEXT, sc);simpleWebSocketClient.setUserProperties(properties);ListTransport transports new ArrayList();transports.add(new WebSocketTransport(simpleWebSocketClient));org.springframework.web.socket.sockjs.client.SockJsClient sockJsClient new org.springframework.web.socket.sockjs.client.SockJsClient(transports);sockJsClient.setMessageCodec(new Jackson2SockJsMessageCodec());WebSocketStompClient stompClient new WebSocketStompClient(sockJsClient);stompClient.setMessageConverter(new MessageConverter() {Overridepublic Object fromMessage(Message? message, Class? aClass) {return new String((byte[])message.getPayload());}Overridepublic Message? toMessage(Object o, MessageHeaders messageHeaders) {return null;}});// url : pointing to websocket as sockJs first tries to get info by sending a HTTP request// and then sends an upgrade request to ws or wss. So your url should be some thing like htttp://URI stompUrlEndpoint new URI(url);WebSocketHttpHeaders handshakeHeaders new WebSocketHttpHeaders();StompHeaders connectHeaders new StompHeaders();/*Can set connection header like login , passcode in connectHeaders */stompClient.connect(stompUrlEndpoint.toString(), handshakeHeaders, connectHeaders, new SessionHandler(args[0]), new Object[0]);Thread.sleep(30000);stompClient.stop();} catch (Exception e) {e.printStackTrace();}}
}会话处理程序 每个套接字连接都需要一个会话处理程序这里是一个用于处理连接设置和传入消息的会话处理程序。 package com.client;import org.springframework.messaging.simp.stomp.StompCommand;
import org.springframework.messaging.simp.stomp.StompFrameHandler;
import org.springframework.messaging.simp.stomp.StompHeaders;
import org.springframework.messaging.simp.stomp.StompSession;
import org.springframework.messaging.simp.stomp.StompSessionHandlerAdapter;import java.lang.reflect.Type;public class SessionHandler extends StompSessionHandlerAdapter {private final String topicName ;public SessionHandler(String topicName) {this.topicName topicName;}Overridepublic void afterConnected(StompSession session, StompHeaders connectedHeaders) {this.subscribeTo(session);}Overridepublic void handleException(StompSession session,StompCommand command,StompHeaders headers,byte[] payload,Throwable exception ) {exception.printStackTrace();}public void handleFrame(StompHeaders headers, Object payload) {System.out.println(payload.toString());}Overridepublic void handleTransportError(StompSession session, Throwable exception) {exception.printStackTrace();}private void subscribeTo(StompSession session) {StompHeaders headers new StompHeaders();headers.add(id,websocket-session-standalone-0);headers.add(destination,topicName);session.subscribe(headers, new StompFrameHandler() {Overridepublic Type getPayloadType(StompHeaders stompHeaders) {return String.class;}Overridepublic void handleFrame(StompHeaders stompHeaders, Object o) {System.out.println( Message is o.toString());}});}
}翻译自: https://www.javacodegeeks.com/2019/08/web-socket-java-client-stomp-spring-server-side.htmlstomp java客户端
