JavaSE项目之聊天室

import java.net.InetAddress;
import java.net.UnknownHostException;
public abstract class HostInfo {
	public static  String IP=getIP();
	public static final int PORT=10086;
	public static final int NUM=50;
	public static final String NEW_LINE="\r\n";
	private static String getIP(){
 try {
 return InetAddress.getLocalHost().getHostAddress();
 } catch (UnknownHostException e) {
 e.printStackTrace();
 return null;
 }
	}
}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public abstract class Release {
	public static void release(Socket socket,BufferedWriter bw){
 release(null,socket,null,bw);
	}
	public static void release(Socket socket,BufferedReader br){
 release(null,socket,br,null);
	}
	public static void release(Socket socket){
 release(null,socket,null,null);
	}
	public static void release(ServerSocket server){
 release(server,null,null,null);
	}
	public static void release(ServerSocket server,Socket socket,BufferedReader br,BufferedWriter bw){
 if(server!=null){
 try {
 server.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
 if(socket!=null){
 try {
 socket.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
 if(br!=null){
 try {
 br.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
 if(bw!=null){
 try {
 bw.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
 
	}
}

import java.awt.Dimension;
import java.awt.FlowLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import 聊天室.server.Server;
import 聊天室.utils.HostInfo;
public class UIserver extends JFrame {
	private JPanel jp=new JPanel();
	private JLabel jl_ipTips=new JLabel("服务器ip:");
	public static JTextField jtf_ip=new JTextField(HostInfo.IP);
	private JLabel jl_portTips=new JLabel("服务器端口:");
	public static JTextField jtf_port=new JTextField(HostInfo.PORT+"");
	public static JButton bt_open=new JButton("启动服务器");
	public static JTextArea jta_log=new JTextArea();
	private JScrollPane jsp_log=new JScrollPane(jta_log);
	public UIserver(){
 jp.setLayout(new FlowLayout());
 jp.add(jl_ipTips);
 jp.add(jtf_ip);
 jp.add(jl_portTips);
 jp.add(jtf_port);
 jp.add(bt_open);
 jp.add(jsp_log);
 jl_ipTips.setPreferredSize(new Dimension(100, 50));
 jtf_ip.setPreferredSize(new Dimension(150, 50));
 jl_portTips.setPreferredSize(new Dimension(100, 50));
 jtf_port.setPreferredSize(new Dimension(150, 50));
 bt_open.setPreferredSize(new Dimension(260, 50));
 jsp_log.setPreferredSize(new Dimension(260, 192));
 jta_log.setLineWrap(true);
 jta_log.setEditable(false);
 bt_open.addActionListener(new ActionListener(){
 @Override
 public void actionPerformed(ActionEvent arg0) {
 new Server().start();
 }
 });
 add(jp);
 setTitle("聊天应用控制服务器");
 setBounds(100, 50, 300, 400);
 setResizable(false);
 setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
 setVisible(true);
	}
	public static void main(String[] args) {
 new UIserver();
	}
}

import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.FocusAdapter;
import java.awt.event.FocusEvent;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import 聊天室.client.Client;
public class UIclient extends JFrame {
	private JPanel jp_chat=new JPanel();
	public static JTextArea jta_chat=new JTextArea();
	private JScrollPane jsp_chat=new JScrollPane(jta_chat);
	private JPanel jp_send=new JPanel();
	public static  JTextField jtf_desip=new JTextField("请输入对方Ip");
	public static  JTextArea jta_message=new JTextArea();
	private JScrollPane jsp_message=new JScrollPane(jta_message);
	private JButton bt_send=new JButton("发送");
	private Client client;
	public UIclient(){
 jp_chat.add(jsp_chat);
 jta_chat.setLineWrap(true);
 jta_chat.setEditable(false);
 jsp_chat.setPreferredSize(new Dimension(550, 400));
 jp_send.add(jtf_desip);
 jp_send.add(jsp_message);
 jta_message.setLineWrap(true);
 jp_send.add(bt_send);
 jtf_desip.setPreferredSize(new Dimension(100, 50)); 
 jsp_message.setPreferredSize(new Dimension(250, 50));
 bt_send.setPreferredSize(new Dimension(100, 50));
 jtf_desip.addFocusListener(new FocusAdapter(){
 @Override
 public void focusGained(FocusEvent e) {
 jtf_desip.setText("");
 }
 });
 jta_message.addFocusListener(new FocusAdapter(){
 @Override
 public void focusGained(FocusEvent e) {
 jta_message.setText("");
 }
 });
 bt_send.addActionListener(new ActionListener(){

 @Override
 public void actionPerformed(ActionEvent arg0) {
 client.send();
 }
 });
 add(jp_chat, BorderLayout.CENTER);
 add(jp_send, BorderLayout.SOUTH);
 setTitle("群聊窗口");
 setBounds(300, 100, 600, 500);
 setResizable(false);
 setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
 setVisible(true);
 client=new Client();
 client.start();
	}
	public static void main(String[] args) {
 new UIclient();
	}
}

import java.io.IOException;

import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import 聊天室.ui.UIserver;
import 聊天室.utils.HostInfo;
import 聊天室.utils.Release;
public class Server extends Thread {
	private ServerSocket server;
	public static List clients=new ArrayList<>();
	@Override
	public void run() {
 try {
 server=new ServerSocket(Integer.parseInt(UIserver.jtf_port.getText().trim()));
 } catch (IOException e) {
 Release.release(server);
 throw new RuntimeException("服务器端口被占！");
 }
 UIserver.bt_open.setText("已启动服务器");
 UIserver.bt_open.setEnabled(false);
 UIserver.jta_log.append("服务器成功启动！"+HostInfo.NEW_LINE);
 new Accept().start();
	}
	class Accept extends Thread{
 private Socket socket;
 @Override
 public void run() {
 int num=0;
 while(num
 try {
 socket=server.accept();
 } catch (IOException e) {
 Release.release(socket);
 throw new RuntimeException("客户端连接失败！");
 }
 num++;
 String str="第 "+num+" 个客户端连接成功！==>"+socket.getInetAddress().getHostAddress()+" :"+socket.getPort()+HostInfo.NEW_LINE;
 UIserver.jta_log.append(str);
 clients.add(new Transport(socket));
 }
 UIserver.jta_log.append("超出服务器负荷！");
 Release.release(server);
 }
	}
}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import 聊天室.utils.Release;
public class Transport extends Thread {
	private Socket socket;
	private String ip;
	public Transport(Socket socket){
 this.socket=socket;
 this.ip=socket.getInetAddress().getHostAddress();
 this.start();
	}
	@Override
	public void run() {
 BufferedReader br=null;
 BufferedWriter ownbw=null;
 try {
 br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
 ownbw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
 } catch (IOException e) {
 Server.clients.remove(this);
 Release.release(socket);
 throw new RuntimeException("获取流失败！");
 }
 String str=null;
 try {
 while((str=br.readLine())!=null){
 String[] split = str.split(":", 2);
 if(split.length<=1){
 ownbw.write("数据格式错误！");
 ownbw.newLine();
 ownbw.flush();
 }
 String desip=split[0];
 String cOntent=split[1];
 BufferedWriter desbw=null;
 boolean isOnLine=false;
 for(Transport des:Server.clients){
 if(desip.equals(des.ip)){
 isOnLine=true;
 desbw=new BufferedWriter(new OutputStreamWriter(des.socket.getOutputStream()));
 desbw.write(str);
 desbw.newLine();
 desbw.flush();
 }
 }
 if(!isOnLine){
 ownbw.write("对方不在线！");
 ownbw.newLine();
 ownbw.flush();
 }
 }
 } catch (IOException e) {
 Server.clients.remove(this);
 Release.release(socket);
 throw new RuntimeException("获取流失败！");
 }
	}
}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import 聊天室.ui.UIclient;
import 聊天室.ui.UIserver;
import 聊天室.utils.HostInfo;
import 聊天室.utils.Release;
public class Client extends Thread {
	private Socket socket;
	@Override
	public void run() {
 try {
 socket=new Socket(UIserver.jtf_ip.getText().toLowerCase(), Integer.parseInt(UIserver.jtf_port.getText().trim()));
 }  catch (IOException e) {
 Release.release(socket);
 throw new RuntimeException("客户端创建失败！");
 }
 BufferedReader br=null;
 try {
 br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
 } catch (IOException e) {
 Release.release(socket);
 throw new RuntimeException("获取流失败！");
 }
 String str=null;
 try {
 while((str=br.readLine())!=null){
 UIclient.jta_chat.append(str+HostInfo.NEW_LINE);
 }
 } catch (IOException e) {
 Release.release(socket);
 throw new RuntimeException("获取流失败！");
 }
	}
	public void send(){
 new Send().start();
	}
	class Send extends Thread{
 @Override
 public void run() {
 BufferedWriter bw=null;
 try {
 bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
 } catch (IOException e) {
 Release.release(socket,bw);
 throw new RuntimeException("获取流失败！");
 }
 String str=UIclient.jtf_desip.getText().trim()+":"+UIclient.jta_message.getText().trim();
 try {
 bw.write(str);
 bw.newLine();
 bw.flush();
 } catch (IOException e) {
 Release.release(socket,bw);
 throw new RuntimeException("获取流失败！");
 }
 }
	}
}