Socket套接字及多线程实现在线群聊示例

package com.etc;

import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;

public class Service {
    //回车符
    static final String CRLF="\r\n";
    //空格符
    static final String BLANK=" ";
    public static void main(String[] args) throws IOException {
        //新建服务端
        ServerSocket server=new ServerSocket(3001);
        while(true) {
            //接收请求
            Socket socket = server.accept();
            System.out.println("server start...");
            //拿到请求流
            InputStream inputStream = socket.getInputStream();
            //存储流的字节数组
            byte[] datas = new byte[1024 * 1024 * 10];
            int length = inputStream.read(datas);
            //拿到请求信息
            if(length > 0) {
                String str = new String(datas, 0, length);
                System.out.println(str);
            }

            //响应流
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            //请求体
            StringBuilder str1 = new StringBuilder();
            str1.append("");
            str1.append("");
            str1.append("");
            str1.append("");
            str1.append("");
            str1.append("我是中国人Hello World!");
            str1.append("");
            str1.append("");
            //请求头
            StringBuilder str2 = new StringBuilder();
            str2.append("HTTP/1.1").append(BLANK).append(200).append(BLANK);
            str2.append("OK");
            str2.append(CRLF);
            //2)  响应头(Response Head)
            str2.append("Server:bjsxt Server/0.0.1").append(CRLF);
            str2.append("Date:").append(new Date()).append(CRLF);
            str2.append("Content-type:text/html;charset=utf-8").append(CRLF);
            //正文长度 ：字节长度
            str2.append("Content-Length:").append(length).append(CRLF);
            str2.append(CRLF); //分隔符
            //将请求头请求体写出
            bw.append(str2.toString());
            bw.append(str1.toString());
            bw.flush();
        }
    }

}

package com.du;

import javax.swing.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

/**
 * 图形界面客户端
 */
public class Client extends JFrame {
    private JTextField textField;
    private JTextArea textArea;
    private JButton button;
    private DataOutputStream dos = null;// 数据的输出流，用来写入数据

    public Client() {
        setTitle("在线群聊");
        getContentPane().setLayout(null);

        JScrollPane scrollPane = new JScrollPane();
        scrollPane.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
        scrollPane.setBounds(12, 10, 506, 242);
        setBounds(10, 10, 544, 418);//设置窗口的出现坐标及它的宽与长
        setLocationRelativeTo(null);//居中显示
        getContentPane().add(scrollPane);

        textArea = new JTextArea();
        scrollPane.setViewportView(textArea);
        textArea.setEditable(false);
        textArea.setRows(10);

        textField = new JTextField();
        textField.setBounds(23, 308, 240, 21);
        getContentPane().add(textField);
        textField.setColumns(10);

        button = new JButton("发言");
        button.addActionListener(new ActionListener() {//点击按钮，发言聊天的内容
            public void actionPerformed(ActionEvent e) {
                String info = textField.getText();
                try {
                    dos.writeUTF(info);//传到服务器上去内容
                    dos.flush();
                    textField.setText("");//清空文本框
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
            }
        });
        button.setBounds(330, 308, 93, 23);
        getContentPane().add(button);
        setVisible(true);
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    }

    public static void main(String[] args) {
        Client client = new Client();
        client.clientTest();
    }

    public void clientTest() {
        Socket client = null;
        DataInputStream dis = null;// 数据的输入流，用来读取数据
        try {
            // 得到套接字对象第一个参数是服务端的地址,第二个参数是端口号
            client = new Socket("127.0.0.1", 6666);
            // 得到数据的输出流
            dos = new DataOutputStream(client.getOutputStream());
            // 得到数据的输入流
            dis = new DataInputStream(client.getInputStream());
            new ClientThread(dis).start();//专门读取从服务器端传递过来的信息
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    //客户端读取服务器端发送过来的内容以线程的形式
    class ClientThread extends Thread{

        private DataInputStream dis;

        public ClientThread(DataInputStream dis) {
            this.dis = dis;
        }

        @Override
        public void run() {
            try {
                while(true) {
                    String info = dis.readUTF();//读取服务端传递过来信息
                    textArea.append(info+"\n\r");//在多文本框中显示内容，并加回车换行符
                }
            }catch(Exception e) {
                e.printStackTrace();
            }finally {
                if(dis != null)
                    try {
                        dis.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
            }
        }
    }
}