Spring websocket over stomp答案

【问题标题】：Spring websocket over stompSpring websocket over stomp
【发布时间】：2016-06-28 16:34:25
【问题描述】：

我是 websocket 新手，一直在探索 spring websocket 解决方案，我已经从以下 url 实现了 hello world 应用程序：Spring websocket。

我想从 nodejs 调用服务器，而不是使用 index.html 页面。这是我使用 SockJS 和 Stompjs 的实现。

var url = 'http://localhost:8080'

var SockJS = require('sockjs-client'),
    Stomp  = require('stompjs'),
    socket = new SockJS(url + '/hello'),

    client = Stomp.over(socket)

function connect(){
  client.connect({}, function(frame){
    console.log(frame)
    client.subscribe(url + '/topic/greetings', function(greeting){
      console.log(greeting)
    })
  })
}

function sendName(){
  var name = 'Gideon'
  client.send(url + '/app/hello', {}, JSON.stringify({ 'name': name }))
}

function disconnect(){
  if(client)
    client.disconnect()
}

function start(){
  connect()
  sendName()
}

start();

我使用node --harmony index.js 运行脚本

这是我在尝试不同的网址时遇到的错误：

url :var socket = new SockJS('http://localhost:8080/hello')
Error: InvalidStateError: The connection has not been established yet

url: var socket = new SockJS('/hello')
Error: The URL '/hello' is invalid

url: var socket = new SockJS('ws://localhost:8080/hello')  
Error: The URL's scheme must be either 'http:' or 'https:'. '" + parsedUrl.protocol + "' is not allowed.

我的依赖

"dependencies": {
   "sockjs-client": "^1.0.3",
   "stompjs": "^2.3.3"
 }

项目可以在这里找到：https://bitbucket.org/gideon_o/spring-websocket-test

【问题讨论】：

标签： node.js spring websocket sockjs stompjs

【解决方案1】：

SockJS 的预期端点 URL 是 HTTP 端点。 SockJS 将在使用 WebSocket 协议之前检查它是否可用，或者回退到其他选项，如长轮询。您的第一个选项是正确的：

var socket = new SockJS('http://localhost:8080/hello')

STOMP 客户端连接方法是非阻塞的，这就是为什么您提供一个回调，该回调将在连接建立时执行。您正在尝试在调用 connect 方法后立即通过该连接发送消息。连接尚未建立（太快），您会收到错误消息：

Error: InvalidStateError: The connection has not been established yet

您必须将消息的发送移至提供给 connect 方法的回调，以确保它已经建立。这同样适用于订阅（您在示例中已经这样做了）。

还有一点需要注意的是，STOMP 目标不是 URL。不需要在目的地前面加上http://localhost:8080，目的地应该只是/topic/greetings

【讨论】：