06.Java网络编程（java GUI实现的聊天界面）
目前测试存在两个问题 1.最初是继承Frame来实现界面显示，后来发现，界面中部分控件存在时而显示时而不显示的问题，查找资料之后，将Frame修为JFrame，并且修改setVisible的时机，界面显示的问题解决，不显示的原因，有一种说法就是注释中提到的 2.界面显示问题解决之后，目前接收消息的线程无法正常接收，导致震动功能也无法实现，原因还有待进一步排查 package com.ren.socket; 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.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.sql.Date; import java.text.SimpleDateFormat; import javax.swing.JFrame; /** * 先调整窗口大小才会显示出组件，而不是立马显示出组件，在组件还未添加到面板前就将窗口 * （JFrame）设为可见（setVisible（）），控件并不会引发重绘。解决方法很简单， * 只需要等所有组件都准备好以后才将JFrame的setVisible（）设置为true。 * 非要在调用setVisible（）之后添加组件，那么你也可以这样做：getContentPane().invalidate(); * * 即便这样做了，也没有达到想要的效果 */ public class GUIChat_UDP extends JFrame{ private static final long serialVersionUID = 1L; private Button send; private Button log; private Button clear; private Button shake; private TextArea viewText; private TextArea sendText; private TextField tField; private DatagramSocket socket; private BufferedWriter writer; public GUIChat_UDP(){ Init(); southPanel(); centerPanel(); event(); getContentPane().invalidate(); } private void centerPanel() { Panel center = new Panel(); //显示的文本区域 viewText = new TextArea(); //发送的文本区域 sendText = new TextArea(); //设置为边界布局管理器 center.setLayout(new BorderLayout()); //发送的文本区域放在南边 center.add(sendText, BorderLayout.SOUTH); //显示区域放在中间 center.add(viewText, BorderLayout.CENTER); //设置不可以编辑 viewText.setEditable(false); //设置背景色 viewText.setBackground(Color.WHITE); //设置字体大小 sendText.setFont(new Font("xxx", Font.PLAIN, 15)); viewText.setFont(new Font("xxx", Font.PLAIN, 15)); //将这个panel设置在中间位置 this.add(center,BorderLayout.CENTER); } private void southPanel() { Panel south = new Panel(); //用于输入聊天对象的IP地址 tField = new TextField(15); tField.setText("127.0.0.1"); send = new Button("send"); log = new Button("log"); clear = new Button("clear"); shake = new Button("shake"); //添加如布局 south.add(tField); south.add(send); south.add(log); south.add(clear); south.add(shake); this.add(south, BorderLayout.SOUTH); } private void Init() { this.setLocation(500, 50); this.setSize(400,600); this.setVisible(true); //开启接收消息线程 new Receive().start(); try { //初始化发送码头 socket = new DatagramSocket(); writer = new BufferedWriter(new FileWriter("log.txt",true)); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } private void event() { //关闭按钮事件 this.addWindowListener(new WindowAdapter() { @Override public void windowClosing(WindowEvent e) { try { socket.close(); writer.close(); System.exit(0); } catch (Exception e2) { } } }); //发送按钮事件 send.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { try { send(); } catch (IOException e1) { e1.printStackTrace(); } } }); //消息记录 log.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { try { logFile(); } catch (IOException e1) { e1.printStackTrace(); } } }); //清空屏幕 clear.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { viewText.setText(""); } }); //震动 shake.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { try { send(new byte[]{-1}, tField.getText()); } catch (IOException e1) { e1.printStackTrace(); } } }); //快捷键监听 sendText.addKeyListener(new KeyAdapter() { @Override public void keyReleased(KeyEvent e) { //control+enter键发送消息 if (e.getKeyCode() == KeyEvent.VK_ENTER && e.isControlDown()) { try { send(); } catch (Exception e2) { } } } }); } //通过不断改变界面在屏幕中的位置达到震动的效果 protected void shake() { int x = this.getLocation().x; int y = this.getLocation().y; for (int i = 0; i < 10; i++) { try { this.setLocation(x + 10, y + 10); Thread.sleep(20); this.setLocation(x + 10, y - 10); Thread.sleep(20); this.setLocation(x - 10, y + 10); Thread.sleep(20); this.setLocation(x - 10, y - 10); Thread.sleep(20); this.setLocation(x, y); } catch (Exception e) { } } } protected void logFile() throws IOException { //刷新缓冲区 writer.flush(); //读取消息记录文件 FileInputStream fis = new FileInputStream("log.txt"); ByteArrayOutputStream baos = new ByteArrayOutputStream(); int len; byte[] arr = new byte[8192]; while((len = fis.read(arr))!= -1){ baos.write(arr,0,len); } String log = baos.toString(); viewText.setText(log); fis.close(); baos.close(); } protected void send() throws IOException { String message = sendText.getText(); String ip = tField.getText(); ip = ip.trim().length() == 0?"255.255.255.255":ip; send(message.getBytes(),ip); String time = getCurrentTime(); String sendMessage = time+" 我对:"+(ip.equals("255.255.255.255")?"所有人":ip)+"说:\r\n "+message+"\r\n\r\n"; viewText.append(sendMessage); //将发送的消息写入文件 writer.write(sendMessage); sendText.setText(""); } private void send(byte[] bytes, String ip) throws IOException { DatagramPacket packet = new DatagramPacket (bytes,bytes.length,InetAddress.getByName(ip),9999); socket.send(packet); } private String getCurrentTime() { Date date = new Date(System.currentTimeMillis()); SimpleDateFormat format = new SimpleDateFormat("yyyy年MM月dd日HH:mm:ss"); return format.format(date); } //接收消息的线程 private class Receive extends Thread{ @Override public void run() { super.run(); try { DatagramSocket socket = new DatagramSocket(9999); DatagramPacket packet = new DatagramPacket(new byte[8192], 8192); while(true){ socket.receive(packet); byte[]arr = packet.getData(); int len = packet.getLength(); if (arr[0] == -1 && len == 1) { shake(); continue; } String message = new String(arr,0,len); String time = getCurrentTime(); String ip = packet.getAddress().getHostAddress(); String receivedMessage = time+" "+ip+"对我说:\r\n"+message+"\r\n"; viewText.append(receivedMessage); //写入收到的消息 writer.write(receivedMessage); } } catch (Exception e) { } } } public static void main(String[] args) { new GUIChat_UDP(); } }
