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服务!

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java技术分享

Dubbo详细介绍与安装使用过程

1 Dubbo介绍 1.1 dubbox简介 随着互联网的发展,网站应用的规模不断扩大,常规的垂直应用架构已无法应对,分布式服务架构以及流动计算架构势在必行,亟...

4888
来自专栏针针小站

【Soft】NetSarang Xshell 6 Free for Home & School 申请

2672
来自专栏程序员的碎碎念

π框架从入门到放弃

什么是π框架? 全称Phalapi,是一个PHP轻量级开源接口框架,以下是他的优点: 免费:最好的往往是免费的; 不断更新:15年发布,到现在不断的更新和完善,...

4759
来自专栏架构师小秘圈

基于dubbo框架,如何进行大型微服务系统架构设计?

一,为什么需要微服务框架 Nginx+tomcat组成的集群,这已经是非常灵活的集群技术,但是当我们的系统遇到更大的瓶颈,全部应用的单点服务器已经不能满足我们的...

5034
来自专栏北京马哥教育

高可用集群基本概念与heartbeat文本配置接口

一、高可用集群基本概念: 什么是高可用集群: 所谓高可用集群,就是在出现故障时,可以把业务自动转移到其他主机上并让服务正常运行的集群构架 > 高...

3587
来自专栏Java职业技术分享

分布式 | Dubbo 架构设计详解

Dubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式可以使各个层之间解耦合(或者最大限度地松耦合)。从服务模型的角度...

2280
来自专栏一名合格java开发的自我修养

计算机操作系统之存储管理

内存的回收与分配,地址变换(程序中的逻辑地址与内存中的物理地址之间的转换),内存扩充(借助虚拟技术或覆盖技术从逻辑上扩充内存容量),内存保护(保证进入内存的各道...

651
来自专栏编程

重构的些许收获

题图:Pixabay 这个项目开始之初,赶时间上线。很多地方基本没怎么管代码规范,直到一期完毕回过头来看之前写的代码,不忍直视。为了之后接手的人能更加轻松,也为...

19010
来自专栏java达人

Kafka漫游记

我是一条消息,从我被生产者发布到topic的时候,我就清楚自己的使命:被消费者获取消费。但我一直很纳闷,把我直接推送给消费者不就行了,为什么一定要先推送到类似队...

2537
来自专栏小程序·云开发专栏

小程序的全栈开发新时代

小程序·云开发是微信团队和腾讯云团队共同研发的一套小程序基础能力,简言之就是:云能力将会成为小程序的基础能力。整套功能是基于腾讯云全新推出的云开发(Tencen...

12.8K17

扫码关注云+社区

领取腾讯云代金券