如何使用Java编写NT服务(二)
四、为什么要采用Java编写NT服务
比较VC等“原装”NT服务开发方式而言，Java开发模式可以更快捷，因为几乎所有得服务框架通过扩展Services类就可以达到，省下不少复杂的细节处理。Java语言提供了丰富的类库，可以为自己使用，可以提高效率，而且编写的程序结构清楚轻易理解，方便以后维护。
Java提供的异常处理模式，可以让我们写好结构良好，更加安全的代码。试想假如编写的服务进程由于采用VC编写却忘记对某块内存的释放，那么服务启动后一段时间由于内存泄漏造成服务性能下降，甚至系统崩溃；但是Java本身的语言特性可以使我们不用时刻提防内存治理，可以更加关注服务逻辑本身，是的实现起来更加有效率。
采用VC假如编写多线程服务进程，虽然可以实现，但是会相当麻烦。而服务进程多线程几乎是每一个性能良好的服务必备特征，Java语言本身可以提供这方面良好的支持，同时Java自身对网络的天然良好支持，使各种网络套接字编程轻易。
最后，假如不采用其他扩展库，我们很轻易将此服务逻辑实现在其他操作系统上。一个编写好的NT服务程序，可以在去掉对Ms的相关本地化扩展实现的类引用后，方便移植到其他例如Linux等平台上，尽可能向Java的“一次编写、到处可运行”的理想境界靠拢。
五、源码
/*所附的ZIP文件报含示例的全部工程文件，还有编译后的NT服务的可执行文件，您可以直接测试此服务exe文件的安装、服务启停*/
/*EchoSvc.java*/
import com.ms.service.* ;
public class EchoSvc extends Service
{
static Thread mainSvc=null ; //定义主线程
public EchoSvc (String[] args) //构造服务
{
CheckPoint(1000); //服务是系统的一部分，作为Log纪录，可以帮助用户理解系统故障
setRunning(ACCEPT_SHUTDOWN ACCEPT_PAUSE_CONTINUE ACCEPT_STOP);
mainSvc = new Thread((Runnable) new MainSvcThread());
mainSvc.start();
System.out.println( "The Echo Service Was Started SUCcessfully!");
}
}
/*-------------- EchoSvc.java源码结束-------------------*/
/*MainSvcThread.java*/
import java.io.*;
import java.net.*;
public class MainSvcThread implements Runnable //实现线程控制多线程接口
{ /将启动一组线程来监听多个服务请求
public static boolean STOP = false; //由系统来控制的内部变量，决定着服务进程（线程）的启动、暂停等
public static boolean PAUSE = false;
public int ListenThreadCount=0; //本服务支持的当前线程数量
int maxSocket=10; //最大支持的同时连结数
int SvcPort=2002; //服务监听的端口
public void run()
{
try
{
while (!STOP)
{
while (!PAUSE && !STOP)
{
{//创建监听服务器
Socket server;
ServerSocket li=new ServerSocket(SvcPort); //创建服务器端套接字
ThreadGroup g=new ThreadGroup("EchoThreads"); //创建一组线程
System.out.println("Echo service starting..."); //记录在Log中
while(ListenThreadCount<maxSocket)
{
server=li.accept(); //监听
EchoThread p=new EchoThread(server,this); //创建服务单线程
Thread t=new Thread(g,(Runnable)p) ; //创建新线程
t.start(); //启动服务线程
ListenThreadCount++; //当前线程的数量
}
}
try
{
Thread.sleep(5000);//暂停5秒
}
catch (InterruptedException e)
{ }
}
try
{
Thread.sleep(1000);
}
catch (InterruptedException ie)
{ }
}
}
catch (IOException ioe)
{}
} //Run结束
}
/*-------------- MainSvcThread.java源码结束-------------------*/
/*EchoThread.java*/
import java.io.*;
import java.net.*;
/*实现每一个客户连接到此NT服务时的服务器端的线程单元逻辑*/
public class EchoThread implements Runnable //实现线程接口
{
Socket so=null;//套接字
MainSvcThread p; //一个指向父线程的指针,EchoThread的线程是服务线程的创建的子线程
public void run()
{
String line;
DataInputStream in; //套接字上的输入流
PrintWriter out; //套接字上的输出流，带缓冲
boolean exitflag=false;
try
{
in=new DataInputStream(so.getInputStream()) ;//获取套接字的输入流
out=new PrintWriter(new DataOutputStream(so.getOutputStream())) ;
out.println("You have connected to EchoSvc!"); //发送问候
out.flush(); //必须刷新缓冲区内的内容
while((line=in.readLine())!=null && ! exitflag)
{
line=line.trim();
if (line.equalsIgnoreCase("quit") )
{//假如是退出命令,则关闭当前套接字上的输入输出流
in.close();
out.flush();
out.close();
p.ListenThreadCount --; //主线程的服务线程单元数量控制
return; //退出当前的服务逻辑线程单元
}
else
{
out.println("ECHO:" + line );
out.flush();
}
}
in.close();
out.close();
p.ListenThreadCount --;
}
catch(IOException ioe)
{}
}
EchoThread(Socket s,MainSvcThread parent)
{
so=s;
p= parent;
}
}
/*-------------- EchoThread.java源码结束-------------------*/