如何使用Java编写NT服务(二)

核心提示：四、为什么要采用java编写NT服务 比较VC等“原装”NT服务开发方式而言，Java开发模式可以更快捷，如何使用Java编写NT服务(二)，因为几乎所有得服务框架通过扩展Services类就可以达到，省下不少复杂的细节处理，作为Log纪录，可以帮助用户理解系统故障 setRunning(ACCEPT_SHUTDOWN

四、为什么要采用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源码结束-------------------*/