程序问答   发布时间:2022-06-02  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了Spring 4 WebSocket应用大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

如何解决Spring 4 WebSocket应用?

开发过程中遇到Spring 4 WebSocket应用的问题如何解决?下面主要结合日常开发的经验,给出你关于Spring 4 WebSocket应用的解决方法建议,希望对你解决Spring 4 WebSocket应用有所启发或帮助;

错误是错误的控制器映射。我有:

  @messageMapPing("/Hello")
    @SendTo("/topic/greeTings")
    public GreeTing greeTing(Hellomessage messagE) throws Exception

在Jsp中:

stompClIEnt.subscribe("<c:url value='/topic/greeTings'/>", function(greeTing){...

stompClIEnt.send("<c:url value='/app/Hello'/>", {}, JsON.Stringify({ 'name': name }));

正确的是:

stompClIEnt.subscribe('/topic/greeTings', function(greeTing){...
stompClIEnt.send('/app/Hello', {}, JsON.Stringify({ 'name': name }));

c:url添加了项目的根目录,当我将其删除时,该应用程序正常运行。但是,在此处使用SockJs创建新套接字时需要c:url(根目录):

var socket = new SockJs("<c:url value='/Hello'/>");

解决方法

我尝试从spring站点运行此示例: 教程, 除了Spring Boot部分。

Web.xml

<web-app>
    <display-name>Archetype Created Web Application</display-name>

    <servlet>
        <servlet-name>sample</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
            <param-name>contextClass</param-name>
            <param-value>
                org.springframework.web.context.support.AnnotationConfigWebApplicationContext
            </param-value>
        </init-param>
        <init-param>
            <param-name>contextConfigLOCATIOn</param-name>
            <param-value>
                com.evgeni.websock.WebSocketConfig
            </param-value>
        </init-param>
    </servlet>

    <servlet-mapping>
        <servlet-name>sample</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>
</web-app>

Java配置:

@Configuration
@ComponentScan(basePackages = {"com.evgeni.controller"})
@EnableWebSocketmessageBroker
@EnableWebMvc
public class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketmessageBrokerConfigurer  {

    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/Hello").withSockJS();
    }

    public void configureClienTinboundChAnnel(ChAnnelRegistration registration) {
        // TODO Auto-generated method stub

    }

    public void configureClientOutboundChAnnel(ChAnnelRegistration registration) {
        // TODO Auto-generated method stub

    }

    public void configuremessageBroker(messageBrokerRegistry registry) {
        registry.enableSimpleBroker("/topic");
        registry.setApplicationDesTinationPrefixes("/app"); 
    }
     @Override
        public void addresourceHandlers(resourceHandlerRegistry registry) {
            registry.addresourceHandler("/css/**").addresourceLOCATIOns("/css/").setCachePeriod(31556926);
            registry.addresourceHandler("/img/**").addresourceLOCATIOns("/img/").setCachePeriod(31556926);
            registry.addresourceHandler("/js/**").addresourceLOCATIOns("/js/").setCachePeriod(31556926);
        }

}

控制器:

@Controller
public class GreeTingController {


    @messageMapping("/Hello")
    @SendTo("/topic/greeTings")
    public GreeTing greeTing(Hellomessage messagE) throws Exception {
        Thread.sleep(3000); // simulated delay
        System.out.println(message.getName());
        return new GreeTing("Hello," + message.getName() + "!");
    }

}

index.jsp

<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<!DOCTYPE html>
<html>
<head>
    <title>Hello WebSocket</title>
    <script src="<c:url value='/js/sockjs-0.3.js'/>"></script>
    <script src="<c:url value='/js/stomp.js'/>"></script>
    <script type="text/javascript">
        var stompClient = null;

        function setConnected(connected) {
            document.getElementById('connect').disabled = connected;
            document.getElementById('disconnect').disabled = !connected;
            document.getElementById('conversationDiv').style.visibility = connected ? 'visible' : 'hidden';
            document.getElementById('response').innerHTML = '';
        }

        function connect() {
            var socket = new SockJS("<c:url value='/Hello'/>");
            stompClient = Stomp.over(socket);
            stompClient.connect('','',function(framE) {
                setConnected(true);
                console.log('Connected: ' + framE);
                stompClient.subscribe("<c:url value='/topic/greeTings'/>",function(greeTing){
                    showGreeTing(JSON.parse(greeTing.body).content);
                });
            });
        }

        function disconnect() {
            stompClient.disconnect();
            setConnected(false);
            console.log("Disconnected");
        }

        function sendName() {
            var name = document.getElementById('name').value;
            stompClient.send("<c:url value='/app/Hello'/>",{},JSON.Stringify({ 'name': name }));
        }

        function showGreeTing(messagE) {
            var response = document.getElementById('response');
            var p = document.createElement('p');
            p.style.wordWrap = 'break-word';
            p.appendChild(document.createTextNode(messagE));
            response.appendChild(p);
        }
    </script>
</head>
<body>
<noscript><h2 style="color: #ff0000">Seems your browser doesn't support Javascript! Websocket relies on Javascript being enabled. Please enable
    Javascript and reload this page!</h2></noscript>
<div>
    <div>
        <button id="connect" onclick="connect();">Connect</button>
        <button id="disconnect" disabled="disabled" onclick="disconnect();">Disconnect</button>
    </div>
    <div id="conversationDiv">
        <label>what is your name?</label><input type="text" id="name" />
        <button id="sendName" onclick="sendName();">Send</button>
        <p id="response"></p>
    </div>
</div>
</body>
</html>

除了从web.xml和jsp中的2-3 c:url加载以添加项目根目录的配置文件之外,其他所有操作均与本教程相同。

当我单击连接然后发送时,在浏览器控制台中,我得到:

Opening Web Socket... stomp.js:122
Web Socket Opened... stomp.js:122
>>> CONNECT
login:
passcode:
accept-version:1.1,1.0
heart-beat:10000,10000

 stomp.js:122
<<< ERROR
message:Illegal header\c 'login\c'. A header must be of the form <name>\c<value>
content-length:0

 stomp.js:122
>>> SEND
desTination:/websock/app/Hello
content-length:14

{"name":"asd"}

我认为这个问题在Sock js的connect函数中

stompClient.connect('',function(framE) {...

我正在传递“”作为登录名和密码。

编辑: 当我将连接功能更改stompClient.connect('random','random',为控制台中的响应时是:

Opening Web Socket... stomp.js:122
Web Socket Opened... stomp.js:122
>>> CONNECT
login:asd
passcode:asd
accept-version:1.1,10000

 stomp.js:122
<<< CONNECTED
heart-beat:0,0
version:1.1

 stomp.js:122
connected to server undefined stomp.js:122
Connected: CONNECTED
version:1.1
heart-beat:0,0

 (indeX):23
>>> SUBSCRIBE
id:sub-0
desTination:/websock/topic/greeTings

 stomp.js:122
>>> SEND
desTination:/websock/app/Hello
content-length:14

{"name":"asd"}

但消息未传递到控制器。

大佬总结

以上是大佬教程为你收集整理的Spring 4 WebSocket应用全部内容,希望文章能够帮你解决Spring 4 WebSocket应用所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。