chatprotocol.java

基于jxta的局域网P2P文件共享,可以实现局域网中的文件p2p共享,实现文件快速传输及交流

package connex.plugins.chat;

import net.jxta.endpoint.Message;
import net.jxta.endpoint.StringMessageElement;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class ChatProtocol {
  protected static String version = "1.00";

  /* Message types*/
  protected static final String chatMessage = "chatMessage";

  /*
   * ChatService also defines it own protocol. Requests arrive as a JXTA
   * Message with the following elements:
   */
  //Protocol header
  protected static final String nameSpace = "ConneXChat";
  protected static final String versionTag = "version";
  protected static final String membIDTag = "memberID";
  protected static final String membNameTag = "membName";
  protected static final String typeTag = "type";

  //protocol data
  protected static final String messageTag = "messageTag";

  /**
   * create a new chatMessage
   * @param messageText String
   * @return Message
   */
  protected static Message createChatMessage(String messageText, String Id,
                                             String name) {
    Message msg = createMessage(ChatProtocol.chatMessage, Id, name);
    /*Messagedata*/
    msg.addMessageElement(ChatProtocol.nameSpace,
                          new
                          StringMessageElement(ChatProtocol.messageTag,
                                               messageText, null));

    return msg;
  }

  /**
   * Create the Message Header
   * @param messageText String
   * @return Message
   */
  protected static Message createMessage(String type, String Id, String name) {
    Message msg = new Message();
    /* version */
    msg.addMessageElement(ChatProtocol.nameSpace,
                          new
                          StringMessageElement(ChatProtocol.
                                               versionTag,
                                               ChatProtocol.version, null));
    /* MemberID*/
    msg.addMessageElement(ChatProtocol.nameSpace,
                          new
                          StringMessageElement(ChatProtocol.
                                               membIDTag,
                                               Id, null));
    /* MemberName*/
    msg.addMessageElement(ChatProtocol.nameSpace,
                          new
                          StringMessageElement(ChatProtocol.membNameTag
                                               ,
                                               name, null));

    /* type */
    msg.addMessageElement(ChatProtocol.nameSpace,
                          new
                          StringMessageElement(ChatProtocol.typeTag,
                                               type, null));
    return msg;
  }

}