转帖：麻雀虽小，五脏俱全－C#创建windows服务、socket通讯实例 ...

设为首页
点击收藏
手机版

手机扫一扫访问
迪恩网络手机版
关注官方公众号

微信扫一扫关注
公众号

登陆注册

快速发帖
客服电话

点击联系客服
在线时间：8:00-16:00

客服电话

132-9538-2358

电子邮件
[email protected]
APP下载

迪恩网络APP

随时随地掌握行业动态
官方微信

扫描二维码

关注迪恩网络微信公众号
问题反馈
返回顶部

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Node.js›Node.js教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

转：http://www.cnblogs.com/xingshao/archive/2010/08/12/1798188.html

一个windows 服务结合 Soctket、邮件发送、短信发送的小应用。功能不大，但是用到的.net下的知识点很多，我感觉对初步接触这几个相关知识的朋友还是有学习意义的。

这个功能来源于一个监视文件夹的需求：

1、轮询监视文件夹内文件的状态

2、在发现异常后通过邮件和短信的方式通知管理员。

3、在有外网环境下使用邮件方式通知。

4、无外网情况下，通过局域网中一台带有的短信设备电脑发送短信提醒。

在经过具体的功能分析后，将功能划分为4个小功能单元：

1、运用c#开发windows服务来实现对文件夹的轮询监视。

2、引用.net框架内的system.net.mail 命名控件的下的邮件处理类来实现邮件的发送。

3、局域网内采用scoket解决局域网内短信设备计算机与监控计算机之间的通讯问题。

4、 C#对短信设备进行简单必要的二次开发。

一、windows服务实现轮询监视

Windows 服务，以前的NT服务，都是被作为Windows NT操作系统的一部分引进来的。你需要使用NT级别的操作系统才可运行Windows服务，诸如：Windows NT、Windows 2000 Professional、windows XP或Windows 2000 Server以上操作系统。举例而言，以Windows服务形式的产品有：Microsoft Exchange、SQL Server，还有别的如设置计算机时钟的Windows Time服务。它随 Windows 操作系统启动而启动的，在后台运行的，通常不和用户产生交互的程序。

在.net框架下创建Windows 服务非常的简单快捷，它封装了Windows服务程序的创建和控制过程，程序相关的命名空间涉及到以下两个：System.ServiceProcess和System.Diagnostics。

首先是创建windows服务，在.net框架中直接创建windows服务项目即可，在服务启动事件中添加必要的逻辑处理。〔实现见下代码〕


protected override void OnStart(string[] args)

{
// TODO: 在此处添加代码以启动服务。
//读取配置信息
            ReadConfig();


timer1.Elapsed+=new System.Timers.ElapsedEventHandler(timer1_Elapsed);

timer1.Interval = GlobalInfo.TimeInterval;

timer1.Start();

}

void timer1_Elapsed(object sender, System.Timers.ElapsedEventArgs e)

{


DirectoryInfo dirs = new DirectoryInfo(GlobalInfo.DirName); 
int count=0;
switch (GlobalInfo.Type)

{
case 0://延迟时间
                    foreach (FileInfo var in dirs.GetFiles())

{

DateTime createTime = var.CreationTime;
if (System.DateTime.Now > createTime.AddHours(GlobalInfo.Size))

count++;

}
if (count > 0)

MessageSender.Send(GlobalInfo.Norm > 1 ? false : true, string.Format("{0}个数据文件延迟超过{1}小时,请关注。[报告时间：{2}]", count.ToString(), GlobalInfo.Size.ToString(), System.DateTime.Now.ToString()));
break;
case 1://延时数据包个数
                    count = dirs.GetFiles().Length;
if (count > GlobalInfo.Count)

MessageSender.Send(GlobalInfo.Norm > 1 ? false : true, string.Format("同时有{0}个数据文件滞留,请关注。[报告时间：{1}]", count.ToString(), System.DateTime.Now.ToString()));
break;
default:
break;

}

}

二、邮件发送功能

在以前的一篇文章中提到过邮件类的使用，所以就不在作详细说明了。〔附代码：见下〕

01

static void  Send(string titel,string megHtml,string subject) 

02

      { 

03

          string meg = ""; 

04

          //发送者 

05

          string smtpAuthUsername = GlobalInfo.SenderAddr; 

06

          //发送者密码 

07

          string smtpAuthPassword = GlobalInfo.SenderPwd; 

08

          //发送服务器 

09

          string smtpServer = GlobalInfo.SmtpServer; 

10

          string objEmail = GlobalInfo.ObjAddr; 

11

          //定义传输协议  

12

          System.Net.Mail.SmtpClient smtp = new System.Net.Mail.SmtpClient(smtpServer); 

13

          //设置认证发件人  

14

          smtp.Credentials = new System.Net.NetworkCredential(smtpAuthUsername, smtpAuthPassword); 

15

          //异步发送完成获取发送状态  

16

          smtp.SendCompleted += new System.Net.Mail.SendCompletedEventHandler(SendCompletedCallback); 

17
 
18

          try

19

          { 

20

              System.Net.Mail.MailMessage mail = new System.Net.Mail.MailMessage(); 

21

              mail.From = new System.Net.Mail.MailAddress(smtpAuthUsername, smtpAuthUsername); 

22

              //回复人，回复人名  

23

              mail.ReplyTo = new System.Net.Mail.MailAddress(smtpAuthUsername, smtpAuthUsername); 

24

              //收件人  

25

              mail.To.Add(objEmail); 

26

              //邮件优先级  

27

              mail.Priority = System.Net.Mail.MailPriority.Normal; 

28

              //设置html邮件  

29

              mail.IsBodyHtml = true; 

30

              //标题  

31

              mail.Subject = titel; 

32

              //内容  

33

              mail.Body = megHtml; 

34

              smtp.Send(mail); 

35
 
36

              meg = string.Format("{0} {1}邮件发送成功。", System.DateTime.Now.ToString(), objEmail); 

37
 
38

              WriteLog(meg); 

39

          } 

40

          catch

41

          { 

42

              meg = string.Format("{0} {1}邮件发送失败。", System.DateTime.Now.ToString(), objEmail); 

43
 
44

              WriteLog(meg); 

45

          } 

46
 
47

      }

三、局域网内Socket通讯

　　Socket原意是“插座”。应用层通过传输层进行数据通信时，TCP和UDP会遇到同时为多个应用程序进程提供并发服务的问题。多个TCP连接或多个应用程序进程可能需要通过同一个TCP协议端口传输数据。为了区别不同的应用程序进程和连接，许多计算机操作系统为应用程序与TCP／IP协议交互提供了称为套接字(Socket)的接口，区分不同应用程序进程间的网络通信和连接。生成套接字，主要有3个参数：通信的目的IP地址、使用的传输层协议(TCP或UDP)和使用的端口号。通过将这3个参数结合起来，与一个“插座”Socket绑定，应用层就可以和传输层通过套接字接口，区分来自不同应用程序进程或网络连接的通信，实现数据传输的并发服务。 Socket可以看成在两个程序进行通讯连接中的一个端点，一个程序将一段信息写入Socket中，该Socket将这段信息发送给另外一个Socket中，使这段信息能传送到其他程序中。

　　因为现有的短信设备位与局域网内的另外一台服务器上，所以需要在短信通知状态下，需要将信息发送到局域网内另一台电脑。用socket通讯的话需要一个接收信息的客户端。并且客户端需要一些参数的设置。比如：接收电话号码、开机启动、通讯计算机IP、等。〔信息接收代码见下〕

01

Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 

02

            socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, 1);  

03

            try

04

            { 

05

                socket.Bind(new IPEndPoint(IPAddress.Parse(Info.IP), int.Parse(Info.PORT))); 

06

                socket.Listen((int)SocketOptionName.MaxConnections); 

07

                while (true) 

08

                { 

09

                    Socket a = socket.Accept(); 

10

                    if (a.Connected) 

11

                    { 

12

                        byte[] stream = new byte[80]; 

13

                        a.Receive(stream); 

14

                        string message = System.Text.Encoding.UTF8.GetString(stream); 

15

                        InsertRechText ins = new InsertRechText(Insert); 

16

                        Invoke(ins, new object[] { message }); 

17

                    } 

18

                    if (isover) 

19

                        return; 

20

                } 

21

            } 

22

            catch (Exception ex) 

23

            { 

24

                WriteLog(string.Format("接收信息失败。[{0}]", ex.Message)); 

25

                throw ex; 

26

            } 

27

            finally

28

            { 

29

                socket.Close(); 

30

            }

四、短信设备二次开发

短信设备用的是人大金仓的DG-C1A 短信猫。该硬件有对应的二次开发类库，开发很简单。直接将引用方法封装成一个类的静态方法。用的时候直接调用就可以了。(直接贴出代码)

01

  [DllImport("GSMMultiPort.dll", 

02

             EntryPoint = "GSMModemInit", 

03

             CharSet = CharSet.Ansi, 

04

             CallingConvention = CallingConvention.StdCall)] 

05

        public static extern bool GSMModemInit( 

06

            string device, 

07

            string baudrate, 

08

            string initstring, 

09

            string charset, 

10

            bool swHandshake, 

11

            string sn); 

12
//发送短信息 

13

        [DllImport("GSMMultiPort.dll", 

14

             EntryPoint = "GSMModemSMSsend", 

15

             CharSet = CharSet.Ansi, 

16

             CallingConvention = CallingConvention.StdCall)] 

17

        public static extern bool GSMModemSMSsend( 

18

            string device, 

19

            string serviceCenterAddress, 

20

            int encodeval, 

21

            string text, 

22

            int textlen, 

23

            string phonenumber, 

24

            bool requestStatusReport); 

25

  //取得错误信息   

26

        [DllImport("GSMMultiPort.dll", 

27

             EntryPoint = "GSMModemGetErrorMsg", 

28

             CharSet = CharSet.Ansi, 

29

             CallingConvention = CallingConvention.StdCall)] 

30

        public static extern string GSMModemGetErrorMsg(string device);