NewLife.Net——构建可靠的网络服务
网络程序应该注册成为系统服务,以保证其自启动以及稳定可靠运行!
这一场,讲讲怎么建立一个生产级别的网络服务。
老规矩,先上源码:https://github.com/nnhy/NewLife.Net.Tests
系统服务功能,由网络库的兄弟框架,X组件的Agent来支撑,以前也叫XAgent,网上搜索 NewLife XAgent 可以找到不少文章。
XAgent在X组件里面很年轻,才10年,设计于2008年,上海陆家嘴。
〇、最终效果
先来看看最终效果,大家也可以telnet net.newlifex.com 1234 来看效果
左边窗口就是这次要讲的网络服务程序,工作在调试模式。
右边窗口是上一次的EchoTest客户端,连接左边网络服务。
一、建立控制台项目
建立一个控制台项目,通过nuget引用NewLife.Core
新建一个服务类 MyService,继承自泛型基类 AgentServiceBase<MyService>
Program.Main里面增加一行引导程序:
class Program
{
static void Main(String[] args)
{
// 引导进入我的服务控制类
MyService.ServiceMain();
}
}
下面就开始慢慢完善我们的服务类MyService
public MyService()
{
ServiceName = "EchoAgent";
DisplayName = "回声服务";
Description = "这是NewLife.Net的一个回声服务示例!";
// 准备两个工作线程,分别负责输出日志和向客户端发送时间
ThreadCount = 2;
Intervals = new[] { 1, 5 };
}
指定一些基本参数,看效果图可以猜到用途
服务名、显示名、描述,就这么多!
ThreadCount = 2指定两个工作线程,Intervals指定它们的轮询周期分别是1秒和5秒
系统服务的标准动作就是启动和停止
MyNetServer _Server;
/// <summary>开始服务</summary>
/// <param name="reason"></param>
protected override void StartWork(String reason)
{
// 实例化服务端,指定端口,同时在Tcp/Udp/IPv4/IPv6上监听
var svr = new MyNetServer
{
Port = 1234,
Log = XTrace.Log
};
svr.Start();
_Server = svr;
base.StartWork(reason);
}
/// <summary>停止服务</summary>
/// <param name="reason"></param>
protected override void StopWork(String reason)
{
_Server.TryDispose();
_Server = null;
base.StopWork(reason);
}
我们重载启动函数,初始化网络服务,并重启停止函数来销毁网络服务。
这里的MyNetServer从上一个例程拷贝过来。
网络服务做一个成员资源,避免被GC回收。
XAgent默认带来多线程任务调度,其核心是 Work(Int32 index)
/// <summary>调度器让每个任务线程定时执行Work,index标识任务</summary>
/// <param name="index"></param>
/// <returns></returns>
public override Boolean Work(Int32 index)
{
switch (index)
{
case 0: ShowStat(_Server); break;
case 1: SendTime(_Server); break;
}
return false;
}
private String _last;
/// <summary>显示服务端状态</summary>
/// <param name="ns"></param>
private void ShowStat(NetServer ns)
{
var msg = ns.GetStat();
if (msg == _last) return;
_last = msg;
WriteLog(msg);
}
/// <summary>向所有客户端发送时间</summary>
/// <param name="ns"></param>
private void SendTime(NetServer ns)
{
var str = DateTime.Now.ToFullString() + Environment.NewLine;
var buf = str.GetBytes();
ns.SendAllAsync(buf);
}
XAgent内部设计有一个任务调度器,它会实际创建2个线程(ThreadCount指定),每个线程定时执行Work(Int32 index)函数,index参数用于标识哪一个任务线程。
我们这只需要一个很简单的switch,0号线程负责输出服务端状态,每秒一次,1号线程负责给连接到服务端的所有会话发送服务器当前时间。
多说几句XAgent:
1,任务线程具有较高线程优先级,比一般线程有更多机会得到CPU时间
2,调度器有个最高优先级的管理线程,负责监管所有任务线程,如果任务线程崩溃或者超时,它会干掉并新建
3,管理线程还负责监控线程数、句柄数、内存占用等
二、开发调试
既然是控制台项目,先跑起来看看:
红色字体显示重要信息,黄色字体显示菜单,常用功能是235。
我们选择5,循环调试,其实就是在控制台里面模拟服务工作流程,让网络服务跑起来。
底下日志可以看到,它监听了4个套接字。
2是安装服务,也就是把当前应用安装成为Windows服务,这里特别注意,一般需要管理员权限,才能安装成功,除非关闭系统UAC。
3是启动服务,只有在安装了服务之后,才能看到。
所以,XAgent程序,既是开发调试控制台程序,也是安装卸载、启动停止服务的操作台,更是Windows服务程序本身!
细心的同学可以发现,安装好的Windows服务实质上就是 EchoAgent.exe -s,带有-s参数。
三、安装服务
最后,我们把它安装到一台公网服务器上,tcp://net.newlifex.com:1234,telnet上去看看效果
从日志文件可以看到,它的应用类型 ApplicationType 是 Service,也就是Windows Service。
下面的日志,在A0线程(也就是0号任务线程)输出服务端状态。
在线1/1,当前在线/最大在线
发送 2/20/0,共发送2次,最大速度每秒20字节,当前速度每秒0字节
既然有A0线程,同样也会有A1,还会有An(ThreadCount>n),可用于区分不同任务线程输出的日志。
至此,我们的Windows网络服务程序开发完成,并安装到公网服务器上,持续对外提供Echo服务!
- 程序员,2017年你的技能树上增加了哪些新技能?
- Android6.0源码分析之View(一)
- 2017 年,我挖的那些开源软件坑
- Android6.0蓝牙开发中获取附近低功耗蓝牙设备结果权限问题分析
- 我的技术投资策略:如何决定学习哪一个新技术的?
- 我的技术投资策略:如何决定学习哪一个新技术的?
- Android6.0源码之蓝牙研究汇总(一)--from初学者
- Android6.0蓝牙协议之OPP
- 简单直白教你理解Java中四大引用强引用,软引用,弱引用,虚引用
- ubuntu系统上配置git
- Android源码编译出错No rule to make...
- Android中资源各种引用方式?,@,@*等等
- git撤销修改各种情况
- Android中ContentProvider简介
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法