JAVA实现POP3服务器
类别: JSP教程 
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(" ");
out.print(".");
out.print(" ");
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;
}
}
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(" ");
out.print(".");
out.print(" ");
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;
}
}
- 上一篇: JAVA中：关于++和--
- 下一篇: 使用JAVA开发CORBA应用
