新闻组

package netkiller.network;

/**
 * @Author 陈景峰(Netkiller)
 *@version 
 **/

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

import javax.servlet.http.*;
import netkiller.security.*;

//javadoc -private -d doc -author -version NNTP.java

public class NNTP 
{
	private boolean debug = false;
	private boolean isConnected = false;
	private static Socket sock 		= null;
	private BufferedReader reader	= null;
	private PrintWriter writer 		= null;	
	private static int port 		= 119;
	
 	public final static String GB18030 	= "GB18030";
 	public final static String UTF8 	= "UTF-8";
 	public final static String GBK 		= "GBK";	
	
	private static final String encode = GB18030;
	//private static final String encode = "UTF-8";
	
	//private static String host	= "news.cdut.edu.cn";
	private static String host	= "news.newsfan.net";
	
	//private static String host	= "news.cn99.com";
	//private static String server	= "news.webking.com.cn";
	
	
	private static int retryTimes 	= 0;
	private StringTokenizer	st		= null;
	//private Vector v = new Vector();
	//private ArrayList al = new ArrayList();
	private String buf = null;
	
	public NNTP(){

	}
	public void setDebug(boolean bool){
		this.debug = bool;	
	}
	private void logs(Object obj){
		System.err.println(obj);	
	}
/**
 * 连接服务器
 **/	
	public void Connect(){
		try{
			sock = new Socket(host,port);
			sock.setSoTimeout(600000);
			//System.out.print(sock);
			reader = new BufferedReader(new InputStreamReader(sock.getInputStream(),encode));
			writer = new PrintWriter(sock.getOutputStream(),true);					
		}catch(Exception e){
			e.printStackTrace();
		}		
	}

/**
 * 连接服务器
 * @param host 服务器地址,ip 或 域名
 * @param port 端口
 * @return boolean false / ture
 **/
	public boolean Connect(String host,int port){
		boolean isConnect = false;
		try{
			sock = new Socket(host,port);
			sock.setSoTimeout(600000);
			//System.out.println(sock);
			reader = new BufferedReader(new InputStreamReader(sock.getInputStream(),encode));
			writer = new PrintWriter(sock.getOutputStream(),true);	
			if(sock != null){
				isConnect = true;
			}				
		}
		
		catch(java.net.UnknownHostException unknown){
			unknown.printStackTrace();
		}
		catch(Exception e){
			e.printStackTrace();
		}
		return isConnect;	
	}

/**
 * 连接服务器
 * @param host 服务器地址,ip 或 域名 ,端口默认119
 * @return boolean false / ture
 **/	
	public boolean Connect(String host){
		return Connect(host,119);
		//HttpServletRequest req;
		//HttpSession host = req.getSession().getAttribute();
		//System.out.println((String)host.getAttribute("newshost"));	
		//System.out.println((String)req.getSession().getAttribute("newshost"));	
	}
	
/**
 * 关闭socket and stream (连接与流)
 * @param 
 * @return
 * @exception Cannot complete Session:Too many tries!
 **/	
	public void close()throws Exception{
		try{
			writer.println("QUIT");
			/*
			while((buf = reader.readLine()) != null) {
				System.out.println(buf);
			}
			*/
			if(writer != null)writer.close();
			if(reader != null)reader.close();
			if(sock != null)sock.close();
			if(retryTimes++ == 10) throw new Exception("Cannot complete Session:Too many tries!");
		}catch(Exception ex){
		}		
	}

/**
 * MODE reader
 * @param 
 * @return void
 **/		
	public void setModeReader(){
		//writer.flush();
		writer.println("MODE reader");
		if(debug){
			//System.err.println(reader.readLine());
		}
	}

/**
 * 列出组列表
 * @param 
 * @return Vector
 * cn.comp.linux.development <br>
 * cn.comp.linux.install <br>
 * cn.comp.linux.admin <br>
 * cn.comp.linux.misc <br>
 * cn.comp.linux.application <br>
 * cn.comp.freebsd <br>
 * cn.comp.minix <br>
 * cn.comp.solaris.admin <br>
 * cn.comp.lang.c <br>
 * cn.comp.lang.php <br>
 * cn.comp.lang.perl <br>
 * cn.comp.lang.python <br>
 * cn.comp.lang.java.development <br>
 * cn.comp.lang.java.jsp <br>
 **/		
	public Vector getNewsList(){
		Vector v = new Vector();
		String tmp = null;
		int n = 1;
		try{
			writer.println("LIST");
			while((buf = reader.readLine()) != null) {
				if(debug){
					System.err.println(buf);
				}				
				if(n>2){
					st = new StringTokenizer(buf);
					st.hasMoreTokens();
					tmp = st.nextToken(" ").toString();
					if(tmp.equals("."))break;

					//v.add(this.Base64Encoder(tmp));
					v.add(tmp);
					st.nextToken();
				}	
				n++;
			}
		}
		catch(Exception e){
			e.printStackTrace();
		}
		
		finally{
			try{
				//this.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
		
		return v;
	}	
	
/**
 * 打开组
 * @param newsgroup 新闻组
 * @return boolean true 组存在，false 组不存在
 * 使用方法： 
 * getNewsList()
 * cn.comp.freebsd <br>
 * cn.comp.solaris.admin <br>
 * cn.comp.lang.c <br>
 *
 * setNewsGroup("cn.comp.freebsd")
 * @see getNewsList()
 **/		
	public boolean setNewsGroup(String newsgroup){
		boolean isSuccess = false;
		try{
			writer.println("GROUP "+newsgroup);
			//writer.println("\r\n");
			//"group cn.comp.lang.c"
			//211 2 6 7 cn.comp.lang.php
			//501 newsgroup
			buf = reader.readLine();
			if(buf.substring(0,3).equals("211")){
				isSuccess = true;
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return isSuccess;
	}
	
/**
 * 列出当前新闻组内的所有文章ID
 * @return ArrayList 文章ID
 * @see setNewsGroup(String newsgroup)
 **/
	public ArrayList getNewsListGroup(){
		ArrayList al = new ArrayList();
		try{
			writer.println("LISTGROUP");
			//listgroup cn.comp.lang.c
			//211 Article list follows
			while((buf = reader.readLine()) != null) {
				if(buf.equals("."))break;
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return al;
	}	
/**
 * 列出 某 新闻组内的所有文章ID
 * @param newsgroup 
 * @return ArrayList 文章ID
 * @see getNewsList()
 * @see setNewsGroup(String newsgroup)
 **/	
	public Vector getNewsListGroup(String newsgroup){
		Vector v = new Vector();
		boolean isAdd = false;
		int i =0;
		try{
			buf = reader.readLine();
			this.logs(buf);
			writer.println("LISTGROUP "+newsgroup);
			
			// writer.flush();
			//System.err.println(writer.checkError());
			
			//listgroup cn.comp.lang.c
			//211 Article list follows
			while((buf = reader.readLine()) != null) {
				//System.err.println("buffer:"+buf);
				if(buf.equals("."))break;
				//211 Article list follows
				//211 list of article numbers follow
				if(buf.length()>3){
					if(buf.substring(0,3).equals("211")){
						isAdd = true;
						continue;
					}
					if(buf.substring(0,3).equals("412")){
						isAdd = false;
						System.err.println(buf +":"+ newsgroup);
						break;
					}
					if(buf.substring(0,3).equals("500")){
						isAdd = false;
						System.err.println(buf);
						break;
					}					
				}
				if(isAdd)v.add(buf);
				if(i++>50)break;
			}			

		}catch(Exception e){
			e.printStackTrace();
		}
		return v;
	}

/**
 * 通过文章ID取得Subject(标题)
 * @param Number 文章ID 
 * @return String 文章标题
 * @see getNewsListGroup()
 * @see getNewsListGroup(String newsgroup)
 **/
	public String getNewsTitle(String Number){
		String strTitle = "";
		try{
			writer.println("HEAD "+Number);
			//listgroup cn.comp.lang.c
			//211 Article list follows
			//buf = reader.readLine();
			while((buf = reader.readLine()) != null) {
				if(buf.equals("."))break;
				if(buf.length()>8){
					if(buf.substring(0,8).equals("Subject:")){
						strTitle = buf.substring(9);
					}
				}
			}			

		}catch(Exception e){
			e.printStackTrace();
		}
		return strTitle;	
	}

	public HashMap getNewsTitle(Vector vector){
		HashMap newsSubject = new HashMap();
		try{
			Enumeration enum = vector.elements();
			while(enum.hasMoreElements()){
				String id = (String)enum.nextElement();
				reader.reset();
				writer.println("HEAD "+id);
				while((buf = reader.readLine()) != null) {
					if(buf.equals("."))break;
					if(buf.length()>8){
						if(buf.substring(0,8).equals("Subject:")){
							newsSubject.put(id,buf.substring(9));
						}
					}
				}
			}			

		}catch(Exception e){
			e.printStackTrace();
		}
		return newsSubject;	
	}

/**
 * 返回文章信息头内容
 * @param Number 文章ID 
 * @return Vector 信息头
 * <br>
 * Path: octopus!not-for-mail <br>
 * From: openunix@163.com<br>
 * Newsgroups: cn.comp.lang.c<br>
 * Subject: ■ web news 测试■<br>
 * Date: 3 Jul 2003 10:09:55 GMT<br>
 * Organization: Chengdu Univ. of Technology.<br>
 * Lines: 394<br>
 * Message-ID: <be0vdj$qo6$1@octopus.cdut.edu.cn><br>
 * NNTP-Posting-Host: 202.103.190.130<br>
 * X-Trace: octopus.cdut.edu.cn 1057226995 27398 202.103.190.130 (3 Jul 2003 10:09:55 GMT)<br>
 * X-Complaints-To: yf@cdut.edu.cn<br>
 * NNTP-Posting-Date: 3 Jul 2003 10:09:55 GMT<br>
 * Xref: octopus cn.comp.lang.c:29 <br>
 *
 * @see getNewsListGroup()
 * @see getNewsListGroup(String newsgroup)
 **/	
	public Vector getNewsHead(String Number){
		Vector vector 			= new Vector();
		boolean sw = true;
		try{
			writer.println("HEAD "+Number);
			buf = reader.readLine();
			buf = reader.readLine();
			while((buf = reader.readLine()) != null) {
				if(buf.equals("."))break;
				/*
				if(buf.length()>4 && !buf.substring(0,4).equals("Path") && sw){
					sw = false;
					continue;	
				}*/
				vector.add(buf);
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return vector;		
	}
/*		
	public String[][] getNewsHead(String Number){
		Vector vector 			= new Vector();
		String arrNewsHead[][]	= new String[64][2];
		StringTokenizer token 	= null;
		boolean sw = true;
		try{
			writer.println("HEAD");
			//listgroup cn.comp.lang.c
			for(int i=0;(buf = reader.readLine()) != null;i++) {
				if(buf.length()>4 && !buf.substring(0,4).equals("Path") && sw){
					sw = false;
					continue;	
				}
				if(buf.length()<3)break;
				token = new StringTokenizer(buf);
				//if(!token.hasMoreTokens())break;
				arrNewsHead[i][0] = token.hasMoreTokens()?(String)token.nextToken():"";
				arrNewsHead[i][1] = token.hasMoreTokens()?(String)token.nextToken():"";
				//System.out.print(arrNewsHead[i][0]);
				//System.out.println(arrNewsHead[i][1]);
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return arrNewsHead;		
	}
*/

/**
 * 返回文章内容
 * @param Number 文章ID 
 * @return Vector 文章内容
 *
 * @see getNewsListGroup()
 * @see getNewsListGroup(String newsgroup)
 **/	
	private Vector getNewsBody(String Number){
		Vector v = new Vector();
		String strTitle = "";
		boolean isAdd = false;
		try{
			writer.println("BODY "+Number);
			while((buf = reader.readLine()) != null) {
				if(buf.length()>3){
					if(buf.substring(0,3).equals("222")){
						isAdd = true;
						continue;
					}
				}
				if(buf.equals("."))break;
				if(isAdd)v.add(buf);			
			}			

		}catch(Exception e){
			e.printStackTrace();
		}
		return v;
	}

/**
 * 返回文章内容
 * @param Number 文章ID 
 * @return Vector 文章内容
 *
 * @see getNewsContent(String Number)
 * @see getNewsArticle(String Number)
 **/	
	public Vector getNewsContent(String Number){
		return this.getNewsBody(Number);
	}
	
/**
 * 返回文章全文内容
 * @param Number 文章ID 
 * @return Vector 文章全文内容
 *
 * @see getNewsContent(String Number)
 **/			
	public Vector getNewsArticle(String Number){
		Vector v = new Vector();
		//article <b4m4kv$n3v$1@octopus.cdut.edu.cn>
		//article 6
		try{
			writer.println("ARTICLE "+Number);
			buf = reader.readLine();
			while((buf = reader.readLine()) != null) {
				if(buf.equals("."))break;
				//if(buf.equals("211 Article list follows")){}
				v.add(buf);
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return v;
	}
/**
 * 下一篇文章
 * @param 
 * @return 
 **/	
	public void setNewsNext(){
		//223 6 <ar08g2$8bi$1@octopus.cdut.edu.cn> Article retrieved; request text separately.
		//421 No next to retrieve.
		try{
			writer.println("NEXT");
			//listgroup cn.comp.lang.c
			//while((buf = reader.readLine()) != null) {
			//	buf.substring(0,3);
			//}
		}catch(Exception e){
			e.printStackTrace();
		}
		//return "1";	
	}
	
/**
 * 发表新帖
 * @param from 用户Email，回信地址
 * @param group 组目的地
 * @param subject 标题
 * @param content 内容
 * @return boolean true发贴成功,false 发贴失败
 * <br>setPostNews("openunix@163.com","cn.comp.linux.admin","hi all test","chen \n chen \n 中国防大学!!!!! \n"); 
 **/	
	public boolean setPostNews(String from,String group,String subject,String content){
		boolean isSuccess = false;
		try{
			setModeReader();
			writer.println("POST");
			writer.println("From: "+from);
			writer.println("Newsgroups: "+group);
			writer.println("Subject: "+subject);
			writer.println("");
			writer.println(content);
			writer.println(".");
			writer.println("QUIT");
			while((buf = reader.readLine()) != null) {
				if(buf.substring(0,3).equals("240"))
				isSuccess = true;
				//System.out.println("Article posted");
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return isSuccess;	
	}

/**
 * 回复组 , 回复用户的帖子
 * @param from 用户Email，回信地址
 * @param group 组目的地
 * @param subject 标题
 * @param content 内容
 * @param ref 参考Message-ID，就是原贴Message-ID
 * @return boolean true发贴成功,false 发贴失败
 * <br>setPostNews("openunix@163.com","cn.comp.linux.admin","hi all test","chen \n chen \n 中国防大学!!!!! <br>","<be954o$ugi$1@octopus.cdut.edu.cn>");
 * Message-ID: <be954o$ugi$1@octopus.cdut.edu.cn><br>
 * References: <bds8v2$qn8$1@octopus.cdut.edu.cn><br>
 **/	
	public boolean setReNews(String from,String group,String subject,String content,String ref){
		boolean isSuccess = false;
		try{
			setModeReader();
			writer.println("POST");
			writer.println("From: "+from);
			writer.println("Newsgroups: "+group);
			writer.println("Subject: "+subject);
			writer.println("References: "+ref);
			writer.println("");
			writer.println(content);
			writer.println(".");
			writer.println("QUIT");
			while((buf = reader.readLine()) != null) {
				if(buf.substring(0,3).equals("240"))
				isSuccess = true;
				//System.out.println("Article posted");
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return isSuccess;	
	}
/**
 * 查看文章状态
 * @param Number 文章ID
 * @return String 文件ID，Message-ID:,status
 **/	
	public String getNewsStat(String Number){
		String stat = null;
		try{
			setModeReader();
			writer.println("STAT "+Number);
			while((buf = reader.readLine()) != null) {
				if(buf.substring(0,3).equals("223")){
					stat = buf;
					System.out.println(buf);
					//System.out.println("Article posted");
				}
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return stat;
	}
/**
 * ISO-8859-1 ==> GBK
 **/
 	
	public String toUnicode(String in,String out,String strSource){
		String strTarget = null;
		try{
			strTarget = new String(strSource.getBytes(in),out); 
		}catch(Exception e){
			e.printStackTrace();
		}
		return strTarget;
	}

/**
 * ISO-8859-1 ==> GBK
 * @see toGBK(String strSource)
 **/
	public static String toChinese(String strvalue)
   	{
        try{
            if(strvalue==null)
               return null;
            else
            {
               strvalue = new String(strvalue.getBytes("ISO8859_1"), "GBK");
               return strvalue;
        }
        }catch(Exception e){
              return null;
        }
   	}
/*	
	public static void checkStatus(String msg) throws Exception
	{
		System.out.println(msg);
		if (msg.substring(0,3).equals("+OK"))
		return;
		else 
		throw new Exception("Cannot Complete Session!");
	}

	public static void performSession() throws Exception
	{
			if(retryTimes++ == 10) throw new Exception("Cannot complete Session:Too many tries!");
			performSession();
		}
	}
*/	
	public static String toUnicode(String value){ 
    	try{ 
            if(value!=null) {
                 value = new String(value.getBytes("ISO8859_1"), "UTF-8");
        	}
        }catch(Exception e){ 
              return null; 
        } 
        return value; 
   	}   
	public static final String Base64Encoder(String code) {
		String tmp = null;
		try{
			tmp = new sun.misc.BASE64Encoder().encode(code.getBytes());
		}
		catch(Exception e){
			System.out.println(e.toString());
		}
		return tmp;
	}

	public static final String Base64Decoder(String code) {
		String tmp = null;
		try{

			tmp = new String(new sun.misc.BASE64Decoder().decodeBuffer(code)).toString();

		}
		catch(Exception e){
			System.out.println(e.toString());
		}
		return tmp;
	}	

	public static void main(String[] args) 
	{
		try{
/*			
		BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
		BufferedWriter writer = new BufferedWriter((System.out),true);
		//BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(System.out),true);
		writer.print("Enter The POP3 Server:");
		server = reader.readLine();
		writer.print("Enter The Server Port (default is 110):");
		String tmp = reader.readLine();
		try{
		port = Integer.parseInt(tmp);
		}
		catch(Exception e){
		}
		writer.print("Enter Your Username:");
		userid = reader.readLine();
		writer.print("Enter Your Password:");
		passwd = reader.readLine();
		reader.close();
*/		
		//performSession();
			NNTP n = new NNTP();
			n.setDebug(true);
			n.Connect();
			Vector v = new Vector();
			System.out.print(n.Connect("news.newsfan.net",119));
			
			n.setModeReader();
			
			v = n.getNewsList();
			
			for(int i=0;i<v.size();i++){
				System.out.println((String)v.get(i));
			}
			
			
			//n.setNewsGroup("cn.comp.lang.python");
			
			System.out.println(n.setNewsGroup("测试中文"));
			
			//System.out.println(n.getNewsStat("24"));
			//n.getNewsHead("24");
			//ArrayList al = n.getNewsListGroup();
			
			//v = n.getNewsListGroup("精华信区.计算机");
			//v = n.getNewsListGroup("测试中文");
			//v = n.getNewsListGroup("1950");
			
			//Vector v = n.getNewsListGroup("cn.comp.linux.admin");
			/*
			System.out.println(v.size());
			for(int i=0;i<v.size();i++){
				System.out.print(i+">"+(String)v.get(i));
				//System.out.println(n.getNewsTitle((String)v.get(i)));
			}*/
			/*
			for(int i=0;i<v.size();i++){
				
			}
			*/
			//System.out.println(n.getNewsTitle("4370"));
			
			//Vector v = n.getNewsArticle("20");
			
			//Vector v = n.getNewsArticle("24");
			//Vector v = n.getNewsHead("33");
			/*
			for(int i=0;i<v.size();i++){
				System.out.println((String)v.get(i));
			}
			*/
			//n.setPostNews("openunix@163.com","cn.comp.linux.admin","hi all test","chen \n chen \n 中国防大学!!!!! \n"); 
			/*
			String head[][] =null;
			 head = n.getNewsHead("24");
			for(int i=0;i<head.length;i++){
				System.out.print(head[i][0]);
			}
			*/
			n.close();
		}catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println("Done");
	}
}