怎么连接nodejs服务器

前面已经学习了WebSocket API，包括事件、方法和属性。详情：WebSocket(二)--API  WebSocket是基于事件驱动，支持全双工通信。下面通过三个简单例子体验一下。

简单开始

1安装node。/

2安装ws模块

ws：是nodejs的一个WebSocket库，可以用来创建服务。

3serverjs

在项目里面新建一个serverjs，创建服务，指定8181端口，将收到的消息log出来。

var WebSocketServer = require('ws')Server,
wss = new WebSocketServer({ port: 8181 });
wsson('connection', function (ws) {
consolelog('client connected');
wson('message', function (message) {
consolelog(message);
});
});

4建立一个clienthtml。

在页面上建立一个WebSocket的连接。用send方法发送消息。

var ws = new WebSocket("ws://localhost:8181");
wsonopen = function (e) {
consolelog('Connection to server opened');
}    function sendMessage() {
wssend($('#message')val());
}

页面：

 View Code

运行之后如下，服务端即时获得客户端的消息。

模拟股票

上面的例子很简单，只是为了演示如何运用nodejs的ws创建一个WebSocket服务器。且可以接受客户端的消息。那么下面这个例子演示股票的实时更新。客服端只需要连接一次，服务器端会不断地发送新数据，客户端收数据后更新UI页面如下，有五只股票，开始和停止按钮测试连接和关闭。

服务端：

1模拟五只股票的涨跌。

var stocks = {    "AAPL": 950,    "MSFT": 500,    "AMZN": 3000,    "GOOG": 5500,    "YHOO": 350}function randomInterval(min, max) {    return Mathfloor(Mathrandom() (max - min + 1) + min);
}var stockUpdater;var randomStockUpdater = function() {    for (var symbol in stocks) {        if(stockshasOwnProperty(symbol)) {            var randomizedChange = randomInterval(-150, 150);            var floatChange = randomizedChange / 100;
stocks[symbol] += floatChange;
}
}    var randomMSTime = randomInterval(500, 2500);
stockUpdater = setTimeout(function() {
randomStockUpdater();
}, randomMSTime);
}
randomStockUpdater();

2连接建立之后就开始更新数据

wsson('connection', function (ws) {    var sendStockUpdates = function (ws) {        if (wsreadyState == 1) {            var stocksObj = {};            for (var i = 0; i < clientStockslength; i++) {              var symbol = clientStocks[i];
stocksObj[symbol] = stocks[symbol];
}            if (stocksObjlength !== 0) {                wssend(JSONstringify(stocksObj));//需要将对象转成字符串。WebSocket只支持文本和二进制数据
consolelog("更新", JSONstringify(stocksObj));
}
}
}    var clientStockUpdater = setInterval(function () {
sendStockUpdates(ws);
}, 1000);
wson('message', function (message) {        var stockRequest = JSONparse(message);//根据请求过来的数据来更新。
consolelog("收到消息", stockRequest);
clientStocks = stockRequest['stocks'];
sendStockUpdates(ws);
});

客户端：

建立连接：

var ws = new WebSocket("ws://localhost:8181");

onopen直接只有在连接成功后才会触发，在这个时候将客户端需要请求的股票发送给服务端。

var isClose = false;    var stocks = {        "AAPL": 0, "MSFT": 0, "AMZN": 0, "GOOG": 0, "YHOO": 0
};    function updataUI() {
wsonopen = function (e) {
consolelog('Connection to server opened');
isClose = false;            wssend(JSONstringify(stock_request));
consolelog("sened a mesg");
}        //更新UI
var changeStockEntry = function (symbol, originalValue, newValue) {            var valElem = $('#' + symbol + ' span');
valElemhtml(newValuetoFixed(2));            if (newValue < originalValue) {
valElemaddClass('label-danger');
valElemremoveClass('label-success');
} else if (newValue > originalValue) {
valElemaddClass('label-success');
valElemremoveClass('label-danger');
}
}        // 处理受到的消息
wsonmessage = function (e) {            var stocksData = JSONparse(edata);
consolelog(stocksData);            for (var symbol in stocksData) {                if (stocksDatahasOwnProperty(symbol)) {
changeStockEntry(symbol, stocks[symbol], stocksData[symbol]);
stocks[symbol] = stocksData[symbol];
}
}
};
}
updataUI();

运行效果如下：只需要请求一次，数据就会不断的更新，效果是不是很赞，不用轮询，也不用长连接那么麻烦了。文章末尾会附上所有源码。

（美股的涨跌和A股的颜色是反的，即红跌绿涨）

实时聊天

上面的例子是连接建立之后，服务端不断给客户端发送数据。接下来例子是一个简单的聊天室类的例子。可以建立多个连接。

1安装node-uuid模块，用来给每个连接一个唯一号。

2服务端消息发送

消息类型分notification和message两种，前者是提示信息，后者是聊天内容。消息还包含一个id、昵称和消息内容。在上一节有学习到readyState有四个值，OPEN表示连接建立可以发送消息。如果页面关闭了，为WebSocketCLOSE。

function wsSend(type, client_uuid, nickname, message) {    for (var i = 0; i < clientslength; i++) {        var clientSocket = clients[i]ws;        if (clientSocketreadyState === WebSocketOPEN) {
clientSocketsend(JSONstringify({                "type": type,                "id": client_uuid,                "nickname": nickname,                "message": message
}));
}
}
}

3服务端处理连接

每新增加一个连接，都会发送一条匿名用户的加入的提示消息，如果消息中带有“/nick” 认为这一个修改昵称的消息。然后更新客户端的昵称。其他都会当做聊天消息处理。

wsson('connection', function(ws) {    var client_uuid = uuidv4();    var nickname = "AnonymousUser" + clientIndex;
clientIndex += 1;
clientspush({ "id": client_uuid, "ws": ws, "nickname": nickname });
consolelog('client [%s] connected', client_uuid);    var connect_message = nickname + " has connected";    wsSend("notification", client_uuid, nickname, connect_message);
consolelog('client [%s] connected', client_uuid);
wson('message', function(message) {        if (messageindexOf('/nick') === 0) {            var nickname_array = messagesplit(' ');            if (nickname_arraylength >= 2) {                var old_nickname = nickname;
nickname = nickname_array[1];                var nickname_message = "Client " + old_nickname + " changed to " + nickname;                wsSend("nick_update", client_uuid, nickname, nickname_message);
}
} else {
wsSend("message", client_uuid, nickname, message);
}
});

处理连接关闭：

var closeSocket = function(customMessage) {        for (var i = 0; i < clientslength; i++) {            if (clients[i]id == client_uuid) {                var disconnect_message;                if (customMessage) {
disconnect_message = customMessage;
} else {
disconnect_message = nickname + " has disconnected";
}                wsSend("notification", client_uuid, nickname, disconnect_message);
clientssplice(i, 1);
}
}
};
wson('close', function () {
closeSocket();
});

4客户端

没有启动时，页面如下，change按钮用来修改昵称。

View Code

js:

//建立连接
       var ws = new WebSocket("ws://localhost:8181");        var nickname = "";
       wsonopen = function (e) {
           consolelog('Connection to server opened');
       }        //显示
       function appendLog(type, nickname, message) {            if (typeof message == "undefined") return;            var messages = documentgetElementById('messages');            var messageElem = documentcreateElement("li");            var preface_label;            if (type === 'notification') {
               preface_label = "<span class=\"label label-info\"></span>";
           } else if (type == 'nick_update') {
               preface_label = "<span class=\"label label-warning\"></span>";
           } else {
               preface_label = "<span class=\"label label-success\">"
               + nickname + "</span>";
           }            var message_text = "<h2>" + preface_label + "&nbsp;&nbsp;"
           + message + "</h2>";
           messageEleminnerHTML = message_text;
           messagesappendChild(messageElem);
       }        //收到消息处理
       wsonmessage = function (e) {            var data = JSONparse(edata);
           nickname = datanickname;
           appendLog(datatype, datanickname, datamessage);
           consolelog("ID: [%s] = %s", dataid, datamessage);
       }
       wsonclose = function (e) {
           appendLog("Connection closed");
           consolelog("Connection closed");
       }        //发送消息
       function sendMessage() {            var messageField = documentgetElementById('message');            if (wsreadyState === WebSocketOPEN) {
               wssend(messageFieldvalue);
           }
           messageFieldvalue = '';
           messageFieldfocus();
       }        //修改名称
       function changName() {            var name = $("#name")val();            if (wsreadyState === WebSocketOPEN) {
               wssend("/nick " + name);
           }
       }

运行结果：

页面关闭之后，连接马上断开。

这种实时响应的体验简直不能太爽，代码也清爽了，前端体验也更好，客户端不用一直发请求，服务端不用等着被轮询。

小结：上面例子的代码都很好理解，接下来学习WebSocket协议。

不知不觉间，2019已经接近尾声，在这一年里，我们看到了很多技术的长足发展，其中就包括NodeJS，它已经变得越来越流行，NPM上的各种功能模块（Package）的发布总数，也呈井喷之势，早早的就跨越了100万大关，成为了这个星球上最大的开源库集合。不
更令人惊喜的是，作为一种Web服务器端的技术，在2019年度，我们看到了业界，在基于NodeJS，构建健壮的内容管理系统（CMS）这一应用领域上的持续发力，一批充满现代意味、方便、实用的CMS产品被纷纷推出，下面所列的，则是在2019年度，被广泛使用的一些CMS产品，正在希望使用NodeJS，开发相关以内容管理为核心的网站的朋友，不妨可以关注下。
至于能不能像WordPress一样，成为一款现象级的CMS产品，就一切都要靠时间去检验了，拭目以待吧。
1 KeystoneJs
KeystoneJs是一款功能强大的NodeJs CMS框架。除了其本身提供了丰富而强壮的CMS基础功能外，KeystoneJs还可以用于开发RESTful API的应用、各种非CMS的应用程序，如电子商务平台或者在线论坛等。
特别的，KeystoneJs提供了简化的Admin UI，可帮助开发人员快速的创建美观但功能复杂的CMS后台管理功能。
KeystoneJs的其他一些主要特性如下：
KeystoneJS使用MongoDB数据库进行数据存储，并借助于Mongoose实现了有效的对象文档映射(ODM)。
通过KeystoneJS MVC架构，并使用KeystoneJS的内置模板，可以快速的构建基于数据的相关页面呈现功能。
只需要少量的一些工作，开发人员就能在KeystoneJS的基础上，实现自定义的路由，并实现各种定制功能的开发。
KeystoneJS非常轻量级，同时为数据库管理提供了丰富的API，这对于构建面向内容的网站来说，是非常重要的。
2 Ghost CMS
如果在几年前，以Ghost为代表的Headless（无头类）类的CMS系统，还只是CMS中的一个不特别被人关注的分支的话，那么，2019年度，在CMS领域，最应该引起人关注的，就是Headless（无头类）类的CMS系统，已经蔚为壮观，渐成主流。
这一现象，反映了一个不争的现实，即：一个后台，多种前端，已经越来越成为了业界基本的形态。
Ghost总体来说，更加适合于构建功能复杂的博客类平台，这也是为什么，一众公司，如苹果(Apple)、天空新闻(SkyNews)等都使用Ghost CMS的原因所在。
首先，Ghost的整体设计是非常干净，简单，舒适的，几乎零配置就能拥有非常友好的内容编辑接口。
其次，Ghost内置了强大的SEO功能。您可以在Ghost里，就准备好所有的站点地图、元数据、AMPs、规范标记等等等等和SEO相关的内容。
3 Strapi CMS
了解了Ghost的优雅，不妨来认识下另一个，在2019年度发展堪称迅猛的框架：Strapi CMS！
和Ghost一样，这也是一个Headless的CMS框架，它为开发人员提供了一个强大的、自托管的、高度可定制的内容API系统。
因此，Strapi非常适用于开发系统级别的、具有良好配置、易于管理的Web和移动端应用程序。

停止方法：

1首先，不能共享完毕之后，都通过Ctrl+C来关闭NodeJS服务器。

2其次，如果仅仅能向客户端提供d:\ilinkit_logopng文件的下载，是没有意义的，共享哪个文件，应该可以通过传入的参数来指定。我们首先来实现退出功能，如果客户端向服务器提交了>

代码如下：

1 var >

2 var fs = require('fs');

3 var url = require( 'url' );

4  （空行）

5 var file_path = "D:\\ilinkit_logopng" ;

6 var file_stream ;

7 var buffer_box = [] ;

8 var file_length = 0 ;
9 （空行）

10 var file_name = file_pathsubstr( file_pathlastIndexOf('\\')+1 );

关键的代码解析如下：

第33行，我们通过request对象获取客户端请求的主机及端口内容。

第46行～第50行，我们判断客户端提交的请求信息，如果是>

验证方式如下：

1 启动服务器：打开命令行，进入js脚本所在的位置，执行：node h_ilinkit_1js。

2 打开浏览器，输入：>

说明当前服务器启动正常。

3 打开浏览器，输入：>

提示NodeJS服务器已经关闭，我们把浏览器关闭之后，发现服务器已经正常退出，如下所示。

这样，我们就没必要每次为了退出服务器，都去按Ctrl + C了。

小鸟云服务器niaoyun实例创建好之后，您可以使用以下任意一种方式登录服务器：
远程桌面连接(MicrosoftTerminalServicesClient,MSTSC)：采用这种方式登录，请确保实例能访问公网。如果在创建实例时没有购买带宽，则不能使用远程桌面连接。
管理终端VNC：无论您在创建实例时是否购买了带宽，只要您本地有网页浏览器，都可以通过管理控制台的管理终端登录实例。
使用远程桌面连接(MSTSC)登录实例
打开开始菜单>远程桌面连接，或在开始菜单>搜索中输入mstsc。也可以使用快捷键Win+R来启动运行窗口，输入mstsc后回车启动远程桌面连接。
在远程桌面连接对话框中，输入实例的公网IP地址。单击显示选项。
输入用户名，如小鸟云默认为niaoyun。单击允许我保存凭据，然后单击连接。这样以后登录就不需要手动输入密码了。

首先安装nodejs环境，windows可以直接下载安装包，下一步到底就可以了~~linux可以使用不同发行版的包管理器（但通常版本都不是最新的），使用最新版本可以从官网下载压缩包，然后解压就可以了，运行nodejs代码只需要在命令行中运行node XXXjs(xxxjs为你的代码文件，如果没有将node添加到环境变量，则需要进入node的目录在执行上述命令)~ok 貌似就是这样了~

两点：第一是否是线上服务，第二是否需要守护进程；
第一点，如果是线上服务，毫无疑问需要一个守护进程来保证，发生意外导致进程退出后，能重新启动，提供服务；当然就需要pm2等守护进程来启动，使用方法请自行参照github；第二点，是否需要守护进程，如果不需要，那么直接node启动即可；如果需要，也不必担心pm2启动进程后并不会抢占服务器资源，如果你的server有很大的需求，毋庸置疑需要更多的内存和cpu，如果没有很大需求，pm2会基于linux的资源调度策略，并不会抢占；

---