大佬教程收集整理的这篇文章主要介绍了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,请注明来意。