xwebserver.java

该代码是《JXTA-java P2P网络编程技术》一书的源代码

/**《JXTA网络编程》例程
*"第五章  JXTA深入编程" 即时消息软件XWeb
*
@作者 慈黎利
@单位 清华大学计算机系软件所知识工程组
@版本 1.0
@联系方式 [e-mail]
@描述 利用P2PSocket 将网站信息发布到P2P网络
Copyright 2002
*/

import java.io.*;
import java.net.*;
import net.jxta.pipe.*; 
import net.jxta.impl.endpoint.*;
import demo.p2psocket.*;


//源程序 XWebServer.java

public class XWebServer implements PipeMsgListener {
	P2PSocket pps=new P2PSocket(); 
	BaseMessage bm=new BaseMessage();
	String default_url="http://127.0.0.1:8080/demo/";
	
	public XWebServer() {
		pps.setInputPipeName("pp");
		pps.setInListener(this);
		pps.bind();
	}
	/**
	* 实现InputPipe 的监听器
	* @param event 获得消息事件
	*/
	public void pipeMsgEvent ( PipeMsgEvent event ){
		String temp=null;
		MessageImpl mi=(MessageImpl) event.getMessage();
		
		temp=mi.getString(bm.WEB_MESSAGE_TYPE);
		if (temp.equals(bm.WEB_REQUEST))  
			{ doWEBRequest(mi); return;}
		if (temp.equals(bm.WEB_REQUEST_FIRST))
			{ doWebRequestFirst(mi);return;}
	}
	
	/**
	* 处理Web页面的请求，将Web页面的内容读入流中发送到连入方
	* @param mi 获得的Message
	*/
	public void doWEBRequest(MessageImpl mi) {
		System.out.println("捕获一个网站内容请求!");		
		String url=mi.getString(bm.WEB_URL);
		pps.send(bm.newWEBMessage(url2stream(url),pps.getOutputPipeName(),
			pps.getInputPipeName(),bm.WEB_CONTENT,"Temp"));
	}
	
	/**
	* 处理第一次连接的请求，在获得连接方的PipeAdvertisment后与其建立连接，发送首页
	* @param mi 获得的Message
	*/
	public void doWebRequestFirst(MessageImpl mi) {
		System.out.println("捕获一个首次连接请求!");	
		MessageElementImpl mei=(MessageElementImpl)mi.getElement(bm.WEB_REQUEST_FIRST);
		String file_name=mi.getString(bm.WEB_URL);
		saveAdv(mei.getStream(),file_name);
		pps.setOutputPipeName(file_name);
		pps.setOutListener(pps);
		pps.connect(file_name);
		pps.send(bm.newWEBMessage(url2stream(null),pps.getOutputPipeName(),
			pps.getInputPipeName(),bm.WEB_CONTENT,"Temp"));	
	}
	
	/**
	* 把流中的信息写道文件中
	* @param is  数据源流
	* @param fname  将要写入的文件
	*/
	public void saveAdv(InputStream is,String fname) {
		int length;
		byte buf[]=new byte[1024];
		try {
			FileOutputStream fos=new FileOutputStream("adv/"+fname+".xml");
			BufferedOutputStream bos=new BufferedOutputStream(fos);
			BufferedInputStream bis=new BufferedInputStream(is);
			while ((length=bis.read(buf,0,1024))!=-1) {
				bos.write(buf,0,length);
				bos.flush();
			}
			bis.close();
			bos.close();
			fos.close();			
		}catch (IOException ioe) {
			System.out.println("写入文件错误:"+ioe);		
		}			
	}
	/**
	* 把指定的 URL中的内容读入流中
	* @param 指定的url
	* @return 返回url得到的流
	*/
	public InputStream url2stream(String url) {
		try {
			String a=default_url;
			if (url!=null) a=a+url;
			System.out.println(a);
			URL link=new URL(a);
			return link.openStream();
		}catch (Exception e) {
			System.err.println("出错!");
			System.exit(-1);
		}
		return null;
	}
	public static void main(String args[]) {
		XWebServer xwebs=new XWebServer();
	}
}