1
私は、webpocketを使ってSpring（バージョン4.3.4.RELEASE）を提供するSimpMessagingTemplateとシンプルブローカーに問題があります。 私はクラスのユーザメッセージに送信：wildfly 8.2.1 + spring mvc + spring-websocket（シンプルブローカー）+ 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();
そして最後に私の問題は - 私はすべてではないクライアント上でメッセージを受信します。一部のメッセージはクライアントに配信されません（ウイルス対策カスペルスキーはオフです）。 理由はありますか？