package com.talk;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.util.Scanner;
//讓該類實現(xiàn)Runnable接口，該類的實例可以作為線程的target
public class MulticastSocketTest implements Runnable{

  //使用常量作為本程序多點廣播的IP地址
  private static final String BROADCAST_IP="230.0.0.1";
  //使用常量作為本程序的多點廣播的目的地端口
  public static final int BROADCAST_PORT=3000;
  //定義每個數(shù)據(jù)報大小最大為4kb
  private static final int DATA_LEN=4096;
  //定義本程序的MulticastSocket實例
  private MulticastSocket socket=null;
  private InetAddress broadcastAddress=null;
  private Scanner scan=null;

  //定義接收網(wǎng)絡(luò)數(shù)據(jù)的字節(jié)數(shù)組
  byte[] inBuff=new byte[DATA_LEN];
  //以指定字節(jié)數(shù)組創(chuàng)建準備接收數(shù)據(jù)的MulticastSocket對象
  private DatagramPacket inPacket =new DatagramPacket(inBuff, inBuff.length);

  //定義一個用于發(fā)送的DatagramPacket對象
  private DatagramPacket outPacket=null;

  public void init() throws IOException{
   //創(chuàng)建鍵盤輸入流
   Scanner scan=new Scanner(System.in);
   //創(chuàng)建用于發(fā)送、接收數(shù)據(jù)的MulticastSocket對象，由于該MulticastSocket需要接收數(shù)據(jù)，所以有指定端口
   socket=new MulticastSocket(BROADCAST_PORT);
   broadcastAddress=InetAddress.getByName(BROADCAST_IP);

   //將該socket加入到指定的多點廣播地址
   socket.joinGroup(broadcastAddress);
   //設(shè)置本MulticastSocket發(fā)送的數(shù)據(jù)報會被回送到自身
   socket.setLoopbackMode(false);

   //初始化發(fā)送用的DatagramSocket，它包含一個長度為0的字節(jié)數(shù)組
   outPacket =new DatagramPacket(new byte[0], 0, broadcastAddress, BROADCAST_PORT);

   //啟動本實例的run()方法作為線程執(zhí)行體的線程
   new Thread(this).start();

   //不斷的讀取鍵盤輸入
   while(scan.hasNextLine()){
    //將鍵盤輸入的一行字符轉(zhuǎn)換成字節(jié)數(shù)組
    byte [] buff=scan.nextLine().getBytes();
    //設(shè)置發(fā)送用的DatagramPacket里的字節(jié)數(shù)據(jù)
    outPacket.setData(buff);
    //發(fā)送數(shù)據(jù)報
    socket.send(outPacket);
   }
   socket.close();
  }

  public void run() {
   // TODO Auto-generated method stub

   while(true){
    //讀取Socket中的數(shù)據(jù)，讀到的數(shù)據(jù)放入inPacket所封裝的字節(jié)組里
    try {
      socket.receive(inPacket);
      //打印從socket讀取到的內(nèi)容
      System.out.println("聊天信息："+new String(inBuff,0,inPacket.getLength()));
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }

    if(socket!=null){
      //讓該socket離開多點IP廣播地址
      try {
       socket.leaveGroup(broadcastAddress);
       //關(guān)閉socket對象
       socket.close();
      } catch (IOException e) {
       // TODO Auto-generated catch block
       e.printStackTrace();
      }

    }

    System.exit(1);
   }
  }
  public static void main(String[] args) {
   try {
    new MulticastSocketTest().init();
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }
}

package com.talk;
import java.net.SocketAddress;
import com.bank.ChatFrame;
public class UserInfo
{
  // 該用戶的圖標
  private String icon;
  // 該用戶的名字
  private String name;
  // 該用戶的MulitcastSocket所在的IP和端口
  private SocketAddress address;
  // 該用戶失去聯(lián)系的次數(shù)
  private int lost;
  // 該用戶對應(yīng)的交談窗口
  private ChatFrame chatFrame;
  public UserInfo(){}
  // 有參數(shù)的構(gòu)造器
  public UserInfo(String icon , String name
   , SocketAddress address , int lost)
  {
   this.icon = icon;
   this.name = name;
   this.address = address;
   this.lost = lost;
  }
  // 省略所有成員變量的setter和getter方法
  // icon的setter和getter方法
  public void setIcon(String icon)
  {
   this.icon = icon;
  }
  public String getIcon()
  {
   return this.icon;
  }
  // name的setter和getter方法
  public void setName(String name)
  {
   this.name = name;
  }
  public String getName()
  {
   return this.name;
  }
  // address的setter和getter方法
  public void setAddress(SocketAddress address)
  {
   this.address = address;
  }
  public SocketAddress getAddress()
  {
   return this.address;
  }
  // lost的setter和getter方法
  public void setLost(int lost)
  {
   this.lost = lost;
  }
  public int getLost()
  {
   return this.lost;
  }
  // chatFrame的setter和getter方法
  public void setChatFrame(ChatFrame chatFrame)
  {
   this.chatFrame = chatFrame;
  }
  public ChatFrame getChatFrame()
  {
   return this.chatFrame;
  }
  // 使用address作為該用戶的標識，所以根據(jù)address作為
  // 重寫hashCode()和equals方法的標準
  public int hashCode()
  {
   return address.hashCode();
  }
  public boolean equals(Object obj)
  {
   if (obj != null && obj.getClass() == UserInfo.class)
   {
    UserInfo target = (UserInfo)obj;
    if (address != null)
    {
      return address.equals(target.getAddress());
    }
   }
   return false;
  }
}

package com.talk;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.net.SocketAddress;
import java.util.ArrayList;
import javax.swing.JOptionPane;
public class ComUtil
{
  // 定義本程序通信所使用的字符集
  public static final String CHARSET = "utf-8";
  // 使用常量作為本程序的多點廣播IP地址
  private static final String BROADCAST_IP
   = "230.0.0.1";
  // 使用常量作為本程序的多點廣播目的的端口
  // DatagramSocket所用的的端口為該端口+1。
  public static final int BROADCAST_PORT = 30000;
  // 定義每個數(shù)據(jù)報的最大大小為4K
  private static final int DATA_LEN = 4096;
  // 定義本程序的MulticastSocket實例
  private MulticastSocket socket = null;
  // 定義本程序私聊的Socket實例
  private DatagramSocket singleSocket = null;
  // 定義廣播的IP地址
  private InetAddress broadcastAddress = null;
  // 定義接收網(wǎng)絡(luò)數(shù)據(jù)的字節(jié)數(shù)組
  byte[] inBuff = new byte[DATA_LEN];
  // 以指定字節(jié)數(shù)組創(chuàng)建準備接受數(shù)據(jù)的DatagramPacket對象
  private DatagramPacket inPacket =
   new DatagramPacket(inBuff , inBuff.length);
  // 定義一個用于發(fā)送的DatagramPacket對象
  private DatagramPacket outPacket = null;
  // 聊天的主界面程序
  private LanTalk lanTalk;
  // 構(gòu)造器，初始化資源
  public ComUtil(LanTalk lanTalk) throws Exception
  {
   this.lanTalk = lanTalk;
   // 創(chuàng)建用于發(fā)送、接收數(shù)據(jù)的MulticastSocket對象
   // 因為該MulticastSocket對象需要接收，所以有指定端口
   socket = new MulticastSocket(BROADCAST_PORT);
   // 創(chuàng)建私聊用的DatagramSocket對象
   singleSocket = new DatagramSocket(BROADCAST_PORT + 1);
   broadcastAddress = InetAddress.getByName(BROADCAST_IP);
   // 將該socket加入指定的多點廣播地址
   socket.joinGroup(broadcastAddress);
   // 設(shè)置本MulticastSocket發(fā)送的數(shù)據(jù)報被回送到自身
   socket.setLoopbackMode(false);
   // 初始化發(fā)送用的DatagramSocket，它包含一個長度為0的字節(jié)數(shù)組
   outPacket = new DatagramPacket(new byte[0]
    , 0 , broadcastAddress , BROADCAST_PORT);
   // 啟動兩個讀取網(wǎng)絡(luò)數(shù)據(jù)的線程
   new ReadBroad().start();
   Thread.sleep(1);
   new ReadSingle().start();
  }
  // 廣播消息的工具方法
  public void broadCast(String msg)
  {
   try
   {
    // 將msg字符串轉(zhuǎn)換字節(jié)數(shù)組
    byte[] buff = msg.getBytes(CHARSET);
    // 設(shè)置發(fā)送用的DatagramPacket里的字節(jié)數(shù)據(jù)
    outPacket.setData(buff);
    // 發(fā)送數(shù)據(jù)報
    socket.send(outPacket);
   }
   // 捕捉異常
   catch (IOException ex)
   {
    ex.printStackTrace();
    if (socket != null)
    {
      // 關(guān)閉該Socket對象
      socket.close();
    }
    JOptionPane.showMessageDialog(null
      , "發(fā)送信息異常，請確認30000端口空閑，且網(wǎng)絡(luò)連接正常！"
      , "網(wǎng)絡(luò)異常", JOptionPane.ERROR_MESSAGE);
    System.exit(1);
   }
  }
  // 定義向單獨用戶發(fā)送消息的方法
  public void sendSingle(String msg , SocketAddress dest)
  {
   try
   {
    // 將msg字符串轉(zhuǎn)換字節(jié)數(shù)組
    byte[] buff = msg.getBytes(CHARSET);
    DatagramPacket packet = new DatagramPacket(buff
      , buff.length , dest);
    singleSocket.send(packet);
   }
   // 捕捉異常
   catch (IOException ex)
   {
    ex.printStackTrace();
    if (singleSocket != null)
    {
      // 關(guān)閉該Socket對象
      singleSocket.close();
    }
    JOptionPane.showMessageDialog(null
      , "發(fā)送信息異常，請確認30001端口空閑，且網(wǎng)絡(luò)連接正常！"
      , "網(wǎng)絡(luò)異常", JOptionPane.ERROR_MESSAGE);
    System.exit(1);
   }
  }
  // 不斷從DatagramSocket中讀取數(shù)據(jù)的線程
  class ReadSingle extends Thread
  {
   // 定義接收網(wǎng)絡(luò)數(shù)據(jù)的字節(jié)數(shù)組
   byte[] singleBuff = new byte[DATA_LEN];
   private DatagramPacket singlePacket =
    new DatagramPacket(singleBuff , singleBuff.length);
   public void run()
   {
    while (true)
    {
      try
      {
       // 讀取Socket中的數(shù)據(jù)。
       singleSocket.receive(singlePacket);
       // 處理讀到的信息
       lanTalk.processMsg(singlePacket , true);
      }
      // 捕捉異常
      catch (IOException ex)
      {
       ex.printStackTrace();
       if (singleSocket != null)
       {
        // 關(guān)閉該Socket對象
        singleSocket.close();
       }
       JOptionPane.showMessageDialog(null
        , "接收信息異常，請確認30001端口空閑，且網(wǎng)絡(luò)連接正常！"
        , "網(wǎng)絡(luò)異常", JOptionPane.ERROR_MESSAGE);
       System.exit(1);
      }
    }
   }
  }
  // 持續(xù)讀取MulticastSocket的線程
  class ReadBroad extends Thread
  {
   public void run()
   {
    while (true)
    {
      try
      {
       // 讀取Socket中的數(shù)據(jù)。
       socket.receive(inPacket);
       // 打印輸出從socket中讀取的內(nèi)容
       String msg = new String(inBuff , 0
        , inPacket.getLength() , CHARSET);
       // 讀到的內(nèi)容是在線信息
       if (msg.startsWith(YeekuProtocol.PRESENCE)
        && msg.endsWith(YeekuProtocol.PRESENCE))
       {
        String userMsg = msg.substring(2
          , msg.length() - 2);
        String[] userInfo = userMsg.split(YeekuProtocol
          .SPLITTER);
        UserInfo user = new UserInfo(userInfo[1]
          , userInfo[0] , inPacket.getSocketAddress(), 0);
        // 控制是否需要添加該用戶的旗標
        boolean addFlag = true;
        ArrayList<Integer> delList = new ArrayList<>();
        // 遍歷系統(tǒng)中已有的所有用戶,該循環(huán)必須循環(huán)完成
        for (int i = 1 ; i < lanTalk.getUserNum() ; i++ )
        {
          UserInfo current = lanTalk.getUser(i);
          // 將所有用戶失去聯(lián)系的次數(shù)加1
          current.setLost(current.getLost() + 1);
          // 如果該信息由指定用戶發(fā)送過來
          if (current.equals(user))
          {
           current.setLost(0);
           // 設(shè)置該用戶無須添加
           addFlag = false;
          }
          if (current.getLost() > 2)
          {
           delList.add(i);
          }
        }
        // 刪除delList中的所有索引對應(yīng)的用戶
        for (int i = 0; i < delList.size() ; i++)
        {
          lanTalk.removeUser(delList.get(i));
        }
        if (addFlag)
        {
          // 添加新用戶
          lanTalk.addUser(user);
        }
       }
       // 讀到的內(nèi)容是公聊信息
       else
       {
        // 處理讀到的信息
        lanTalk.processMsg(inPacket , false);
       }
      }
      // 捕捉異常
      catch (IOException ex)
      {
       ex.printStackTrace();
       if (socket != null)
       {
        // 關(guān)閉該Socket對象
        socket.close();
       }
       JOptionPane.showMessageDialog(null
        , "接收信息異常，請確認30000端口空閑，且網(wǎng)絡(luò)連接正常！"
        , "網(wǎng)絡(luò)異常", JOptionPane.ERROR_MESSAGE);
       System.exit(1);
      }
    }
   }
  }
}

package com.talk;
import java.awt.Color;
import java.awt.Component;
import java.awt.Dimension;
import java.awt.Font;
import java.awt.Graphics;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.net.DatagramPacket;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.text.DateFormat;
import java.util.Date;
import javax.swing.DefaultListModel;
import javax.swing.ImageIcon;
import javax.swing.JFrame;
import javax.swing.JList;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.ListCellRenderer;
import com.bank.ChatFrame;
import com.bank.LoginFrame;
public class LanTalk extends JFrame
{
  private DefaultListModel<UserInfo> listModel
   = new DefaultListModel<>();
  // 定義一個JList對象
  private JList<UserInfo> friendsList = new JList<>(listModel);
  // 定義一個用于格式化日期的格式器
  private DateFormat formatter = DateFormat.getDateTimeInstance();
  public LanTalk()
  {
   super("局域網(wǎng)聊天");
   // 設(shè)置該JList使用ImageCellRenderer作為單元格繪制器
   friendsList.setCellRenderer(new ImageCellRenderer());
   listModel.addElement(new UserInfo("all" , "所有人"
    , null , -2000));
   friendsList.addMouseListener(new ChangeMusicListener());
   add(new JScrollPane(friendsList));
   setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
   setBounds(2, 2, 160 , 600);
  }
  // 根據(jù)地址來查詢用戶
  public UserInfo getUserBySocketAddress(SocketAddress address)
  {
   for (int i = 1 ; i < getUserNum() ; i++)
   {
    UserInfo user = getUser(i);
    if (user.getAddress() != null
      && user.getAddress().equals(address))
    {
      return user;
    }
   }
   return null;
  }
  // ------下面四個方法是對ListModel的包裝------
  // 向用戶列表中添加用戶
  public void addUser(UserInfo user)
  {
   listModel.addElement(user);
  }
  // 從用戶列表中刪除用戶
  public void removeUser(int pos)
  {
   listModel.removeElementAt(pos);
  }
  // 獲取該聊天窗口的用戶數(shù)量
  public int getUserNum()
  {
   return listModel.size();
  }
  // 獲取指定位置的用戶
  public UserInfo getUser(int pos)
  {
   return listModel.elementAt(pos);
  }
  // 實現(xiàn)JList上的鼠標雙擊事件的監(jiān)聽器
  class ChangeMusicListener extends MouseAdapter
  {
   public void mouseClicked(MouseEvent e)
   {
    // 如果鼠標的擊鍵次數(shù)大于2
    if (e.getClickCount() >= 2)
    {
      // 取出鼠標雙擊時選中的列表項
      UserInfo user = (UserInfo)friendsList.getSelectedValue();
      // 如果該列表項對應(yīng)用戶的交談窗口為null
      if (user.getChatFrame() == null)
      {
       // 為該用戶創(chuàng)建一個交談窗口，并讓該用戶引用該窗口
       user.setChatFrame(new ChatFrame(null , user));
      }
      // 如果該用戶的窗口沒有顯示，則讓該用戶的窗口顯示出來
      if (!user.getChatFrame().isShowing())
      {
       user.getChatFrame().setVisible(true);
      }
    }
   }
  }
  /**
  * 處理網(wǎng)絡(luò)數(shù)據(jù)報，該方法將根據(jù)聊天信息得到聊天者，
  * 并將信息顯示在聊天對話框中。
  * @param packet 需要處理的數(shù)據(jù)報
  * @param single 該信息是否為私聊信息
  */
  public void processMsg(DatagramPacket packet , boolean single)
  {
   // 獲取該發(fā)送該數(shù)據(jù)報的SocketAddress
   InetSocketAddress srcAddress = (InetSocketAddress)
    packet.getSocketAddress();
   // 如果是私聊信息，則該Packet獲取的是DatagramSocket的地址，
   // 將端口減1才是對應(yīng)的MulticastSocket的地址
   if (single)
   {
    srcAddress = new InetSocketAddress(srcAddress.getHostName()
      , srcAddress.getPort() - 1);
   }
   UserInfo srcUser = getUserBySocketAddress(srcAddress);
   if (srcUser != null)
   {
    // 確定消息將要顯示到哪個用戶對應(yīng)窗口上。
    UserInfo alertUser = single ? srcUser : getUser(0);
    // 如果該用戶對應(yīng)的窗口為空，顯示該窗口
    if (alertUser.getChatFrame() == null)
    {
      alertUser.setChatFrame(new ChatFrame(null , alertUser));
    }
    // 定義添加的提示信息
    String tipMsg = single ? "對您說：" : "對大家說：";
    try{
      // 顯示提示信息
      alertUser.getChatFrame().addString(srcUser.getName()
       + tipMsg + "......................("
       + formatter.format(new Date()) + ")\n"
       + new String(packet.getData() , 0 , packet.getLength()
       , ComUtil.CHARSET) + "\n");
    } catch (Exception ex) { ex.printStackTrace(); }
    if (!alertUser.getChatFrame().isShowing())
    {
      alertUser.getChatFrame().setVisible(true);
    }
   }
  }
  // 主方法，程序的入口
  public static void main(String[] args)
  {
   LanTalk lanTalk = new LanTalk();
   new LoginFrame(lanTalk , "請輸入用戶名、頭像后登錄");
  }
}
// 定義用于改變JList列表項外觀的類
class ImageCellRenderer extends JPanel
  implements ListCellRenderer<UserInfo>
{
  private ImageIcon icon;
  private String name;
  // 定義繪制單元格時的背景色
  private Color background;
  // 定義繪制單元格時的前景色
  private Color foreground;
  @Override
  public Component getListCellRendererComponent(JList list
   , UserInfo userInfo , int index
   , boolean isSelected , boolean cellHasFocus)
  {
   // 設(shè)置圖標
   icon = new ImageIcon("ico/" + userInfo.getIcon() + ".gif");
   name = userInfo.getName();
   // 設(shè)置背景色、前景色
   background = isSelected ? list.getSelectionBackground()
    : list.getBackground();
   foreground = isSelected ? list.getSelectionForeground()
    : list.getForeground();
   // 返回該JPanel對象作為單元格繪制器
   return this;
  }
  // 重寫paintComponent方法，改變JPanel的外觀
  public void paintComponent(Graphics g)
  {
   int imageWidth = icon.getImage().getWidth(null);
   int imageHeight = icon.getImage().getHeight(null);
   g.setColor(background);
   g.fillRect(0, 0, getWidth(), getHeight());
   g.setColor(foreground);
   // 繪制好友圖標
   g.drawImage(icon.getImage() , getWidth() / 2 - imageWidth / 2
    , 10 , null);
   g.setFont(new Font("SansSerif" , Font.BOLD , 18));
   // 繪制好友用戶名
   g.drawString(name, getWidth() / 2 - name.length() * 10
    , imageHeight + 30 );
  }
  // 通過該方法來設(shè)置該ImageCellRenderer的最佳大小
  public Dimension getPreferredSize()
  {
   return new Dimension(60, 80);
  }
}

package com.talk;
public interface YeekuProtocol
{
  String PRESENCE = "⊿⊿";
  String SPLITTER = "▓";
}

package com.bank;
import java.awt.Dimension;
import java.awt.Font;
import java.awt.GridLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.JButton;
import javax.swing.JComboBox;
import javax.swing.JComponent;
import javax.swing.JDialog;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JTextField;
import com.talk.ComUtil;
import com.talk.LanTalk;
import com.talk.YeekuProtocol;
// 登錄用的對話框
public class LoginFrame extends JDialog
{
  public JLabel tip;
  public JTextField userField = new JTextField("錢鐘書" , 20);
  public JComboBox<Integer> iconList = new JComboBox<>(
   new Integer[]{1, 2, 3, 4, 5 , 6, 7, 8 ,9 ,10});
  private JButton loginBn = new JButton("登錄");
  // 聊天的主界面
  private LanTalk chatFrame;
  // 聊天通信的工具實例
  public static ComUtil comUtil;
  // 構(gòu)造器，用于初始化的登錄對話框
  public LoginFrame(LanTalk parent , String msg)
  {
   super(parent , "輸入名字后登錄" , true);
   this.chatFrame = parent;
   setLayout(new GridLayout(5, 1));
   JPanel jp = new JPanel();
   tip = new JLabel(msg);
   tip.setFont(new Font("Serif" , Font.BOLD , 16));
   jp.add(tip);
   add(jp);
   add(getPanel("用戶名" , userField));
   iconList.setPreferredSize(new Dimension(224, 20));
   add(getPanel("圖 標" , iconList));
   JPanel bp = new JPanel();
   loginBn.addActionListener(new MyActionListener(this));
   bp.add(loginBn);
   add(bp);
   pack();
   setVisible(true);
  }
  // 工具方法，該方法將一個字符串和組件組合成JPanel對象
  private JPanel getPanel(String name , JComponent jf)
  {
   JPanel jp = new JPanel();
   jp.add(new JLabel(name + "："));
   jp.add(jf);
   return jp;
  }
  // 該方法用于改變登錄窗口最上面的提示信息
  public void setTipMsg(String tip)
  {
   this.tip.setText(tip);
  }
  // 定義一個事件監(jiān)聽器
  class MyActionListener implements ActionListener
  {
   private LoginFrame loginFrame;
   public MyActionListener(LoginFrame loginFrame)
   {
    this.loginFrame = loginFrame;
   }
   // 當鼠標單擊事件發(fā)生時
   public void actionPerformed(ActionEvent evt)
   {
    try
    {
      // 初始化聊天通信類
      comUtil = new ComUtil(chatFrame);
      final String loginMsg = YeekuProtocol.PRESENCE + userField.getText()
       + YeekuProtocol.SPLITTER + iconList.getSelectedObjects()[0]
       + YeekuProtocol.PRESENCE;
      comUtil.broadCast(loginMsg);
      // 啟動定時器每20秒廣播一次在線信息
      javax.swing.Timer timer = new javax.swing.Timer(1000 * 10
       , event-> comUtil.broadCast(loginMsg));
      timer.start();
      loginFrame.setVisible(false);
      chatFrame.setVisible(true);
    }
    catch (Exception ex)
    {
      loginFrame.setTipMsg("確認30001端口空閑，且網(wǎng)絡(luò)正常！");
    }
   }
  }
}

package com.bank;
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.net.InetSocketAddress;
import javax.swing.AbstractAction;
import javax.swing.Action;
import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.KeyStroke;
import com.talk.LanTalk;
import com.talk.UserInfo;
// 定義交談的對話框
public class ChatFrame extends JDialog
{
  // 聊天信息區(qū)
  JTextArea msgArea = new JTextArea(12 , 45);
  // 聊天輸入?yún)^(qū)
  JTextField chatField = new JTextField(30);
  // 發(fā)送聊天信息的按鈕
  JButton sendBn = new JButton("發(fā)送");
  // 該交談窗口對應(yīng)的用戶
  UserInfo user;
  // 構(gòu)造器，用于初始化交談對話框的界面
  public ChatFrame(LanTalk parent , final UserInfo user)
  {
   super(parent , "和" + user.getName() + "聊天中" , false);
   this.user = user;
   msgArea.setEditable(false);
   add(new JScrollPane(msgArea));
   JPanel buttom = new JPanel();
   buttom.add(new JLabel("輸入信息："));
   buttom.add(chatField);
   buttom.add(sendBn);
   add(buttom , BorderLayout.SOUTH);
   // 發(fā)送消息的Action，Action是ActionListener的子接口
   Action sendAction = new AbstractAction()
   {
    @Override
    public void actionPerformed(ActionEvent evt)
    {
      InetSocketAddress dest = (InetSocketAddress)user.getAddress();
      // 在聊友列表中，所有人項的SocketAddress是null
      // 這表明是向所有人發(fā)送消息
      if (dest == null)
      {
       LoginFrame.comUtil.broadCast(chatField.getText());
       msgArea.setText("您對大家說："
        + chatField.getText() + "\n" + msgArea.getText());
      }
      // 向私人發(fā)送信息
      else
      {
       // 獲取發(fā)送消息的目的
       dest = new InetSocketAddress(dest.getHostName(),
        dest.getPort() + 1);
       LoginFrame.comUtil.sendSingle(chatField.getText(), dest);
       msgArea.setText("您對" + user.getName() + "說："
        + chatField.getText() + "\n" + msgArea.getText());
      }
      chatField.setText("");
    }
   };
   sendBn.addActionListener(sendAction);
   // 將Ctrl+Enter鍵和"send"關(guān)聯(lián)
   chatField.getInputMap().put(KeyStroke.getKeyStroke('\n'
    , java.awt.event.InputEvent.CTRL_MASK) , "send");
   // 將"send"與sendAction關(guān)聯(lián)
   chatField.getActionMap().put("send", sendAction);
   pack();
  }
  // 定義向聊天區(qū)域添加消息的方法
  public void addString(String msg)
  {
   msgArea.setText(msg + "\n" + msgArea.getText());
  }
}