您的位置:首页 > 编程语言 > C#

C# 创建windows服务、socket通讯实例

2010-08-13 14:27 465 查看
本人一直以来都是一个实践主义者,认为在实践中学习,是最好的学习方式。所以在博客中添加文章的时候,总是习惯写一些具体实现的技术知识点。感觉这些东西可以更好的帮助那些学习使用.net c#进行开发开发者。虽然自己的文笔不好,知识的应用也很渐显,但是本着互相学习的精神,希望在总结的同时可以加深自己的理解,考效自己对各个知识的了解程度,共同提高。
言归正传,我今天要说的就是一个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;
}
}


二、邮件发送功能

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

view source

print?

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、等。〔信息接收代码见下〕

view source

print?

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 短信猫。该硬件有对应的二次开发类库,开发很简单。直接将引用方法封装成一个类的静态方法。用的时候直接调用就可以了。(直接贴出代码)

view source

print?

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);
在完成功能后,部署,运行效果不错。感觉这个功能虽然很小。但是用到的知识可不少,感觉还是有所收获的。毕竟术业有专攻,每个人在从事的行业开发中专注的技术也是有限的。多学点各个方面的知识对自己的成长还是很有好处的。哈哈.〔啰嗦了〕。共同学习吧。

if ($ != jQuery){
$ = jQuery.noConflict();
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: