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

public class XChatp
		implements PipeMsgListener
{
	/**
	*  實現(xiàn)接口PipeMsgListener,每當(dāng)有消息傳送到輸入管道的時候，事件將被捕獲---------------------------------(1)
	*/
	public void pipeMsgEvent(PipeMsgEvent event)
	{
		System.out.println("come a message!");
		//MessageImpl mi = (MessageImpl)event.getMessage();
		Message mi = (Message)event.getMessage();
		String message = mi.getString(BaseMessage.CHAT);
		if( this.closeConnect(message)) return;
		String temp = mi.getString(BaseMessage.OP);
		toScreen(temp + ":" + message);
	}

	/**
	*  顯示字符串---------------------------------(2)
	*/
	public void toScreen(String s) { System.out.println(s); }

	/**
	*  根據(jù)傳送的字符串判斷是否關(guān)閉通信---------------------------------(3)
	*/
	public boolean closeConnect(String s) { if(s.equals("#bye#"))return true;return false; }

	/**
	*  獲取從鍵盤輸入的字符串---------------------------------(4)
	*/
	public String getStrFromKey()
	{
		try
		{
			BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
			return br.readLine();
		}catch(IOException eoe)
		{
			System.out.println("從鍵盤讀取字符串發(fā)生I/O錯誤!");
			System.exit(-1);
		}
		return null;
	}

	public static void main(String args[])
	{
		XChatp xc = new XChatp();
		P2PSocket pps = new P2PSocket();
		pps.setInputPipeName("PP");
		pps.setInListener(xc);
		pps.bind();
		pps.setOutListener(pps);
		pps.connect("PP");
		while(true)
			pps.send(new BaseMessage().newChatMessage(xc.getStrFromKey(),
					"Peer1",pps.getInputPipeName()));
	}
}