/**
基于Udp通讯的Java局域网群聊小程序
*/
package com.UdpDemo;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
public class UdpDemo {
private Frame f;
private TextField tf;
private Button but;
private Button but1;
private TextArea ta;
DatagramSocket ds1;
//1.创建udpSocket服务建立端点,监听10000端口,接受的ds
DatagramSocket dss;
//创建一个线程用来接收10000端口并打印到文本框中
Thread t1=new Thread(new Runnable(){
public void run(){
while(true){
try{
//1.创建udpSocket服务建立端点,监听10000端口,接受的ds1
dss=new DatagramSocket(10000);
//2.定义数据包,用于存储数据
byte[] buf=new byte[1024];
DatagramPacket dp=new DatagramPacket(buf,buf.length);
//3.通过服务的receive方法将收到的数据存入数据包中
dss.receive(dp);
//4.通过数据包的方法获取其中的数据
String ip=dp.getAddress().getHostAddress();
String data=new String(dp.getData(),0,dp.getLength());
//获取发送的端口
int port=dp.getPort();
//输出到文本框
ta.append("\n"+ip+":"+port+"\t:--->"+data+"#\r\n\n");
//关闭资源
dss.close();
}
catch(Exception e){
System.out.println("接收数据异常");
}
}
}
});
public void send(){
try{
//1.创建udp服务,通过DatagramSocket对象
ds1=new DatagramSocket();
//确定数据
byte[] bufSend1=tf.getText().getBytes();
// 构造 DatagramPacket,用来将长度为 length 的包发送到指定主机上的指定端口。封装成数据包 DatagramPacket(byte[] buf,int length,InetAddress address,int port)
DatagramPacket dp1=new DatagramPacket(bufSend1,bufSend1.length,InetAddress.getByName("127.0.0.255"),10000);
//send方法发送,Socket服务将已有数据包发送。
ds1.send(dp1);
//关闭发送资源
ds1.close();
}
catch(Exception e){
System.out.println("send异常");
}
}
//定义一个函数,该函数调用时需传入要发送的参数
public void sendGo(String obj){
//到追加文本区,显示本人已发送的
ta.append("My Speak:"+obj+"\r\n"+"#");
//调用send()函数发送数据
send();
//清空输入框
tf.setText("");
}
//UDPDemo方法来调用窗体创建和运行接收线程
UdpDemo(){ init(); t1.start(); }
public void init(){
f=new Frame("UdpDemo");
//f.setBounds(横坐标,纵坐标,长度,宽度);
f.setBounds(200,200,600,600);
f.setLayout(new FlowLayout());
//输入框长度
tf=new TextField(60);
//按钮文字
but=new Button("发送");
//按钮文字
but1=new Button("清屏");
// 文本框位置
ta=new TextArea(30,80);
//将以上组件添加到窗体中
f.add(ta);
f.add(tf);
f.add(but);
f.add(but1);
//文本框设置为不可编辑
ta.setEditable(false);
//文本框为指定的颜色
tf.setBackground(new Color(244, 244, 244));
//创建可显示的窗体
myEvent();
f.setVisible(true);
}
private void myEvent(){
f.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
//向大家发送我下了的提示
sendGo("我下了!");
//关闭资源
ds1.close();
//关闭窗体
System.exit(0);
}
});
but.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e){
sendGo(tf.getText());
}
});
but1.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e){
//清空文本框
ta.setText("");
//清空输入框
tf.setText(" ");
}
});
tf.addKeyListener(new KeyAdapter(){
public void keyPressed(KeyEvent e){
//如果按Enter则调用sendGo方法
if(e.getKeyCode()==KeyEvent.VK_ENTER){
sendGo(tf.getText());
}
}
});
}
public static void main(String [] arguments) {
try{
//创建UdpDemo()对象
new UdpDemo();
}
catch(Exception e){
//有异常时打印到对话框
System.out.println("main异常");
}
}
//采用127.0.0.255的回环地址来测试,若使用仅需更改为局域网ip网段即可。(例:网段为192.168.0.1改为192.168.1.255即可)