聊天室设计

JAVA的课程设计选择的聊天室，最开始不会写，完全没思路，然后去看了一下有关线程的一些知识，最后也是结合了一些人的想法写出来的聊天室。

如果服务器放在本地电脑的话，有可能会客户端在别的电脑上运行不了，主要原因就是因为连不上服务器。我个人觉得可能是与防火墙这些有关系。可以在服务器上运行这个服务器，然后可以连接。

    package Chat;
/**
 * 服务器端
 * @author opc
 */
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

public class Server {
    private List<MyChannel> all = new ArrayList<MyChannel>();
    private ServerSocket server;
    int i = 0;

    public static void main(String args[]) throws IOException {
        new Server().start();
    }

    public void start() throws IOException {
        server = new ServerSocket(9450);
        while (true) {
            Socket client = server.accept();
            MyChannel channel = new MyChannel(client);
            all.add(channel); // 统一管理
            new Thread(channel).start();
        }
    }

    /**
     * 一个客户端就是一个通道
     * 
     * @author opc
     *
     */

    private class MyChannel implements Runnable {
        private DataInputStream dis;
        private DataOutputStream dos;
        private boolean isRunning = true;
        private String name;
        public MyChannel(Socket client) {
            try {
                dis = new DataInputStream(client.getInputStream());
                dos = new DataOutputStream(client.getOutputStream());
                this.name = dis.readUTF();
                
            } catch (IOException e) {
                Closeutil.ColseAll(dis, dos);
                isRunning = false;
            }
        }
        /**
         *  接受数据
         * @return
         */
        
        private String receive() {
            String meg = "";
            try {
                meg = dis.readUTF();
            } catch (IOException e) {
                Closeutil.ColseAll(dis, dos);
                isRunning = false;
                all.remove(this);
            }
            return meg;
        }

        /**
         * 
         * 发送数据
         * 
         */

        private void send(String meg) {
            if (null == meg || meg.equals("")) {
                return;
            }
            try {
                dos.writeUTF(meg);
                dos.flush();
            } catch (IOException e) {
                Closeutil.ColseAll(dis, dos);
                isRunning = false;
                all.remove(this);
            }
        }
        
        /*
         * 发送给其他客户端
         */

        private void sendOthers(String meg) {
            SimpleDateFormat df = new SimpleDateFormat("hh:mm:ss");
            int loc = meg.indexOf(":");
        //    System.out.println(loc+"   "+meg.length()+"  "+meg);
            if(meg.charAt(loc+1)=='@'){
                /**
                 * 私聊
                 */
                String send_name = meg.substring(0,loc);
                String name = meg.substring(loc+2,meg.indexOf(":",loc+1));
                String content = meg.substring(meg.indexOf(":",loc+1)+1);
                for(MyChannel other:all){
                    if(other.name.equals(name)){
                        other.send(this.name+df.format(new Date())+"悄悄对你说 :  "+content+'
');
                    }else if(other.name.equals(send_name)){
                        other.send(this.name+df.format(new Date())+"对 "+name+" 悄悄说：   "+content+'
');
                    }
                }
            }else{
                // 遍历容器，群聊
                String sendname = meg.substring(0,meg.indexOf(":"));
                String content = meg.substring(meg.indexOf(":")+1);
                for (MyChannel other : all) {
                    other.send(sendname+"  "+df.format(new Date())+" : "+content+'
');
                }
            }
        }

        public void run() {
            while (isRunning) {
                sendOthers(receive());
            }

        }
    }
}

package Chat;

import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;



/**
 * 客户端
 * @author opc
 *
 */

public class Client {
    public static void main(String[] args) throws UnknownHostException, IOException {
        Socket client;
        Gird grid = new Gird();
        client = grid.getClient();
        Listenner listener = new Listenner();  
        grid.setMycommandListenner(listener);
        new Thread(new Receive(client,grid)).start();
    }
}

package Chat;

import java.io.Closeable;


/**
 * 关闭流的方法
 * @author opc
 *
 */
public class Closeutil {
    public static void ColseAll(Closeable...io){
        for(Closeable temp:io){
            try{
                if(temp!=null){
                    temp.close();
                }
            }catch(Exception e){
                
            }
        }
    }
}

package Chat;

import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.GridLayout;
import java.awt.Toolkit;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JSplitPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.border.TitledBorder;;

@SuppressWarnings("serial")
public class Gird extends JFrame{
    private JTextField name;  //姓名输入框
    private Socket client;    
    private JPanel TopFloor;  //顶层容器
    private JPanel LowFloor;  //底层容器
    private JTextArea TextArea;   //显示字体界面
    private JTextField TextFile;
    private JTextField TextIp;
    private JButton But_Send;    //发送按钮
    private JButton But_Name;    //确认按钮
    private JScrollPane rightScroll;    
    private JScrollPane leftScroll;
    private JSplitPane centerSplit;    
    @SuppressWarnings("unused")
    private MycommandListenner listener;    
    Gird() throws UnknownHostException, IOException{
        But_Send = new JButton("发送");
        But_Name = new JButton("确认");
        name = new JTextField(10);
        TextIp = new JTextField("118.89.51.123");
        TextFile = new JTextField();
        TextArea = new JTextArea();
        TopFloor = new JPanel();
        //this.client = client;
        client = new Socket(TextIp.getText(),3390);
        TopFloor.setLayout(new GridLayout(1,7));
        TopFloor.add(new JLabel("      姓名"));
        TopFloor.add(name);
        TopFloor.add(But_Name);
        TopFloor.add(new JLabel("           Ip"));
        TopFloor.add(new JLabel("  118.89.51.123"));
        rightScroll = new JScrollPane(TextArea);
        rightScroll.setBorder(new TitledBorder("消息框"));
        LowFloor = new JPanel(new BorderLayout());
        LowFloor.add(TextFile,"Center");
        LowFloor.add(But_Send,"East");
        LowFloor.setBorder(new TitledBorder("写消息"));
        centerSplit = new JSplitPane(JSplitPane.HORIZONTAL_SPLIT,leftScroll,rightScroll);
        setTitle("聊天室");
        setLayout(new BorderLayout());
        add(TopFloor,"North");
        add(centerSplit,"Center");
        add(LowFloor,"South");
        Toolkit kit = Toolkit.getDefaultToolkit();
        Dimension screensize = kit.getScreenSize();
        int screenHeight = screensize.height;
        int screenWhdth = screensize.width;
        setBounds(400,200,screenWhdth/2,screenHeight/2);
        setVisible(true);
        setDefaultCloseOperation(EXIT_ON_CLOSE);
    }
    /**
     * 获取姓名
     * @return
     */
    public String getname(){
        return name.getText();
    }
    /**
     * 添加监听
     * @param listener
     */
    void setMycommandListenner(MycommandListenner listener){
        this.listener = listener;
        listener.setJTextField(TextFile);
        listener.setJtextArea(TextArea);
        listener.set(client);
        listener.settextname(name);
        But_Name.addActionListener(listener);
        TextFile.addActionListener(listener);
        But_Send.addActionListener(listener);
    }
    
    public Socket getClient(){
        return client;
    }
    /**
     * 显示界面
     * @param meg
     */
    public void show(String meg){
        TextArea.append(meg);
    }
    /**
     * 获取输入框中的文字
     * @return
     */
    public String getText(){
        return TextFile.getText();
    }
}

package Chat;

import java.awt.event.ActionEvent;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

import javax.swing.JTextArea;
import javax.swing.JTextField;

public class Listenner implements MycommandListenner {
    JTextArea textShow;
    JTextField textInput;
    JTextField textname;
    private DataOutputStream dos;
    Socket client;
    private String name;
    /**
     * 进行监听
     */
    public void actionPerformed(ActionEvent e) {
        if(e.getActionCommand().equals("确认")){
            this.setName(textname.getText());
            send(name);
            System.out.println(e.getActionCommand().toString());
        }else {            
            String meg = textInput.getText();
            send(name+":"+meg);
            //textShow.append(meg+'
');
            textInput.setText("");
        }
    }
    /**
     * 设置socket
     */
    public void set(Socket client){
        this.client = client;
        try {
            dos = new DataOutputStream(client.getOutputStream());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    /**
     * 设置名字
     */
    public void setName(String name){
        this.name = name;
    }
    @Override
    /**
     * 设置输入框
     */
    public void setJTextField(JTextField text) {
        textInput = text;
    }
    @Override
    /**
     * 设置屏幕的字
     */
    public void setJtextArea(JTextArea area) {
        textShow = area;
    }
    /**
     * 设置名字
     */
    public void settextname(JTextField text){
        textname = text;
    }
    /**
     * 发送消息
     * @param meg
     */
    public void send(String meg){
        if(!meg.equals("")){
            try {
                dos.writeUTF(meg);
                dos.flush();
            } catch (IOException e) {
                Closeutil.ColseAll(dos);
            }
        }
    }
}

package Chat;
/**
 * 一个监听的接口
 */
import java.awt.event.ActionListener;
import java.net.Socket;
import javax.swing.JTextArea;
import javax.swing.JTextField;

interface MycommandListenner extends ActionListener{
    
    public void setJTextField(JTextField text);
    public void setJtextArea(JTextArea area);
    public void set(Socket client);
    public void setName(String name);
    public void settextname(JTextField text);

}

package Chat;
/**
 * 用于客户端的信息接受
 * 
 * @author opc
 */
import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;

public class Receive implements Runnable {
    /**
     * 接受流
     */
    private DataInputStream dis;
    Gird grid;
    /**
     * 判断运行的标志
     */
    private boolean isRunning = true;
    public Receive() {
        
    }
    /**
     * 构造方法
     * @param client
     * @param grid
     */
    public Receive(Socket client,Gird grid){
        try {
            dis = new DataInputStream(client.getInputStream());
            this.grid = grid;
        } catch (IOException e) {
            isRunning = false;
            Closeutil.ColseAll(dis);
        }
    }
    /**
     * 接收数据
     * @return
     */
    public String receive(){
        String meg = "";
        try {
            meg = dis.readUTF();
        } catch (IOException e) {
            isRunning = false;
            Closeutil.ColseAll(dis);
        }
        return meg;
    }
    
    @Override
    /**
     * 重写run方法
     */
    public void run() {
        while(isRunning){
            grid.show(receive());
        }
    }
    
}