Java 版仿QQ

package com.ooyhao.client; import java.awt.List; import java.awt.TextField; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.InetAddress; import java.net.Socket; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashSet; import java.util.Set; import javax.swing.JOptionPane; import com.google.gson.Gson; import com.ooyhao.pojo.DataPackage; import com.ooyhao.ui.GroupChatFrame; //客户端 public class Client { public static void main(String[] args) throws Exception { GroupChatFrame frame = new GroupChatFrame("username"); Socket socket = null; //动态获取本机ip地址 InetAddress ia = InetAddress.getLocalHost(); //当服务器未启动时，弹出提示框。 try { socket = new Socket(ia.getHostAddress(), 8888); }catch (Exception e) { JOptionPane.showMessageDialog(frame, "服务器未启动"); System.exit(0); } //弹出输入框，要求用户输入用户名 frame.setTitle(socket.getInetAddress().getHostAddress()); while(true) { String inputContent = null; inputContent = JOptionPane.showInputDialog( frame, "输入你的名字(" + "不允许不输入或只输入空格):","服务器ip:"+"192.168.91.1", JOptionPane.QUESTION_MESSAGE ); System.out.println("输入的内容: " + inputContent); if(inputContent == null || "".equals(inputContent) || "".equals(inputContent.trim()) ) { System.exit(0); }else { //发送一条状态信息为1的信息，用户告知服务器，此客户端上线。 TextField field = frame.getTextField(); List list = frame.getList(); frame.setTitle(inputContent); String message = field.getText(); DataPackage dataPackage = new DataPackage(); //要发送给谁 Set<String> dest = new HashSet<String>(); String[] strs = list.getItems(); for(String s : strs) { dest.add(s); } String sender = frame.getTitle(); Integer state = 1; dataPackage.setDest(dest); dataPackage.setMessage(message); dataPackage.setSender(sender); dataPackage.setState(state); try { // 通过socket获取发送数据的输出流,并将其包装成一个缓冲字符流 BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); Gson gson = new Gson(); writer.write(gson.toJson(dataPackage)); writer.newLine(); writer.flush(); } catch (IOException e1) { e1.printStackTrace(); } InputStream in = socket.getInputStream(); BufferedReader reader = new BufferedReader(new InputStreamReader(in)); String line = null; line = reader.readLine(); Gson gson = new Gson(); DataPackage data = gson.fromJson(line, DataPackage.class); if(data.getState() == 0) { JOptionPane.showMessageDialog(frame, "用户名存在"); }else { SimpleDateFormat sdf = new SimpleDateFormat("hh:mm:ss"); String time = sdf.format(new Date()); frame.getTextArea().append(data.getSender()+ " "+time+"\r\n "+ data.getMessage()+"\r\n"+"\r\n"); //更新之前的好友列表 frame.getList().removeAll(); for(String s : data.getDest()) { //将新的好友列表添加上去 frame.getList().add(s); } break; } } } //客户端注册成功之后，开启两个线程，进行数据的发送和接收。 new ClientReceiveThread(socket,frame).start(); new ClientSendThread(socket,frame).start(); } }