如何在java项目中使用MulticastSocket

本篇文章为大家展示了如何在java项目中使用MulticastSocket，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

创新互联建站专注于玉泉企业网站建设,响应式网站建设,商城网站建设。玉泉网站建设公司,为玉泉等地区提供建站服务。全流程定制网站制作，专业设计，全程项目跟踪，创新互联建站专业和态度为您提供的服务

（1）DatagramSocket只允许数据报发给指定的目标地址，而MulticastSocket可以将数据报以广播的方式发送到多个客户端。

（2）IP协议为多点广播提供了这批特殊的IP地址，这些IP地址的范围是：224.0.0.0至239.255.255.255..

（3）MulticastSocket类时实现多点广播的关键，当MulticastSocket把一个DaragramPocket发送到多点广播的IP地址时，该数据报将会自动广播到加入该地址的所有MulticastSocket。MulticastSocket既可以将数据报发送到多点广播地址，也可以接收其他主机的广播信息。

（4）事实上，MulticastSocket是DatagramSocket的子类，也就是说，MulticastSocket是特殊的DatagramSocket。当要发送一个数据报时，可以使用随机端口创建MulticastSocket，也可以在指定端口创建MulticastSocket。MulticastSocket提供了如下三个构造器：

public MulticastSocket（） 使用本机默认地址，随机端口来创建MulticastSocket对象
public MulticastSocket（int portNumber） 用本机默认地址，指定端口来创建MulticastSocket对象
public MulticastSocket（SocketAddress bindaddr） 用指定IP地址，指定端口来创建MulticastSocket对象

（5）创建MulticastSocket对象后，还需要将MulticastSocket加入到指定的多点广播地址。MulticastSocket使用joinGroup()方法加入指定组；使用leaveGroup()方法脱离一个组。

joinGroup(InetAddress multicastAddr) 将该MulticastSocket加入到指定的多点广播地址

leaveGroup(InetAddress multicastAddr) 将该MulticastSocket离开指定的多点广播地址

（6）在某些系统中，可能有多个网络接口，这可能为多点广播带来问题，这时候程序需要在一个指定的网络接口上监听，通过调用setInterface()方法可以强制MulticastSocket使用指定的网络接口‘也可以使用getInterface()方法查询MulticastSocket监听的网络接口。

（7）如果创建仅仅用于发送数据报的MulticastSocket对象，则使用默认地址，随机端口即可。但如果创建接收用的MulticastSocket对象，'则该MulticastSocket对象必须有指定端口，否则无法确定发送数据报的目标端口。

（8）MulticastSocket用于发送接收数据报的方法与DatagramSocket完全一样。但MulticastSocket比DatagramSocket多了一个setTimeToLive(int ttl)方法，该ttl用于设置数据报最多可以跨过多少个网络。
当ttl为0时，指定数据报应停留在本地主机
当ttl为1时，指定数据报发送到本地局域网
当ttl为32时，指定数据报发送到本站点的网络上
当ttl为64时，意味着数据报应该停留在本地区
当ttl为128时，意味着数据报应保留在本大洲
当ttl为255时，意味着数据报可以发送到所有地方
默认情况下，ttl值为1.

程序实例：

下面程序使用MulticastSocket实现一个基于广播的多人聊天室。程序只需要一个MulticastSocket，两个线程，其中MulticastSocket既用于发送，也用于接收；一个线程负责键盘输入，并向MulticastSocket发送数据；一个线程负责从MulticastSocket中读取数据。

package com.talk;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.util.Scanner;
//让该类实现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;
  //定义每个数据报大小最大为4kb
  private static final int DATA_LEN=4096;
  //定义本程序的MulticastSocket实例
  private MulticastSocket socket=null;
  private InetAddress broadcastAddress=null;
  private Scanner scan=null;

  //定义接收网络数据的字节数组
  byte[] inBuff=new byte[DATA_LEN];
  //以指定字节数组创建准备接收数据的MulticastSocket对象
  private DatagramPacket inPacket =new DatagramPacket(inBuff, inBuff.length);

  //定义一个用于发送的DatagramPacket对象
  private DatagramPacket outPacket=null;

  public void init() throws IOException{
   //创建键盘输入流
   Scanner scan=new Scanner(System.in);
   //创建用于发送、接收数据的MulticastSocket对象，由于该MulticastSocket需要接收数据，所以有指定端口
   socket=new MulticastSocket(BROADCAST_PORT);
   broadcastAddress=InetAddress.getByName(BROADCAST_IP);

   //将该socket加入到指定的多点广播地址
   socket.joinGroup(broadcastAddress);
   //设置本MulticastSocket发送的数据报会被回送到自身
   socket.setLoopbackMode(false);

   //初始化发送用的DatagramSocket，它包含一个长度为0的字节数组
   outPacket =new DatagramPacket(new byte[0], 0, broadcastAddress, BROADCAST_PORT);

   //启动本实例的run()方法作为线程执行体的线程
   new Thread(this).start();

   //不断的读取键盘输入
   while(scan.hasNextLine()){
    //将键盘输入的一行字符转换成字节数组
    byte [] buff=scan.nextLine().getBytes();
    //设置发送用的DatagramPacket里的字节数据
    outPacket.setData(buff);
    //发送数据报
    socket.send(outPacket);
   }
   socket.close();
  }

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

   while(true){
    //读取Socket中的数据，读到的数据放入inPacket所封装的字节组里
    try {
      socket.receive(inPacket);
      //打印从socket读取到的内容
      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);
       //关闭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();
   }
  }
}

下面将结合MulticastSocket和DatagramSocket开发一个简单的局域网即时通讯工具，局域网内每个用户启动该工具后，就可以看到该局域网内所有的在线用户，该用户也会被其他用户看到：

该程序的思路是：每个用户都启动两个Socket，即MulticastSocket和DatagramSocket。其中MulticastSocket会周期性的向230.0.0.1发送在线信息，且所有的MulticastSocket都会加入到230.0.0.1这个多点广播IP中，这样每个用户都会收到其他用户的在线信息，如果系统在一段时间内没有收到某个用户广播的在线信息，则从用户列表中删除该用户。除此之外，该MulticastSocket还用于向其他用户发送广播信息。

DatagramSocket主要用于发送私聊信息，当用户收到其他用户广播来的DatagramSocket时，即可获得该用户MulticastSocket对应的SocketAddress.这个SocketAddress将作为发送私聊信息的重要依据。—本程序让MulticastSocket在30000端口监听，而DatagramSocket在30001端口监听，这样程序就可以根据其他用户广播来的DatagramPacket得到他的DatagramSocket所在的地址。

本系统提供了一个UserInfo类，该类封装了用户名、图标、对应的SocketAddress以及该用户对应的交谈窗口，失去联系的次数等信息：

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;
  // 该用户失去联系的次数
  private int lost;
  // 该用户对应的交谈窗口
  private ChatFrame chatFrame;
  public UserInfo(){}
  // 有参数的构造器
  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作为该用户的标识，所以根据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;
  }
}

通过UserInfo的封装，所有客户端只需要维护该UserInfo类的列表，程序就可以实现广播、发送私聊信息等功能。本程序的底层通信类则需要一个MulticastSocket和一个DatagramSocket，该工具类的代码如下：

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;
  // 定义每个数据报的最大大小为4K
  private static final int DATA_LEN = 4096;
  // 定义本程序的MulticastSocket实例
  private MulticastSocket socket = null;
  // 定义本程序私聊的Socket实例
  private DatagramSocket singleSocket = null;
  // 定义广播的IP地址
  private InetAddress broadcastAddress = null;
  // 定义接收网络数据的字节数组
  byte[] inBuff = new byte[DATA_LEN];
  // 以指定字节数组创建准备接受数据的DatagramPacket对象
  private DatagramPacket inPacket =
   new DatagramPacket(inBuff , inBuff.length);
  // 定义一个用于发送的DatagramPacket对象
  private DatagramPacket outPacket = null;
  // 聊天的主界面程序
  private LanTalk lanTalk;
  // 构造器，初始化资源
  public ComUtil(LanTalk lanTalk) throws Exception
  {
   this.lanTalk = lanTalk;
   // 创建用于发送、接收数据的MulticastSocket对象
   // 因为该MulticastSocket对象需要接收，所以有指定端口
   socket = new MulticastSocket(BROADCAST_PORT);
   // 创建私聊用的DatagramSocket对象
   singleSocket = new DatagramSocket(BROADCAST_PORT + 1);
   broadcastAddress = InetAddress.getByName(BROADCAST_IP);
   // 将该socket加入指定的多点广播地址
   socket.joinGroup(broadcastAddress);
   // 设置本MulticastSocket发送的数据报被回送到自身
   socket.setLoopbackMode(false);
   // 初始化发送用的DatagramSocket，它包含一个长度为0的字节数组
   outPacket = new DatagramPacket(new byte[0]
    , 0 , broadcastAddress , BROADCAST_PORT);
   // 启动两个读取网络数据的线程
   new ReadBroad().start();
   Thread.sleep(1);
   new ReadSingle().start();
  }
  // 广播消息的工具方法
  public void broadCast(String msg)
  {
   try
   {
    // 将msg字符串转换字节数组
    byte[] buff = msg.getBytes(CHARSET);
    // 设置发送用的DatagramPacket里的字节数据
    outPacket.setData(buff);
    // 发送数据报
    socket.send(outPacket);
   }
   // 捕捉异常
   catch (IOException ex)
   {
    ex.printStackTrace();
    if (socket != null)
    {
      // 关闭该Socket对象
      socket.close();
    }
    JOptionPane.showMessageDialog(null
      , "发送信息异常，请确认30000端口空闲，且网络连接正常！"
      , "网络异常", JOptionPane.ERROR_MESSAGE);
    System.exit(1);
   }
  }
  // 定义向单独用户发送消息的方法
  public void sendSingle(String msg , SocketAddress dest)
  {
   try
   {
    // 将msg字符串转换字节数组
    byte[] buff = msg.getBytes(CHARSET);
    DatagramPacket packet = new DatagramPacket(buff
      , buff.length , dest);
    singleSocket.send(packet);
   }
   // 捕捉异常
   catch (IOException ex)
   {
    ex.printStackTrace();
    if (singleSocket != null)
    {
      // 关闭该Socket对象
      singleSocket.close();
    }
    JOptionPane.showMessageDialog(null
      , "发送信息异常，请确认30001端口空闲，且网络连接正常！"
      , "网络异常", JOptionPane.ERROR_MESSAGE);
    System.exit(1);
   }
  }
  // 不断从DatagramSocket中读取数据的线程
  class ReadSingle extends Thread
  {
   // 定义接收网络数据的字节数组
   byte[] singleBuff = new byte[DATA_LEN];
   private DatagramPacket singlePacket =
    new DatagramPacket(singleBuff , singleBuff.length);
   public void run()
   {
    while (true)
    {
      try
      {
       // 读取Socket中的数据。
       singleSocket.receive(singlePacket);
       // 处理读到的信息
       lanTalk.processMsg(singlePacket , true);
      }
      // 捕捉异常
      catch (IOException ex)
      {
       ex.printStackTrace();
       if (singleSocket != null)
       {
        // 关闭该Socket对象
        singleSocket.close();
       }
       JOptionPane.showMessageDialog(null
        , "接收信息异常，请确认30001端口空闲，且网络连接正常！"
        , "网络异常", JOptionPane.ERROR_MESSAGE);
       System.exit(1);
      }
    }
   }
  }
  // 持续读取MulticastSocket的线程
  class ReadBroad extends Thread
  {
   public void run()
   {
    while (true)
    {
      try
      {
       // 读取Socket中的数据。
       socket.receive(inPacket);
       // 打印输出从socket中读取的内容
       String msg = new String(inBuff , 0
        , inPacket.getLength() , CHARSET);
       // 读到的内容是在线信息
       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 delList = new ArrayList<>();
        // 遍历系统中已有的所有用户,该循环必须循环完成
        for (int i = 1 ; i < lanTalk.getUserNum() ; i++ )
        {
          UserInfo current = lanTalk.getUser(i);
          // 将所有用户失去联系的次数加1
          current.setLost(current.getLost() + 1);
          // 如果该信息由指定用户发送过来
          if (current.equals(user))
          {
           current.setLost(0);
           // 设置该用户无须添加
           addFlag = false;
          }
          if (current.getLost() > 2)
          {
           delList.add(i);
          }
        }
        // 删除delList中的所有索引对应的用户
        for (int i = 0; i < delList.size() ; i++)
        {
          lanTalk.removeUser(delList.get(i));
        }
        if (addFlag)
        {
          // 添加新用户
          lanTalk.addUser(user);
        }
       }
       // 读到的内容是公聊信息
       else
       {
        // 处理读到的信息
        lanTalk.processMsg(inPacket , false);
       }
      }
      // 捕捉异常
      catch (IOException ex)
      {
       ex.printStackTrace();
       if (socket != null)
       {
        // 关闭该Socket对象
        socket.close();
       }
       JOptionPane.showMessageDialog(null
        , "接收信息异常，请确认30000端口空闲，且网络连接正常！"
        , "网络异常", JOptionPane.ERROR_MESSAGE);
       System.exit(1);
      }
    }
   }
  }
}

本程序的一个主类，LanTalk ，该类使用DefaultListModel来维护用户列表，该类里的每个列表项就是一个UserInfo。该类还提供了一个ImageCellRenderer，该类用于将列表项绘制出用户图标和用户名字。

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 listModel
   = new DefaultListModel<>();
  // 定义一个JList对象
  private JList friendsList = new JList<>(listModel);
  // 定义一个用于格式化日期的格式器
  private DateFormat formatter = DateFormat.getDateTimeInstance();
  public LanTalk()
  {
   super("局域网聊天");
   // 设置该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);
  }
  // 根据地址来查询用户
  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);
  }
  // 获取该聊天窗口的用户数量
  public int getUserNum()
  {
   return listModel.size();
  }
  // 获取指定位置的用户
  public UserInfo getUser(int pos)
  {
   return listModel.elementAt(pos);
  }
  // 实现JList上的鼠标双击事件的监听器
  class ChangeMusicListener extends MouseAdapter
  {
   public void mouseClicked(MouseEvent e)
   {
    // 如果鼠标的击键次数大于2
    if (e.getClickCount() >= 2)
    {
      // 取出鼠标双击时选中的列表项
      UserInfo user = (UserInfo)friendsList.getSelectedValue();
      // 如果该列表项对应用户的交谈窗口为null
      if (user.getChatFrame() == null)
      {
       // 为该用户创建一个交谈窗口，并让该用户引用该窗口
       user.setChatFrame(new ChatFrame(null , user));
      }
      // 如果该用户的窗口没有显示，则让该用户的窗口显示出来
      if (!user.getChatFrame().isShowing())
      {
       user.getChatFrame().setVisible(true);
      }
    }
   }
  }
  /**
  * 处理网络数据报，该方法将根据聊天信息得到聊天者，
  * 并将信息显示在聊天对话框中。
  * @param packet 需要处理的数据报
  * @param single 该信息是否为私聊信息
  */
  public void processMsg(DatagramPacket packet , boolean single)
  {
   // 获取该发送该数据报的SocketAddress
   InetSocketAddress srcAddress = (InetSocketAddress)
    packet.getSocketAddress();
   // 如果是私聊信息，则该Packet获取的是DatagramSocket的地址，
   // 将端口减1才是对应的MulticastSocket的地址
   if (single)
   {
    srcAddress = new InetSocketAddress(srcAddress.getHostName()
      , srcAddress.getPort() - 1);
   }
   UserInfo srcUser = getUserBySocketAddress(srcAddress);
   if (srcUser != null)
   {
    // 确定消息将要显示到哪个用户对应窗口上。
    UserInfo alertUser = single ? srcUser : getUser(0);
    // 如果该用户对应的窗口为空，显示该窗口
    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
{
  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)
  {
   // 设置图标
   icon = new ImageIcon("ico/" + userInfo.getIcon() + ".gif");
   name = userInfo.getName();
   // 设置背景色、前景色
   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 );
  }
  // 通过该方法来设置该ImageCellRenderer的最佳大小
  public Dimension getPreferredSize()
  {
   return new Dimension(60, 80);
  }
}

除了以上主要的代码，还有YeekuProtocol   ChatFrame   LoginFrame等类：

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 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;
  // 构造器，用于初始化的登录对话框
  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);
  }
  // 定义一个事件监听器
  class MyActionListener implements ActionListener
  {
   private LoginFrame loginFrame;
   public MyActionListener(LoginFrame loginFrame)
   {
    this.loginFrame = loginFrame;
   }
   // 当鼠标单击事件发生时
   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端口空闲，且网络正常！");
    }
   }
  }
}

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
{
  // 聊天信息区
  JTextArea msgArea = new JTextArea(12 , 45);
  // 聊天输入区
  JTextField chatField = new JTextField(30);
  // 发送聊天信息的按钮
  JButton sendBn = new JButton("发送");
  // 该交谈窗口对应的用户
  UserInfo user;
  // 构造器，用于初始化交谈对话框的界面
  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);
   // 发送消息的Action，Action是ActionListener的子接口
   Action sendAction = new AbstractAction()
   {
    @Override
    public void actionPerformed(ActionEvent evt)
    {
      InetSocketAddress dest = (InetSocketAddress)user.getAddress();
      // 在聊友列表中，所有人项的SocketAddress是null
      // 这表明是向所有人发送消息
      if (dest == null)
      {
       LoginFrame.comUtil.broadCast(chatField.getText());
       msgArea.setText("您对大家说："
        + chatField.getText() + "\n" + msgArea.getText());
      }
      // 向私人发送信息
      else
      {
       // 获取发送消息的目的
       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"关联
   chatField.getInputMap().put(KeyStroke.getKeyStroke('\n'
    , java.awt.event.InputEvent.CTRL_MASK) , "send");
   // 将"send"与sendAction关联
   chatField.getActionMap().put("send", sendAction);
   pack();
  }
  // 定义向聊天区域添加消息的方法
  public void addString(String msg)
  {
   msgArea.setText(msg + "\n" + msgArea.getText());
  }
}

上述内容就是如何在java项目中使用MulticastSocket，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。