1
我有一個websocket專門用SimpMessagingTemplate和提供spring（version 4.3.4.RELEASE）的simple-broker的問題。 我發送到用戶的消息類：wildfly 8.2.1 + spring mvc + spring-websocket（simple-broker）+ sockjs + stomp
@Autowired
SimpMessagingTemplate simpMessagingTemplate;
public void onMessage(final TextMessage message, Session session) throws JMSException {
....
this.simpMessagingTemplate.convertAndSendToUser(
userInfo.getIp(), "/queue/resp", message.getText());
}
這是我的WebSocket配置：
<websocket:message-broker application-destination-prefix="/app" user-destination-prefix="/user">
<websocket:stomp-endpoint path="/workplace">
<websocket:handshake-interceptors>
<bean class="org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor"/>
</websocket:handshake-interceptors>
<websocket:sockjs/>
</websocket:stomp-endpoint>
<websocket:simple-broker prefix="/topic, /queue, /user"/>
</websocket:message-broker>
這是我的web.xml內容：
<servlet>
<servlet-name>mvc-dispatcher</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<load-on-startup>1</load-on-startup>
<async-supported>true</async-supported>
</servlet>
<servlet-mapping>
<servlet-name>mvc-dispatcher</servlet-name>
<url-pattern>/rest/*</url-pattern>
</servlet-mapping>
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>/WEB-INF/mvc-dispatcher-servlet.xml</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
我的控制器：
@Controller public class UserController extends TextWebSocketHand LER {
@MessageMapping("/req")
@SendToUser(destinations = "/queue/resp")
public String greeting(String greeting)
throws Exception {
System.out.println("greeeeeeeeeeeeeeeeeeeeeeeeeeeeeting: " + greeting);
return "{ \"date\": "+ new Date().getTime() + ", \"message\": " + greeting + "}";
}
@MessageExceptionHandler
@SendToUser("/queue/errors")
public String handleException(Exception ex) {
ex.printStackTrace();
System.out.println(ex);
return ex.getMessage();
}
}
而且客戶端我的js代碼：
<script>
var service = {}, socket = {
client: null,
stomp: null
};
service.userIpAddress = 'someIpAddress';
service.RECONNECT_TIMEOUT = 25000;
service.SOCKET_URL = 'http://localhost:8080/examinee_workplace/rest/workplace/';
service.send = function(message) {
console.info('try send message = ', message);
var id = Math.floor(Math.random() * 1000000);
socket.stomp.send("/app/req", {
priority: 9
}, JSON.stringify({
message: message,
id: id
}));
};
var startListener = function() {
console.info('subscribe');
socket.stomp.subscribe('/user/' + service.userIpAddress + '/queue/resp', function(resp) {
console.warn('resp = ', resp);
});
socket.stomp.subscribe('/user/' + service.userIpAddress + '/queue/errors', function(resp) {
var body = JSON.parse(resp.body);
console.warn('error body = ', body);
});
};
var reconnect = function() {
console.info('reconnect. this.RECONNECT_TIMEOUT = ', this.RECONNECT_TIMEOUT);
setTimeout(service.initialize,1000);
};
service.initialize = function() {
socket.client = new SockJS(service.SOCKET_URL);
socket.stomp = Stomp.over(socket.client);
socket.stomp.connect({}, startListener);
socket.stomp.onclose = reconnect;
};
service.initialize();
最後我的問題 - 我收到的郵件客戶端上，但不是全部。有些消息沒有傳送給客戶端（防病毒卡巴斯基關閉）。 你有什麼想法嗎？