Node.jsでWatershedを定義するにはどうすればいいですか？

次のコードを実行すると、エラーが発生します。参照エラー：流域が定義されていません。どうすれば定義できますか？モジュールをインストールする必要がありますか？Node.jsでWatershedを定義するにはどうすればいいですか？

var restify=require('restify'); 
var ws= new Watershed(); 
var server=restify.createServer(); 
server.get('websocket/attach', function upgradeRoute(req, res, next){ 
    if(!res.claimUpgrade){ 
     next(new Error("Connection must be upgraded.")); 
     return; 
    } 
    var upgrade=res.claimUpgrade(); 
    var shed=ws.accept(req, upgrade.socket, upgrade.head); 
    shed.on('text', function (msg){ 
     console.log("The message is: "+msg); 
    }); 
    shed.send("hello there"); 
    next(false); 
}); 
server.listen(8081, function(){ 
    console.log('%s listening at %s', server.name, server.url); 
});

出典

2016-11-03 Vikas Kumar

あなたはソケットをアップグレードする機能をどのように処理するかを述べたrestifyドキュメントのセクションもあり

var Watershed = require('lib/watershed').Watershed;

出典

2016-11-03 09:09:24

方法：で発見このため

restify listening at http://[::]:8080 client connected! Rest service called started upgrade claimed Received message from websocket client: Here's some text that the server is urgently awaiting!

ドキュメント知ってますか？あなたはそのようなものをどこで読むのですか？ –

流域ライブラリを含める必要があります。私はちょうどemarrassingly長い時間のためにこれで苦労し、私は単純な解決策を共有すると思った。さらに@Dibu Rajの返信では、handleUpgradesオプションをtrueに設定して再構築サーバーを作成する必要があります。 ./static/test/indexでファイルに以下このHTMLを書く：あなたの新しいnodejs用WebSocketサーバーをテストするためのHTMLページの

'use strict'; 
var restify = require('restify'); 
var watershed = require('watershed'); 
var ws = new watershed.Watershed(); 

var server = restify.createServer({ 
    handleUpgrades: true 
}); 

server.get('/websocket/attach', function (req, res, next) { 
    if (!res.claimUpgrade) { 
    next(new Error('Connection Must Upgrade For WebSockets')); 
    return; 
    } 
    console.log("upgrade claimed"); 

    var upgrade = res.claimUpgrade(); 
    var shed = ws.accept(req, upgrade.socket, upgrade.head); 

    shed.on('text', function(msg) { 
    console.log('Received message from websocket client: ' + msg); 
    }); 

    shed.send('hello there!'); 

    next(false); 
}); 

//For a complete sample, here is an ability to serve up a subfolder: 
server.get(/\/test\/?.*/, restify.serveStatic({ 
    directory: './static', 
    default: 'index.html' 
})); 

server.listen(8080, function() { 
    console.log('%s listening at %s', server.name, server.url); 
});

：ここでのWebSocketのアップグレードや流域とrestify作品を作るための完全な例です。 html - ブラウザでhttp://localhost:8080/test/index.htmlを指定する - ブラウザのデバッグコンソールを開いて、メッセージ交換を確認します。

<!doctype html> 
<html lang="en"> 
<head> 
    <meta charset="utf-8"> 
    <title>Web Socket test area</title> 
    <meta name="description" content="Web Socket tester"> 
    <meta name="author" content="Tim"> 
</head> 
<body> 
    Test Text. 
<script> 
    (function() { 
    console.log("Opening connection"); 
    var exampleSocket = new WebSocket("ws:/localhost:8080/websocket/attach"); 
    exampleSocket.onopen = function (event) { 
     console.log("Opened socket!"); 
     exampleSocket.send("Here's some text that the server is urgently awaiting!"); 
    }; 
    exampleSocket.onmessage = function (event) { 
     console.log("return:", event.data); 
     exampleSocket.close(); 
    } 
    })(); 
</script> 
</body> 
</html>

お使いのブラウザのログには、次のようなものになります。

07:05:05.357 index.html:18 Opening connection 
07:05:05.480 index.html:22 Opened socket! 
07:05:05.481 index.html:26 return: hello there!

をそして、あなたのノードのログには、次のようになります。 http://restify.com/#upgrade-requests

出典

2017-05-15 11:24:13

Node.jsでWatershedを定義するにはどうすればいいですか？

答えて

関連する問題