Java实现POP3服务器

核心提示：//write --1998.6import java.net.*;import java.util.*;public class pop3server{PRivate static final int SERVER_PORT=110;private static final int MAX_CLIENT=500;pr

　　//write --1998.6
　　
　　import java.net.*;
　　
　　import java.util.*;
　　
　　public class pop3server{
　　
　　PRivate static final int SERVER_PORT=110;
　　
　　private static final int MAX_CLIENT=500;
　　
　　private ServerSocket listenSocket=null;
　　
　　private boolean keeprunning=true;
　　
　　private InetAddress ip;
　　
　　public static void main(String[] args){
　　
　　pop3server server=new pop3server();
　　
　　server.impserver();
　　
　　}
　　
　　public void impserver(){
　　
　　Socket clientSocket=null;
　　
　　try{
　　
　　while(keeprunning){
　　
　　clientSocket=listenSocket.accept();
　　
　　int numThreads=Thread.activeCount();
　　
　　System.out.println(numThreads);
　　
　　manageconnection newhandle=new manageconnection(clientSocket);
　　
　　Thread newhandlethread=new Thread(newhandle);
　　
　　newhandlethread.start();
　　
　　System.out.println("hello");
　　
　　}
　　
　　}
　　
　　catch(IOException excpt){
　　
　　System.err.println("Sorry ,Failed I/O:"+excpt);
　　
　　}
　　
　　}
　　
　　public pop3server()
　　
　　{
　　
　　try{
　　
　　listenSocket=new ServerSocket(SERVER_PORT,MAX_CLIENT);
　　
　　}catch(IOException excpt){
　　
　　System.err.println("SOrry to open port "+SERVER_PORT+":"+excpt);
　　
　　System.exit(1);
　　
　　}
　　
　　}
　　
　　}
　　
　　/*follow is manage and process command class*/
　　
　　class manageconnection implements Runnable{
　　
　　private static final boolean AUTOFLUSH=true;
　　
　　private Socket mySocket=null;
　　
　　private PrintWriter out=null;
　　
　　private BufferedReader in=null;
　　
　　private boolean checkedpass=false;
　　
　　private int msgnum=0;
　　
　　private long[] msgsize=new long[100];
　　
　　private long totalsize=0;
　　
　　private String username=null;
　　
　　public manageconnection(Socket newSocket){
　　
　　mySocket=newSocket;
　　
　　}
　　
　　public void run(){
　　
　　String nextline=null;
　　
　　String passWord;
　　
　　int check=0;
　　
　　int strlen;
　　
　　String content="Subject:hello";
　　
　　String command=null;
　　
　　String auth_user="user";
　　
　　String arg1;
　　
　　int arg2=0;
　　
　　String arg3;
　　
　　int i=0;
　　
　　int count=0;
　　
　　int time=0;
　　
　　try{Thread.currentThread().sleep(10);
　　
　　}catch(Exception e){
　　
　　System.out.println(e);
　　
　　}
　　
　　try{
　　
　　mySocket.setTcpNoDelay(true);
　　
　　time=mySocket.getSoTimeout();
　　
　　}catch(SocketException excpt){
　　
　　System.out.println(excpt);
　　
　　}
　　
　　try{
　　
　　out=new PrintWriter(mySocket.getOutputStream(),AUTOFLUSH);
　　
　　in=new BufferedReader(new InputStreamReader(mySocket.getInputStream())
　　
　　
　　);
　　
　　/*System.out.println("hello thread1");*/
　　
　　out.println("+OK"+" TianHua's pop3 server");
　　
　　try{
　　
　　while(true){
　　
　　if(check!=3){
　　
　　try{
　　
　　nextline=in.readLine();}catch(Exception excpt){
　　
　　System.out.println("sorry:"+excpt);
　　
　　break;
　　
　　}
　　
　　System.out.println(count+" "+nextline);
　　
　　if(nextline.length()<4){
　　
　　out.println("-ERR");
　　
　　}else{
　　
　　command=nextline.substring(0,4);
　　
　　if(command.equalsIgnoreCase("user")){
　　
　　i=1;
　　
　　}
　　
　　if(command.equalsIgnoreCase("pass")){
　　
　　i=2;
　　
　　}
　　
　　if(command.equalsIgnoreCase("stat")){
　　
　　i=3;
　　
　　}
　　
　　if(command.equalsIgnoreCase("quit")){
　　
　　i=4;
　　
　　}
　　
　　if(command.equalsIgnoreCase("list")){
　　
　　i=5;
　　
　　}
　　
　　if(command.equalsIgnoreCase("retr")){
　　
　　i=6;
　　
　　}
　　
　　if(command.equalsIgnoreCase("dele")){
　　
　　i=7;
　　
　　}
　　
　　switch(i){
　　
　　case 1:if(check==0){
　　
　　check=1;
　　
　　if(nextline.length()<5){
　　
　　out.println("-ERR");
　　
　　}else{arg1=nextline.substring(5);
　　
　　username=arg1;
　　
　　out.println("+OK");
　　
　　}
　　
　　}else{out.println("-ERR");}
　　
　　i=0;
　　
　　break;
　　
　　case 2:if(check==1){
　　
　　if(nextline.length()<5){
　　
　　out.println("-ERR");
　　
　　}else{
　　
　　arg1=nextline.substring(5);
　　
　　password=arg1;
　　
　　if(check(username,password)=='1'){
　　
　　check=2;
　　
　　/*msgnum=readmail(username);*/
　　
　　out.println("+OK");}else{
　　
　　out.println("-ERR"+" sorry auth failed");
　　
　　check=0;}
　　
　　}
　　
　　}else{out.println("-ERR");}
　　
　　i=0;
　　
　　break;
　　
　　case 3:if(check==2){
　　
　　msgnum=readmail(username);
　　
　　out.println("+OK"+" "+msgnum+" "+totalsize);
　　
　　}else{
　　
　　out.println("-ERR");
　　
　　}
　　
　　i=0;
　　
　　break;
　　
　　case 4:out.println("+OK BYE BYE welcome to TianHua's Mail System next
　　
　　
　　time");
　　
　　check=3;
　　
　　i=0;
　　
　　break;
　　
　　case 5:if(check==2){
　　
　　out.println("+OK");
　　
　　out.println(msgnum+" "+totalsize);
　　
　　int ii,iii=0;
　　
　　for(ii=1;ii<=msgnum;ii++){
　　
　　out.println(ii+" "+msgsize[iii]);
　　
　　iii++;
　　
　　}
　　
　　out.println(".");
　　
　　}else{
　　
　　out.println("-ERR");
　　
　　}
　　
　　i=0;
　　
　　break;
　　
　　case 6:if(check==2){
　　
　　if(nextline.length()<5){
　　
　　out.println("-ERR");
　　
　　}else{
　　
　　arg1=nextline.substring(5);
　　
　　out.println("+OK");
　　
　　System.out.println(arg1);
　　
　　printmail(Integer.parseInt(arg1),username);
　　
　　out.print("\r\n");
　　
　　out.print(".");
　　
　　out.print("\r\n");
　　
　　boolean st=out.checkError();
　　
　　System.out.println(st);
　　
　　/*if(nextline.length()<6){
　　
　　out.println("-ERR");
　　
　　}else{
　　
　　try{
　　
　　arg2=Integer.parseInt(nextline.substring(5));
　　
　　}catch(NumberFormatException except)
　　
　　{
　　
　　out.println("-ERR");
　　
　　break;
　　
　　}
　　
　　if(msgnum==0){
　　
　　out.println("-ERR no msg retrived");
　　
　　}
　　
　　if(arg2<=msgnum){
　　
　　out.println("+OK");
　　
　　out.println(content);
　　
　　out.println("");
　　
　　out.print(".");
　　
　　out.println();
　　
　　out.println(".");
　　
　　System.out.println("msg finished");
　　
　　}else{
　　
　　out.println("no sUCh msg");
　　
　　}
　　
　　}*/
　　
　　}
　　
　　}else{out.println("-ERR");
　　
　　}
　　
　　i=0;
　　
　　System.out.println("retr finished");
　　
　　break;
　　
　　case 7:if(check==2){
　　
　　out.println("+OK");
　　
　　}else{
　　
　　out.println("-ERR");
　　
　　}
　　
　　i=0;
　　
　　break;
　　
　　default:out.println("-ERR");
　　
　　i=0;
　　
　　break;
　　
　　}