NewLife.Net——构建可靠的网络服务

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

网络程序应该注册成为系统服务，以保证其自启动以及稳定可靠运行！

这一场，讲讲怎么建立一个生产级别的网络服务。

老规矩，先上源码：https://github.com/NewLifeX/NewLife.Net

系统服务功能，由网络库的兄弟框架，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 = ;
Intervals = new[] { , };
}

指定一些基本参数，看效果图可以猜到用途

服务名、显示名、描述，就这么多！

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 = ,
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 : ShowStat(_Server); break;
case : 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);
}