搜索
您的当前位置:首页正文

node.js ws模块搭建websocket服务端的方法示例

2023-12-07 来源:车融汽车网

首先下载websocket模块,命令行输入

npm install ws

node.js的 模块ws,可用于创建websocket服务,基本的express 和 http模块的使用

var express = require('express');var http = require('http');var WebSocket = require('ws');var app = express();var server = http.createServer(app);var wss = new WebSocket.Server({server});

创建好服务之后,websocket 服务通过监听 message事件获取来自客户端的数据,然后我们可以给客户端发送一些消息。

wss.on('connection', function connection(ws) { console.log('连接成功!') ws.on('message', function incoming(data) { wss.clients.forEach(function each(client) { client.send('do you love me?'); }); });});

搭建的服务我选择监听3000端口,

server.listen(3000, function listening() { console.log('服务器启动成功!');}); 

最后客户端就简单了,web API 用于创建连接: new web(socket);

var socket = `ws://localhost:3000`;var websocket = new WebSocket(socket);

关于WebSocket的详细操作,可前往w3c查看:webSocket

小编还为您整理了以下内容,可能对您也有帮助:

如何用nodejs搭建一个wss的websocket服务

var https=require('https');var ws=require('ws');var fs=require('fs');var keypath=process.cwd()+'/ssl_certificate_key.key';var certpath=process.cwd()+'/ssl_certificate.pem';var options = {
 key: fs.readFileSync(keypath),
 cert: fs.readFileSync(certpath)
};var server=https.createServer(options, function (req, res) {
 res.writeHead(403);
 res.end("This is a WebSockets server! ");
}).listen(80);var wss = new ws.Server( { server: server } );

如何用nodejs搭建一个wss的websocket服务

var https=require('https');var ws=require('ws');var fs=require('fs');var keypath=process.cwd()+'/ssl_certificate_key.key';var certpath=process.cwd()+'/ssl_certificate.pem';var options = {
 key: fs.readFileSync(keypath),
 cert: fs.readFileSync(certpath)
};var server=https.createServer(options, function (req, res) {
 res.writeHead(403);
 res.end("This is a WebSockets server! ");
}).listen(80);var wss = new ws.Server( { server: server } );

如何搭建 websocket服务器

其实,在服务器的选择上很广,基本上,主流语言都有WebSocket的服务器端实现,而我们作为前端开发工程师,当然要选择现在比较火热的NodeJS作为我们的服务器端环境了。

NodeJS本身并没有原生的WebSocket支持,但是有第三方的实现(大家要是有兴趣的话,完全可以参考WebSocket协议来做自己的实现),我们选择了“ws”作为我们的服务器端实现。

由于本文的重点是讲解WebSocket,所以,对于NodeJS不做过多的介绍,不太熟悉的朋友可以去参考NodeJS入门指南(http://www.nodebeginner.org/index-zh-cn.html)。

安装好NodeJS之后,我们需要安装“ws”,也就是我们的WebSocket实现,安装方法很简单,在终端或者命令行中输入:

npm install ws

,等待安装完成就可以了。

接下来,我们需要启动我们的WebSocket服务。首先,我们需要构建自己的HTTP服务器,在NodeJS中构建一个简单的HTTP服务器很简单,so easy。代码如下:

var app = http.createServer(onRequest ).listen( 8888 );

onRequest()作为回调函数,它的作用是处理请求,然后做出响应,实际上就是根据接收的URL,在服务器上查找相应的资源,最终返回给浏览器。

在构建了HTTP服务器后,我们需要启动WebSocket服务,代码如下:

var WebSocketServer = require('ws').Server;

var wss = new WebSocketServer( { server : app } );

从代码中可以看出,在初始化WebSocket服务时,把我们刚才构建好的HTTP实例传递进去就好。到这里,我们的服务端代码差不多也就编写完成了。怎么样?很简单吧。

Nodejs如何搭建Web服务器

使用Nodejs搭建Web服务器是学习Node.js比较全面的入门教程,因为要完成一个简单的Web服务器,你需要学习Nodejs中几个比较重要的模块,比如:http协议模块、文件系统、url解析模块、路径解析模块、以及301重定向问题,下面我们就简单讲一下如何来搭建一个简单的Web服务器。

作为一个Web服务器应具备以下几个功能:

1、能显示以.html/.htm结尾的Web页面

2、能直接打开以.js/.css/.json/.text结尾的文件内容

3、显示图片资源

4、自动下载以.apk/.docx/.zip结尾的文件

5、形如http://xxx.com/a/b/ , 则查找b目录下是否有index.html,如果有就显示,如果没有就列出该目录下的所有文件及文件夹,并可以进一步访问。

6、形如http://xxx.com/a/b, 则作301重定向到http://xxx.com/a/b/ , 这样可以解决内部资源引用错位的问题。

引入需要用到的几个模块:

//http协议模块

var http = require('http');

//url解析模块

var url = require('url');

//文件系统模块

var fs = require("fs");

//路径解析模块

var path = require("path");创建服务并在指定的端口监听:

//创建一个服务

var httpServer = http.createServer(this.processRequest.bind(this));

//在指定的端口监听服务

httpServer.listen(port,function(){

console.log("[HttpServer][Start]","runing at http://"+ip+":"+port+"/");

console.timeEnd("[HttpServer][Start]");

});在创建服务的时候需要传递一个匿名函数processRequest 对请求进行处理,processRequest接收2个参数,分别是request和response, request对象中包含了请求的所有内容,request是用来设置响应头以及对客户端做出响应操作。

processRequest:function(request,response){

var hasExt = true;

var requestUrl = request.url;

var pathName = url.parse(requestUrl).pathname;

//对请求的路径进行解码,防止中文乱码

pathName = decodeURI(pathName);

//如果路径中没有扩展名

if(path.extname(pathName) === ''){

//如果不是以/结尾的,加/并作301重定向

if (pathName.charAt(pathName.length-1) != "/"){

pathName += "/";

var redirect = "http://"+request.headers.host + pathName;

response.writeHead(301, {

location:redirect

});

response.end();

}

//添加默认的访问页面,但这个页面不一定存在,后面会处理

pathName += "index.html";

hasExt = false; //标记默认页面是程序自动添加的

}

//获取资源文件的相对路径

var filePath = path.join("http/webroot",pathName);

//获取对应文件的文档类型

var contentType = this.getContentType(filePath);

//如果文件名存在

fs.exists(filePath,function(exists){

if(exists){

response.writeHead(200, {"content-type":contentType});

var stream = fs.createReadStream(filePath,{flags:"r",encoding:null});

stream.on("error", function() {

response.writeHead(500,{"content-type": "text/html"});

response.end("<h1>500 Server Error</h1>");

});

//返回文件内容

stream.pipe(response);

}else { //文件名不存在的情况

if(hasExt){

//如果这个文件不是程序自动添加的,直接返回404

response.writeHead(404, {"content-type": "text/html"});

response.end("<h1>404 Not Found</h1>");

}else {

//如果文件是程序自动添加的且不存在,则表示用户希望访问的是该目录下的文件列表

var html = "<head><meta charset='utf-8'></head>";

try{

//用户访问目录

var filedir = filePath.substring(0,filePath.lastIndexOf(''));

//获取用户访问路径下的文件列表

var files = fs.readdirSync(filedir);

//将访问路径下的所以文件一一列举出来,并添加超链接,以便用户进一步访问

for(var i in files){

var filename = files[i];

html += "<div><a href='"+filename+"'>"+filename+"</a></div>";

}

}catch (e){

html += "<h1>您访问的目录不存在</h1>"

}

response.writeHead(200, {"content-type": "text/html"});

response.end(html);

}

}

});

},请求处理函数中有几个重点需要说一下:

对于路径中有中文的,浏览器会自动进行编码(英文不变,中文会变),因此在接收到地址后,需要对地址进行解码,否则最后得到的路径和真实路径不相符,

当访问路径不是以具体的文件结尾,并且不是以/结尾,则需要通过重定向加上/,表示当前目录,否则当前路径下的静态资源会找不到

如果访问路径是目录,则列出该目录下所有文件及文件夹,并可以点击访问,为了让中文目录能正常显示,则还要在header中设置charset=utf-8

核心代码就这么多,大概140行左右,完整的代码已上传到Git:https://github.com/git-onepixel/Node

如果要运行demo,打开cmd切换到根目录,运行node start即可。

车融汽车网还为您提供以下相关内容希望对您有帮助:

如何用nodejs搭建一个wss的websocket服务

var https=require('https');var ws=require('ws');var fs=require('fs');var keypath=process.cwd()+'/ssl_certificate_key.key';var certpath=process.cwd()+'/ssl_certificate.pem';var options = { key: fs...

websocket 服务器怎么启动

安装好nodejs之后,我们需要安装“ws”,也就是我们的websocket实现,安装方法很简单,在终端或者命令行中输入:npm install ws ,等待安装完成就可以了。接下来,我们需要启动我们的websocket服务。首先,我们需要构建自己的http...

websocket实现即时通讯怎么操作?

服务器端编写:在服务器端,您需要使用WebSocket库来处理WebSocket连接和消息传输。具体实现方式因语言和框架而异。例如,在Node.js中,您可以使用ws库来实现WebSocket服务器端。实现即时通讯:通过以上步骤,您已经可以建立WebSoc...

怎么连接nodejs服务器

2.安装ws模块 ws:是nodejs的一个WebSocket库,可以用来创建服务。 3.server.js 在项目里面新建一个server.js,创建服务,指定8181端口,将收到的消息log出来。 var WebSocketServer = require('ws').Server,wss = new WebSocketServer({...

websocket实现即时通讯怎么操作?

具体实现方式因语言和框架而异。例如,在Node.js中,您可以使用ws库来实现WebSocket服务器端。选择WebSocket服务器:要实现即时通讯,需要使用WebSocket协议,所以需要选择一个支持WebSocket的服务器,例如Node.js、Socket.io、...

如何通过WebSocket连接服务器进行数据传输

C#可以用SuperSocket,这里我举例用Node.js,创建server.js:var WebSocketServer = require('ws').Server , wss = new WebSocketServer({port: 8080});wss.on('connection', function(ws) { ws.on('message', f...

node websocket的问题

我这个方法已经测试通过。安装 npm install ws 服务端 server.js var WebSocketServer = require('ws').Server , wss = new WebSocketServer({port: 8080});wss.on('connection', function(ws) { ws.on('message...

websocket

8.WebSocket.close():关闭连接方法 SOCKJS SOCKJS 是一个浏览器使用的js库,它提供了一个类似网络的对象,和连贯的,跨浏览器的jaApi,可以在浏览器和服务器之间创建一个低延迟,全双工的跨域通信通道 SOCKJS实现了对浏览...

WebSocket协议-原理篇

我们在使用WebSocket协议时通常不会使用它的API来实现,而是借助于Socket.io,Socket.io是一个WebSocket库,包括客户端的js和服务端的nodejs,它的目标是构建可以在不同浏览器和移动设备上使用的实时应用。它会自动根据浏览器...

在局域网中怎么搭建node服务器?

1.安装nodejs服务(从官网下载安装),node相当于apache服务器 2.在自己定义的目录下新建服务器文件如 server.js 例如,我在E:\PhpProject\html5\websocket下创建了server.js文件 var http = require('http');//引入http...

本文如未解决您的问题请添加抖音号:51dongshi(抖音搜索懂视),直接咨询即可。

热门图文

Top