JAVA TCP-IP应用开发详解

21-1 F:\book\tools\james\bin>run Avalon runner parser : org.apache.xerces.parsers.SAXParser configurationPath : ../conf/ logFile : ../logs/avalon.log libPath : ../lib/ blockPath : ./blocks/ Scanning jars for new Blocks... Found new jar: Avalon.jar Installing Avalon configuration file into ../conf/ from template Found new jar: JAMES.jar Installing JAMES configuration file into ../conf/ from template Templates installed in ../conf/ If you need to fill templates with values or overwrite default you can do it now and then press then Enter to continue Reading configuration Avalon 2.2-dev 2001.11.02 10:10:19 831 Channel default opened 21-2 E:\>telnet localhost 4555 root <回车> fujie<回车> help<回车> 此时显示命令列表 adduser mellon 1234<回车> 可能的输出如下： JAMES RemoteAdministration Tool 1.2.1rc2 Please enter your login and password Welcome root. HELP for a list of commands unknown command htlp Currently implemented commans: help display this help adduser [username] [password] add a new user deluser [username] delete existing user listusers display existing accounts countusers display the number of existing accounts verify [username] verify if specified user exist quit close connection Existing accounts 0 User mellon added Existing accounts 1 user: mellon 21-3 /***************************************************************************** * Copyright (C) The Apache Software Foundation. All rights reserved. * * ------------------------------------------------------------------------- * * This software is published under the terms of the Apache Software License * * version 1.1, a copy of which has been included with this distribution in * * the LICENSE file. * *****************************************************************************/ package org.apache.james.smtpserver; import java.io.*; import java.net.*; import java.util.*; import org.apache.mailet.*; import org.apache.avalon.blocks.*; import org.apache.james.*; import org.apache.james.core.*; import org.apache.avalon.*; import org.apache.james.util.*; import Javax.mail.*; import Javax.mail.internet.*; public class SMTPHandler implements Composer, Configurable, Stoppable, TimeServer.Bell, Contextualizable { //常量声明 public final static String SERVER_NAME = "SERVER_NAME"; public final static String SERVER_TYPE = "SERVER_TYPE"; public final static String REMOTE_NAME = "REMOTE_NAME"; public final static String REMOTE_IP = "REMOTE_IP"; public final static String NAME_GIVEN = "NAME_GIVEN"; public final static String CURRENT_HELO_MODE = "CURRENT_HELO_MODE"; public final static String SENDER = "SENDER_ADDRESS"; public final static String RCPT_VECTOR = "RCPT_VECTOR"; public final static String SMTP_ID = "SMTP_ID"; public final static char[] SMTPTerminator = {'\r','\n','.','\r','\n'}; //私有变量声明 //与socket相关变量 private Socket socket; private DataInputStream in; private InputStream socketIn; private PrintWriter out; //与远程地址相关的变量声明 private String remoteHost; private String remoteHostGiven; private String remoteIP; private String messageID; private String smtpID; //与上下文相关的变量声明 private ComponentManager comp; private Configuration conf; private Context context; private Logger logger; private TimeServer timeServer; private MailServer mailServer; //工具与提示信息变量声明 private String servername; private String softwaretype = "JAMES SMTP Server " + Constants.SOFTWARE_VERSION; private static long count; private Hashtable state; private Random random; //设置配置组件 public void setConfiguration(Configuration conf) { this.conf = conf; } //设置上下文组件 public void setContext(Context context) { this.context = context; } //设置组件管理器 public void setComponentManager(ComponentManager comp) { this.comp = comp; } //初始化log日志，mail服务器，时间服务器，随机数，状态表 public void init() throws Exception { logger = (Logger) comp.getComponent(Interfaces.LOGGER); mailServer = (MailServer) comp.getComponent(Interfaces.MAIL_SERVER); timeServer = (TimeServer) comp.getComponent(Interfaces.TIME_SERVER); servername = (String) context.get(Constants.HELO_NAME); state = new Hashtable(); random = new Random(); } //请求解析 public void parseRequest(Socket socket) { try { //得到输入输出流 this.socket = socket; socketIn = new BufferedInputStream(socket.getInputStream(), 1024); in = new DataInputStream(socketIn); out = new InternetPrintWriter(socket.getOutputStream(), true); //得到主机地址 remoteHost = socket.getInetAddress ().getHostName (); remoteIP = socket.getInetAddress ().getHostAddress (); smtpID = Math.abs(random.nextInt() % 1024) + ""; //提取状态信息 state.clear(); state.put(SERVER_NAME, this.servername ); state.put(SERVER_TYPE, this.softwaretype ); state.put(REMOTE_NAME, remoteHost); state.put(REMOTE_IP, remoteIP); state.put(SMTP_ID, smtpID); } catch (Exception e) { //返回错误代码 } public void run() { try { // 初始化连接 timeServer.setAlarm(this.toString(), this, conf.getConfiguration("connectiontimeout").getValueAsLong(120000)); out.println("220 " + this.servername + " SMTP Server (" + softwaretype + ") ready " + RFC822DateFormat.toString(new Date())); //解析命令 while (parseCommand(in.readLine())) { timeServer.resetAlarm(this.toString()); } socket.close(); timeServer.removeAlarm(this.toString()); } catch (SocketException e) { //返回错误代码 } catch (InterruptedIOException e) { //返回错误代码 } catch (IOException e) { //返回错误代码 } catch (Exception e) { //返回错误代码 } finally { try { socket.close(); } catch (IOException e) { //返回错误代码 } } } //连接超时 public void wake(String name, String memo) { logger.log("Connection timeout on socket", "SMTP", logger.ERROR); try { out.println("Connection timeout. Closing connection"); socket.close(); } catch (IOException e) { //返回错误代码 } } //命令解析 private boolean parseCommand(String command) throws Exception { //命令为空，返回失败 if (command == null) return false; logger.log("Command received: " + command, "SMTP", logger.INFO); //解析命令和命令的参数 StringTokenizer commandLine = new StringTokenizer(command.trim(), " :"); int arguments = commandLine.countTokens(); if (arguments == 0) { //返回错误代码 return true; } else if(arguments > 0) { command = commandLine.nextToken(); } String argument = (String) null; if(arguments > 1) { argument = commandLine.nextToken(); } String argument1 = (String) null; if(arguments > 2) { argument1 = commandLine.nextToken(); } // HELO 命令 if (command.equalsIgnoreCase("HELO")) { if (state.containsKey(CURRENT_HELO_MODE)) { //返回错误代码 ) retur