nodejs socket长连接服务端和测试客户端

想用nodejs写个简单的游戏服务器,正在研究中...

服务区代码server.js

var net = require('net');

var HOST = '127.0.0.1';
var PORT = 8080;

var chatServer = net.createServer();
var clientList = [];

chatServer.on('connection', function(client){
	client.name = client.remoteAddress + ':' + client.remotePort;
	console.log('connect request from ' + client.name)

	client.setTimeout(5*1000);

	client.write('Hi!\n');
	clientList.push(client);

	client.on('data', function(data){
		broadcast(data, client);
	});

	client.on('end', function(){
		clientList.splice(clientList.indexOf(client), 1);
	});

	client.on('close', function() {
  		console.log('close:' + client.name);
	});

	client.on('timeout',function(){
    	client.end();
	})

	client.on('error', function(error) {
  		console.log(error);
  		connection.end();
	});
});

function broadcast(message, client){
	var cleanup = [];
	for(var i = 1; i < clientList.length; i++){
		if(client !== clientList[i]){
			if (clientList[i].writable){
				clientList[i].write(client.name + ' says:' + message);
			} else {
				cleanup.push(clientList[i]);
				clientList[i].destroy()
			}
		}
	}
	for (var i = 0; i < cleanup.length; i++) {
		clientList.splice(clientList.indexOf(cleanup[i]), 1);
	};
}

chatServer.listen(PORT, HOST);

console.log('Server listening on ' + HOST +':'+ PORT);

测试客服端代码client.js

var net = require('net');

var HOST = '127.0.0.1';
var PORT = 8080;

var client = new net.Socket();
client.connect(PORT, HOST, function(){
	console.log('connect to ' + HOST + ':' + PORT);
	client.write('connet request from ' + + HOST + ':' + PORT + '\n');
	client.destroy();
});

client.on('close', function(){
	console.log('connetion closed.');
});
时间: 2024-08-07 08:39:57

nodejs socket长连接服务端和测试客户端的相关文章

Netty 长连接服务

转自:https://www.dozer.cc/2014/12/netty-long-connection.html 推送服务 还记得一年半前,做的一个项目需要用到 Android 推送服务.和 iOS 不同,Android 生态中没有统一的推送服务.Google 虽然有 Google Cloud Messaging ,但是连国外都没统一,更别说国内了,直接被墙. 所以之前在 Android 上做推送大部分只能靠轮询.而我们之前在技术调研的时候,搜到了 jPush 的博客,上面介绍了一些他们的技

170122、Netty 长连接服务

推送服务 还记得一年半前,做的一个项目需要用到 Android 推送服务.和 iOS 不同,Android 生态中没有统一的推送服务.Google 虽然有 Google Cloud Messaging ,但是连国外都没统一,更别说国内了,直接被墙. 所以之前在 Android 上做推送大部分只能靠轮询.而我们之前在技术调研的时候,搜到了 jPush 的博客,上面介绍了一些他们的技术特点,他们主要做的其实就是移动网络下的长连接服务.单机 50W-100W 的连接的确是吓我一跳!后来我们也采用了他们

android通过socket连接服务端(PC端)

自己的计算机网络的基础太差了,一个很小的Demo居然搞了快一天,真醉了,不过坑踩多了,自然知道怎么走路了. 首先,是服务端的代码 class Server implements Runnable{ public static void main(){ Thread server = new Thread(new Server()); server.start();} //服务端因为需要接受多个客户端的信息,所以需要一直开放端口等待客户端连入,我就不写try catch了,有点多 public v

《UNIX网络编程》之多客户连接服务端,可重用套接字对

该网络编程之客户端与服务端程序模板支持: 1. 多客户端同时连接服务端,即服务程序可以同时为多个客户端服务: 2. 服务端支持套接字对重用,即即使处于TIME_WAIT状态,仍可支持服务端重启: 3. 服务端可以发现客户端是否已断开连接: 4. 支持客户端标准输入会显,服务端从标准输出显示客户端所输入内容. 程序如下,记下该模板以备再次使用: 客户端程序如下: /*******************************************************************

socket长连接的用处与模块图 待续

维护socket长连接虽然很耗电,但是却有广泛的用途.如:网络电话,实时接单的应用等. 由于服务器域名固定,手机客户端的网络IP可能不断变更,服务器一般想主动找手机客户端想说声不容易.运营商发现手机经常不用网络时(大部分省份判断手机客户端最近30分钟内是否使用流量,来判断你的手机是否在用网络,若有流量就不把你IP分给别人),会把你的手机以前使用的IP分配给其它手机号,所有苹果把苹果手机网络定义为不稳定的网络,禁止发布的应用严重依赖网络的稳定性.所以服务和客户端只有建立可靠的socket长连接,每

基于netty框架的socket长连接负载均衡解决方案

socket通讯的单机瓶颈 物联网的项目socket使用方式有两种: 短连接的socket请求 维持socket长连接的请求 对于socket短链接来说就好比是http请求,请求服务器,服务器返回数据以后请求管道就关闭了,服务器与客户端的链接就释放了.但是对于socket长链接就不同了,当设备与服务器建立连接以后就要一直保持连接,或者说保持较长时间的链接,那么就会大量消耗服务器的资源.若存在大量的这样的请求以后服务器终究会受不了垮掉.通过对TcpClient/server最大连接数我们得知单机s

服务端协议测试系列教程

测试技术分享之服务端协议测试系列教程 童鞋看完后有啥想法,可以发给我改进 在线播放地址:http://www.iqiyi.com/u/2013029540/a 下载地址:链接: http://pan.baidu.com/s/1boDHpbp 密码: p76e

Oracle客户端无法连接服务端解决方法及步骤

客户端无法连接服务端数据库,原因有网络,配置,文件访问权限,数据库服务是否已启动 等问题导致,一般排查的步骤如下:1.检查操作系统级别网络是否通畅 ping 192.168.10.1 2.检查数据库层网络是否通畅 tnsping myserverdb 3.检查监听状态是否正常 lsnrctl status listener 4.如果第二步不通,检查服务端监听配置是否正确 监听文件配置一般如下 # 监听名称 LISTENER= (DISCRIPTION = (ADDRESS=(PROTOCOL =

服务端主动给客户端推送消息

在了解这个之前,先要知道ajax,队列和递归 ajax操作 异步提交,局部刷新.用它就可以实现轮询/长轮询 创建django项目 views from django.shortcuts import render,HttpResponse import json from django.http import JsonResponse # Create your views here. # 验证ajax def ab_dy(request): if request.method == 'post