Java第八课UDP接收广播

 

昨天我们做了发送广播，今天我们做一个接收的，代码如下：

package test;

 

import java.awt.*;

import java.awt.event.*;

import java.io.IOException;

import java.net.*;

import javax.swing.*;

 

public class demo extends JFrame implements Runnable, ActionListener {

/**

* 

*/

private static final long serialVersionUID = 5952137875741655180L;

int port = 9544;

InetAddress group;

MulticastSocket socket;

JButton inceBtn = new JButton("开始接收");

JButton stopBtn = new JButton("停止接收");

JTextArea inceAr = new JTextArea(10, 10); // 显示接收广播的文本域

JTextArea inced = new JTextArea(10, 10);

Thread thread;

boolean stop = false; // 停止接受信息状态

 

public demo() {

setTitle("广播数据报");

setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE);

thread = new Thread(this);

inceBtn.addActionListener(this); // 绑定按钮ince的单击事件

stopBtn.addActionListener(this); // 绑定按钮stop的单击事件

inceAr.setForeground(Color.blue); // 指定文本域中文字的颜色

JPanel north = new JPanel(); // 创建Jpanel对象

north.add(inceBtn); // 将按钮添加到面板north上

north.add(stopBtn);

add(north, BorderLayout.NORTH); // 将north放置在窗体的上部

JPanel center = new JPanel(); // 创建面板对象center

center.setLayout(new GridLayout(1, 2)); // 设置面板布局

center.add(inceAr); // 将文本域添加到面板上

center.add(inced);

add(center, BorderLayout.CENTER); // 设置面板布局

validate(); // 刷新

port = 9544; // 设置端口号

try {

group = InetAddress.getByName("224.255.10.1"); // 指定接收地址

socket = new MulticastSocket(port); // 绑定多点广播套接字

socket.joinGroup(group); // 加入广播组

} catch (IOException e) {

e.printStackTrace(); // 输出异常信息

}

setBounds(100, 50, 360, 380); // 设置布局

setVisible(true); // 将窗体设置为显示状态

}

 

public void run() { // run()方法

while (!stop) {

byte data[] = new byte[1024]; // 创建缓存字节数组

DatagramPacket packet = null;

packet = new DatagramPacket(data, data.length, group, port); // 待接收的数据包

try {

socket.receive(packet); // 接收数据包

String message = new String(packet.getData(), 0, packet.getLength()); // 获取数据包中的内容

inceAr.setText("正在接收的内容：\n" + message); // 将接收内容显示在文本域中

} catch (IOException e) {

e.printStackTrace(); // 输出异常信息

}

}

}

 

public void actionPerformed(ActionEvent e) { // 单击事件

if (e.getSource() == inceBtn) { // 单击按钮ince触发的事件

inceBtn.setBackground(Color.red); // 设置按钮颜色

stopBtn.setBackground(Color.yellow);

if (!(thread.isAlive())) { // 如线程不处于“新建状态”

thread = new Thread(this); // 实例化Thread对象

}

thread.start(); // 启动线程

stop = false; // 开始接受信息

}

if (e.getSource() == stopBtn) { // 单击按钮stop触发的事件

inceBtn.setBackground(Color.yellow); // 设置按钮颜色

stopBtn.setBackground(Color.red);

stop = true; // 停止接受信息

}

}

 

public static void main(String[] args) {

demo rec = new demo();

rec.setSize(460, 200);

}

}

 

以上是代码，我们需要新建一个test项目，建一个test包，在包内建一个demo.java类文件，把代码放在里。

先运行昨天的发送广播程序，然后再运行这个接收的程序，运行后点开始接收，会发现收到数据，仔细看一下时间，因为我们发送的内容是相同的，所以只有时间在变。

 

可以根据代码先看看大概是什么意思，明天开始，我们讲一下这些代码的意思。