Java是伴随Internet的大潮产生的,对网络及多线程具有内在的支持,具有网络时代编程语言的一切特点。从Java的当前应用看,Java主要用于在Internet或局域网上的网络编程,而且将Java作为主流的网络编程语言的趋势愈来愈明显。实际工作中,我们除了使用商品化的服务器软件外,时常需要按照实际环境编写自己的服务器软件,以完成特定任务或与特定客户端软件实现交互。在实现服务器程序时,为提高程序运行效率,降低用户等待时间,我们应用了在Java Applet中常见的多线程技术。
一、Java中的服务器程序与多线程
在Java之前,没有一种主流编程语言能够提供对高级网络编程的固有支持。在其他语言环境中,实现网络程序往往需要深入依赖于操作平台的网络API的技术中去,而Java提供了对网络支持的无平台相关性的完整软件包,使程序员没有必要为系统网络支持的细节而烦恼。
Java软件包内在支持的网络协议为TCP/IP,也是当今最流行的广域网/局域网协议。Java有关网络的类及接口定义在java.net包中。客户端软件通常使用java.net包中的核心类Socket与服务器的某个端口建立连接,而服务器程序不同于客户机,它需要初始化一个端口进行监听,遇到连接呼叫,才与相应的客户机建立连接。Java.net包的ServerSocket类包含了编写服务器系统所需的一切。下面给出ServerSocket类的部分定义。
public class ServerSocket
{
public ServerSocket(int port)
throws IOException ;
public Socket accept() throws IOException ;
public InetAddress getInetAddress() ;
public int getLocalPort() ;
public void close() throws IOException ;
public synchronized void setSoTimeout (int timeout) throws SocketException ;
public synchronized int getSoTimeout() throws IOException ;
}
ServerSocket构造器是服务器程序运行的基础,它将参数port指定的端口初始化作为该服务器的端口,监听客户机连接请求。Port的范围是0到65536,但0到1023是标准Internet协议保留端口,而且在Unix主机上,这些端口只有root用户可以使用。一般自定义的端口号在8000到16000之间。仅初始化了ServerSocket还是远远不够的,它没有同客户机交互的套接字(Socket),因此需要调用该类的accept方法接受客户呼叫。Accept()方法直到有连接请求才返回通信套接字(Socket)的实例。通过这个实例的输入、输出流,服务器可以接收用户指令,并将相应结果回应客户机。ServerSocket类的getInetAddress和getLocalPort方法可得到该服务器的IP地址和端口。setSoTimeout和getSoTimeout方法分别是设置和得到服务器超时设置,如果服务器在timout设定时间内还未得到accept方法返回的套接字实例,则抛出IOException的异常。
Java的多线程可谓是Java编程的精华之一,运用得当可以极大地改善程序的响应时间,提高程序的并行性。在服务器程序中,由于往往要接收不同客户机的同时请求或命令,因此可以对每个客户机的请求生成一个命令处理线程,同时对各用户的指令作出反应。在一些较复杂的系统中,我们还可以为每个数据库查询指令生成单独的线程,并行对数据库进行操作。实践证明,采用多线程设计可以很好的改善系统的响应,并保证用户指令执行的独立性。由于Java本身是"线程安全"的,因此有一条编程原则是能够独立在一个线程中完成的操作就应该开辟一个新的线程。
Java中实现线程的方式有两种,一是生成Thread类的子类,并定义该子类自己的run方法,线程的操作在方法run中实现。但我们定义的类一般是其他类的子类,而Java又不允许多重继承,因此第二种实现线程的方法是实现Runnable接口。通过覆盖Runnable接口中的run方法实现该线程的功能。本文例子采用第一种方法实现线程。
二、多线程服务器程序举例
以下是我们在项目中采用的多线程服务器程序的架构,可以在此基础上对命令进行扩充。本例未涉及数据库。如果在线程运行中需要根据用户指令对数据库进行更新操作,则应注意线程间的同步问题,使同一更新方法一次只能由一个线程调用。这里我们有两个类,receiveServer包含启动代码(main()),并初始化ServerSocket的实例,在accept方法返回用户请求后,将返回的套接字(Socket)交给生成的线程类serverThread的实例,直到该用户结束连接。
//类receiveServer
import java.io.*;
import java.util.*;
import java.net.*;
public class receiveServer{
final int RECEIVE_PORT=9090; //该服务器的端口号
//receiveServer的构造器public receiveServer() {ServerSocket rServer=null;
//ServerSocket的实例
Socket request=null;
//用户请求的套接字Thread receiveThread=null;
try{
rServer=new ServerSocket(RECEIVE_PORT);
//初始化ServerSocket System.out.println("Welcome to the server!");
System.out.println(new Date());
System.out.println("The server is ready!");
System.out.println("Port: "+RECEIVE_PORT);
while(true){ //等待用户请求 request=rServer.accept(); //接收客户机连接请求receiveThread=new serverThread(request);
//生成serverThread的实例
receiveThread.start();
//启动serverThread线程
}
}
catch(IOException e){
System.out.println(e.getMessage()) ;
}
} public static void main(String args[]){ new receiveServer();
} //end of main} //end of class//类serverThreadimport java.io.*;
import java.net.*;
class serverThread extends Thread {Socket clientRequest;
//用户连接的通信套接字BufferedReader input;
//输入流PrintWriter output;
//输出流
public serverThread(Socket s) {
//serverThread的构造器 this.clientRequest=s;
//接收receiveServer传来的套接字 InputStreamReader reader;
OutputStreamWriter writer;
try{
//初始化输入、输出流
reader=new InputStreamReader(clientRequest.getInputStream());
writer=new OutputStreamWriter(clientRequest.getOutputStream());
input=new BufferedReader(reader);
output=new PrintWriter(writer,true);
}
catch(IOException e){ System.out.println(e.getMessage());}
output.println("Welcome to the server!");
//客户机连接欢迎词
output.println("Now is: "+new java.util.Date()+" "+ "Port:"+clientRequest.getLocalPort());
output.println("What can I do for you?");
}
public void run(){
//线程的执行方法
String command=null;
//用户指令 String str=null;
boolean done=false;
while(!done){
try{
str=input.readLine();
//接收客户机指令
}catch(IOException e){
System.out.println(e.getMessage());
}
command=str.trim().toUpperCase();
if(str==null || command.equals("QUIT")) //命令quit结束本次连接
done=true;
else if(command.equals("HELP")){
//命令help查询本服务器可接受的命令
output.println("query");
output.println("quit");
output.println("help");
}
else if(command.startsWith("QUERY")){
//命令
query output.println("OK to query something!");
}//else if …….. //在此可加入服务器的其他指令
else if(!command.startsWith("HELP") && !command.startsWith("QUIT") && !command.startsWith("QUERY")){output.println("Command not Found!
Please refer to the HELP!"); }
}
//end of while
try
{
clientRequest.close();
//关闭套接字
}
catch(IOException e){
System.out.println(e.getMessage());
}
command=null;
}
//end of run
启动该服务器程序后,可用telnet machine port命令连接,其中machine为本机名或地址,port为程序中指定的端口。也可以编写特定的客户机软件通过TCP的Socket套接字建立连接。
http://www.dev26.com/bbs/topic/367web开发站
分享到:
相关推荐
简单的多线程服务器实现,东北大学网络实验之一
程序设计-基于Java的多线程Web服务器(HttpRequest.java和MultiThreadedWebServer.java)
Java 实例 - Socket 实现多线程服务器程序源代码+详细指导教程.zip
一个进程可以创建多个线程,线程与线程间的通信方式比较容易。本设计主要是编写一个多线程的网络通信程序,不同的线程处理不同类型的消息,比如有专门处理TCP的线程、专门处理UDP消息的线程等。
java多线程 socket聊天程序。可实现多个用户与一个服务器聊天。
本软件实现了简单的聊天功能。对于学习java 多线程 socket编程的初学者有帮助。
java多线程实现一个控制台聊天室 java多线程实现一个控制台聊天室
这是一个在eclipse下用java编写的小程序,有源代码也有生成的jar可执行文件,附带简单的使用说明。
Java Socket编程实现的简单多线程WEB服务器
采用apache commons开发包,实现了FTP多线程下载,并有简单的包括进度条的界面,代码的运行:1 把自己的PC配置成FTP服务器(只需下载Serc-U软件)2 建立用户,用户名:zhangyu,密码:123,设置根目录,并拷贝进一些...
通过研究这份源代码,读者将学会如何使用Java多线程机制来构建一个高效的FTP服务器,从而满足大规模数据传输的需求。这对于开发者来说是一个非常重要的技能,尤其是在处理大量用户并发访问时。 实际操作: 源代码中...
Java Socket实例(服务器多线程) 之前3积分下的代码,代码不错就是太贵,现本人分享出来
Unix操作系统环境下,应用程序可以利用fork... 可以说:Java语言对应用程序多线程能力的支持增强了Java作为网络程序设计语言的优势,为实现分布式应用系统中多客户端的并发访问以及提高服务器的响应效率奠定坚实基础。
《JAVA多线程设计模式》PDF 下载 《Java线程 高清晰中文第二版》中文第二版(PDF) 前言 第一章 线程简介 Java术语 线程概述 为什么要使用线程? 总结 第二章 Java线程API 通过Thread类创建线程 使用Runable接口...
NULL 博文链接:https://youngmaster.iteye.com/blog/429280
本资源是东北大学程序实践3的上机实验,是基于java的简单的客户端和服务器,多线程服务器以及远程RMI会议的代码,可以用request和response完成客户端和服务器的应答。
读者将学会如何使用Java多线程机制来构建一个高效的FTP服务器,从而满足大规模数据传输的需求。 全面而深入: 报告内容包括FTP协议的基础知识、多线程编程技巧、服务器性能优化、数据传输安全等各个方面。这个资源...
java的服务端程序(多线程)和客户端程序 Demo
实现下载文件分流下载最后合成整个完整的文件 启动服务器 多线程