pop3.txt

来自「这是一个关于 JAVA的邮件程序」· 文本 代码 · 共 597 行

package network;

import java.net.*;
import java.util.*;
import java.io.*;

public class pop3server{
	private static final int SERVER_PORT=111;
	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(Exception excpt){
			System.err.println("Sorry ,Failed I/O:"+excpt);
			}
		}
	public pop3server(){
		try{
			listenSocket=new ServerSocket(SERVER_PORT,MAX_CLIENT);
			}catch(Exception 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 nexttime");

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;

}

}

}else{

out.close();

in.close();

mySocket.close();

break;

}

}

}catch(NullPointerException excpt){

System.out.println("sorry "+excpt);

in.close();

out.close();

mySocket.close();

}

}catch(IOException excpt){

System.err.println("Failed I/O:"+excpt);

}

System.out.println("bye");

}

private void printmail(int msgnumber,String uname){

String msgdir="/webmail/userinfo/";

String msgfile=msgdir+uname+"/"+Integer.toString(msgnumber);

System.out.println(msgfile);

long filepoint=0;

try{

RandomAccessFile file=new RandomAccessFile(msgfile,"r");

long msglength=file.length();

while(filepoint<msglength){

String s=file.readLine();

out.println(s);

try{

Thread.currentThread().sleep(5);

}catch(Exception e){

System.out.println(e);

}

filepoint=file.getFilePointer();

}

}catch(Exception e){

System.out.println(e);

}

}

/*check your username and password*/

private char check(String user,String pass){

String[] arg=new String[2];

int c=0;

char value='0';

arg[0]="uname="+user;

arg[1]="pass="+pass;

try{

Process child=Runtime.getRuntime().exec("/disk2/ftp/pub/login"


,arg);

InputStream inn =child.getInputStream();

while((c=inn.read())!=-1){

value=(char)c;

}

inn.close();

try{child.waitFor();}catch(InterruptedException e){

e.printStackTrace();

}

}catch(IOException e){

System.err.println(e);

}

return value;

}

private int readmail(String uname){

String[] arg=new String[1];

arg[0]="username="+uname;

int[] msg=new int[3];

int i=0,j=0;

int msgnum=0;

int c;

try{

Process child=Runtime.getRuntime().exec("/disk2/ftp/pub/readmail",


arg);

InputStream inn =child.getInputStream();

while((c=inn.read())!=-1){

msg[i]=c-48;

i++;

}

inn.close();

try{child.waitFor();}catch(InterruptedException e){

e.printStackTrace();

}

}catch(IOException e){

System.err.println(e);

}

for(j=0;j<=i;j++){

msgnum=msgnum+msg[j];

}

System.out.println(msgnum);

int k=0;

try{

for(j=1;j<=msgnum;j++){

RandomAccessFile file=new RandomAccessFile("/webmail/userinfo/"+uname+


"/"+Integer.toString(j),"r");

msgsize[k]=file.length();

totalsize=msgsize[k]+totalsize;

System.out.println(msgsize[k]);

k++;

}

}catch(Exception e){

System.out.println(e);

}

System.out.println(totalsize);

return msgnum;

}

}