package first;import java.io.IOException;
import java.util.Enumeration;import net.jxta.discovery.DiscoveryService;
import net.jxta.document.Advertisement;
import net.jxta.document.AdvertisementFactory;
import net.jxta.endpoint.Message;
import net.jxta.endpoint.Message.ElementIterator;
import net.jxta.endpoint.MessageElement;
import net.jxta.endpoint.StringMessageElement;
import net.jxta.id.IDFactory;
import net.jxta.peergroup.PeerGroup;
import net.jxta.pipe.InputPipe;
import net.jxta.pipe.OutputPipe;
import net.jxta.pipe.PipeService;
import net.jxta.platform.NetworkConfigurator;
import net.jxta.platform.NetworkManager;
import net.jxta.platform.NetworkManager.ConfigMode;
import net.jxta.protocol.PipeAdvertisement;public class Chat {private NetworkManager networkManager = null;// 配置private PeerGroup netWorkPeerGroup = null;// 对等组private DiscoveryService discoveryService = null;// 发现服务private PipeService pipeService = null;// 管道服务private InputPipe inputPipe = null;// 输入管道private OutputPipe outputPipe = null;// 输出管道Enumeration<Advertisement> enumeration = null;// 初始化配置public void init(String name) {try {// 相当于jxta的配置,如果不写的话会出现配置页面,手动配置也可networkManager = new NetworkManager(ConfigMode.ADHOC, name);// 在一台pc测试的时候,端口号不能一致,这里修改下端口号NetworkConfigurator configurator = networkManager.getConfigurator();configurator.setTcpPort(9703);configurator.save();// 启动创建对等组// netWorkPeerGroup=new NetPeerGroupFactory().getInterface();netWorkPeerGroup = networkManager.startNetwork();// 初始化discoveryService和pipeServicediscoveryService = netWorkPeerGroup.getDiscoveryService();pipeService = netWorkPeerGroup.getPipeService();} catch (Exception e) {e.printStackTrace();}}// 创建一个管道通告public PipeAdvertisement createPipeAdvertisement(String name) {PipeAdvertisement advertisement = (PipeAdvertisement) AdvertisementFactory.newAdvertisement(PipeAdvertisement.getAdvertisementType());advertisement.setPipeID(IDFactory.newPipeID(netWorkPeerGroup.getPeerGroupID()));advertisement.setName(name);advertisement.setType(PipeService.UnicastType);return advertisement;}// 发布通告public void publish(PipeAdvertisement advertisement) {try {discoveryService.publish(advertisement);discoveryService.remotePublish(advertisement);} catch (IOException e) {e.printStackTrace();}}// 初始化管道public void initPipe(String name) {// 管道通告,相当于名片PipeAdvertisement advertisement = createPipeAdvertisement(name);// 发布 告诉别人我是谁publish(advertisement);try {// 初始化管道inputPipe = pipeService.createInputPipe(advertisement);// 输入通道} catch (IOException e) {e.printStackTrace();}}// 找你想聊的人public PipeAdvertisement discover(String name) {int count = 3;// 担心一次连不上while (count-- > 0) {try {// 先从本地缓存里头找enumeration = discoveryService.getLocalAdvertisements(DiscoveryService.ADV, "Name", name);if (enumeration != null && enumeration.hasMoreElements()) {PipeAdvertisement pipeAdvertisement = (PipeAdvertisement) enumeration.nextElement();return pipeAdvertisement;}discoveryService.getRemoteAdvertisements(null,DiscoveryService.ADV, "Name", name, 1, null);} catch (IOException e) {e.printStackTrace();}}return null;}// 发送信息public void sendMessage(String name, String msg) {try {outputPipe = pipeService.createOutputPipe(discover(name), 0);// 发送的信息Message message = new Message();StringMessageElement string = new StringMessageElement("data", msg,null);message.addMessageElement(string);outputPipe.send(message);} catch (IOException e) {e.printStackTrace();}}// 接收消息public void receiveMessage() {while (true) {try {// 接收Message message = inputPipe.waitForMessage();// 解析获取到的信息ElementIterator messageElements = message.getMessageElements();if (messageElements != null) {while (messageElements.hasNext()) {MessageElement next = messageElements.next();System.out.println("接收到消息:" + next.toString());}}} catch (InterruptedException e) {e.printStackTrace();}}}public void stop() {// 停止服务networkManager.stopNetwork();}public void start() {init("peer1");initPipe("peer1");discover("peer2");sendMessage("peer2", "hello!!!!");}public static void main(String[] args) {Chat chat = new Chat();chat.start();}
}