package UDP;
import java.awt.BorderLayout;
import java.awt.Button;
import java.awt.Color;
import java.awt.Font;
import java.awt.Frame;
import java.awt.Panel;
import java.awt.TextArea;
import java.awt.TextComponent;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.BufferedWriter;
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.Date;
public class GUI_Chat extends Frame{
/*
* GUI聊天室
*
* 1个frame
* 两个Panel
* 中间的Panel：两个TextArea
* 南边的Panel：一个TextFiled,四个Button
*/
private TextArea view;
private TextArea sendText;
private TextField tf;
private Button send;
private Button log;
private Button clear;
private Button shake;
private DatagramSocket socket;
private BufferedWriter bw;
public GUI_Chat() {
Frame();
southPanel();
centerPanel();
event();
this.setVisible(true);
}
public void event() {
//关闭窗口
this.addWindowListener(new WindowAdapter() {
@Override
public void windowClosing(WindowEvent e) {
try {
socket.close();
bw.close();
} catch (IOException e1) {
e1.printStackTrace();
}
System.exit(0);
}
});
//发送按钮
send.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
try {
send();
} catch (IOException e) {
e.printStackTrace();
}
}
});
//记录按钮
log.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
try {
logFile();
} catch (IOException e) {
e.printStackTrace();
}
}
});
//清屏按钮
clear.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
view.setText("");
}
});
//震动按钮
shake.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
try {
send(new byte[]{-1},tf.getText());
} catch (IOException e1) {
e1.printStackTrace();
}
}
});
sendText.addKeyListener(new KeyAdapter(){
public void KeyReleased(KeyEvent e) {
if(e.getKeyCode()==KeyEvent.VK_ENTER) { //如果按下回车就调用send按钮
try {
send();
}catch(IOException e1) {
e1.printStackTrace();
}
}
}
});
}
public void shake() {
int x=this.getLocation().x; //获取横坐标位置
int y=this.getLocation().y; //获取纵坐标位置
for(int s=0;s<20;s++) { //要多震动几次
try {
this.setLocation(x+20,y+20);
Thread.sleep(20);
this.setLocation(x+20,y-20);
Thread.sleep(20);
this.setLocation(x-20,y+20);
Thread.sleep(20);
this.setLocation(x-20,y-20);
this.setLocation(x,y);
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}
private void send(byte[] arr,String ip) throws IOException {
DatagramPacket packet=new DatagramPacket(arr,arr.length,InetAddress.getByName(ip),6666);
socket.send(packet); //发送数据
}
public void logFile() throws IOException {
bw.flush(); //刷新缓冲区
FileInputStream fis=new FileInputStream("config.txt");
ByteArrayOutputStream baos=new ByteArrayOutputStream(); //在内存中创建缓冲区
int len = 0;
byte[] arr=new byte[8192];
while((len=fis.read(arr)) !=-1) {
baos.write(arr,0,len);
}
String str=baos.toString(); //将内存中的内容转换成字符串
System.out.println(str+"hi");
view.setText(str);
fis.close();
}
public void send() throws IOException {
String msg=sendText.getText(); //获取发送数据的内容
String ip=tf.getText(); //获取IP地址
ip=ip.trim().length()==0 ? "255.255.255.255":ip;
send(msg.getBytes(),ip);
String time=getCurrentTime(); //获取当前时间
String text = time+" I sent to "+(ip.equals("255.255.255.255")?"所有人" : ip)+" said \n"+msg+"\n";
view.append(text); //将信息添加到显示区域中
bw.write(text);
sendText.setText(null); //清除发送文本区域的文本
}
private class Receive extends Thread{ //接受和发送同时进行，所以需要使用多线程
public void run() {
try {
DatagramSocket socket=new DatagramSocket(6666);
DatagramPacket packet=new DatagramPacket(new byte[8192],8192);
while(true) {
socket.receive(packet); //接收信息
byte[]arr=packet.getData(); //获取字节数据
int len=packet.getLength(); //获取有效字节个数
String msg=new String(arr,0,len); //转换成字符串
if(arr[0]==-1 && len==1) { //如果发过来的数组第一个存储的值是-1，并且数组长度是1，调用shake方法令窗口震动
shake();
continue; //终止本次循环，继续下次循环，因为震动后不需要执行下面的代码
}
String time=getCurrentTime(); //获取当前时间
String ip=packet.getAddress().getHostAddress(); //获取IP地址
String text = time+" "+ip+"said to me: \n"+msg+"\n"; //alt+shift+L抽取局部变量
view.append(text);
bw.write(text); //将聊天记录存在config.txt文件中
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
public String getCurrentTime() {
Date date=new Date(); //创建当前日期对象
SimpleDateFormat sdf=new SimpleDateFormat("yyyy-mm-dd hh:mm:ss");
return sdf.format(date);
}
public void centerPanel() {
Panel centerP=new Panel(); //创建中间的Panel
view = new TextArea();
sendText = new TextArea(5,1);
centerP.setLayout(new BorderLayout()); //设置为边界布局管理器
centerP.add(sendText,BorderLayout.SOUTH); //发送的文本区域放在南边
centerP.add(view,BorderLayout.CENTER); //显示区域放在中间
view.setEditable(false); //将显示的文本区域设置为不可编辑
view.setBackground(Color.WHITE); //因为显示的文本区域已经被设置为了不可编辑，它自动变成了灰色，所以要改成白色
view.setFont(new Font("xxx",Font.PLAIN,25)); //设置显示文本区域的字体大小
send.setFont(new Font("xxx",Font.PLAIN,25)); //设置显示文本区域的字体大小
this.add(centerP,BorderLayout.CENTER);
}
public void Frame() {
this.setLocation(500, 50);
this.setSize(500,500);
try {
socket=new DatagramSocket();
bw=new BufferedWriter(new FileWriter("config.txt",true));
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
new Receive().start();
}
public void southPanel() {
Panel southP=new Panel(); //创建南边的Panel
tf = new TextField(25);
tf.setText("127.0.0.1");
send = new Button("send");
log = new Button("log");
clear = new Button("clear");
shake = new Button("shake");
southP.add(tf);
southP.add(send);
southP.add(log);
southP.add(clear);
southP.add(shake);
this.add(southP,BorderLayout.SOUTH); //将Panel放在Frame的南边
}
public static void main(String[] args) {
new GUI_Chat();
}
}