/*
需求：定义一个程序，用于接收和发送消息
*/
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
//发送端
class Send implements Runnable
{
private String text;
public Send(String text)
{
this.text = text;
}
public void run()
{
try
{
DatagramSocket ds = new DatagramSocket(7777);
byte [] buf = text.getBytes();
DatagramPacket dp =
new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10004);
ds.send(dp);
ds.close();
}
catch(Exception e)
{
throw new RuntimeException("发送失败");
}
}
}
//接收端
class Rece implements Runnable
{
private TextArea receArea;
public Rece(TextArea receArea)
{
this.receArea = receArea;
}
public void run()
{
try
{
DatagramSocket ds = new DatagramSocket(10005);
while(true)
{
byte[] buf = new byte[1024];
DatagramPacket dp =new DatagramPacket(buf,buf.length);
ds.receive(dp);
String ip = dp.getAddress().getHostAddress();
String data = new String(dp.getData(),0,dp.getLength());
receArea.append("-----_"+ip+"说:\r\n"+data+"\r\n");
}
}
catch(Exception e)
{
throw new RuntimeException("接收失败");
}
}
}
//窗体
class myFrame
{
private Frame f;
private Button but;
private TextArea sendArea,receArea;
public myFrame()
{
init();
}
public void init()
{
f = new Frame("聊天窗口");
but = new Button("发送");
receArea = new TextArea(15,76);
sendArea = new TextArea(12,70);
f.setBounds(200,100,600,500);
myEvent();
f.setLayout(new FlowLayout());
f.add(receArea);
f.add(sendArea);
f.add(but);
f.setVisible(true);
new Thread(new Rece(receArea)).start();
}
//监听器
public void myEvent()
{
f.addWindowListener(new WindowAdapter()
{
public void windowClosing(WindowEvent e)
{
System.exit(0);
}
});
//按钮 -- 活动监听器
but.addActionListener(new ActionListener()
{
public void actionPerformed(ActionEvent e)
{
String text = sendArea.getText();
Thread sendThread = new Thread(new Send(text));
sendThread.start();
//sendThread.interrupt();
sendArea.setText("");
}
});
//下文本区 -- 键盘监听器
sendArea.addKeyListener(new KeyAdapter()
{
public void keyPressed(KeyEvent e)
{
if(e.isControlDown() && e.getKeyCode()==e.VK_ENTER)
{
String text = sendArea.getText();
Thread sendThread = new Thread(new Send(text));
sendThread.start();
sendThread.interrupt();
sendArea.setText("");
}
}
});
}
}
class UdpAndAwt
{
public static void main(String[] args)
{
new myFrame();
}
}
|
收藏
淘帖
踩
