Java Socket通讯编程——多线程网络聊天程序

用js获取url的参数值

睡前用电脑会对健康造成的

8月28

大 | 中 | 小

21:57Heck

Web开发 From: 本站原创

用java进行网络编程确实很方便，很容易上手 jzan

。这几天用java进行socket编程，收获不少。首先，进行服务端的编程，作为服务端，编程主要按下面几个步骤进行：

作为客户端则分为下面几个步骤，其实和服务端差不多，只是少了用ServerSocket进行监听。

上面这些只是一个单线程的服务端->客户端的程序，只能进行一次通讯，多次通讯将被告知无法连接。
这时，我们就需要用到进程Thread进行编程，将其改造成多线程聊天程序，可以同时进行多客户端的连接与发送信息。
代码如下：

//Server.java
import java.awt.*;
import java.net.*;
import java.io.*;
public class Server extends Thread {
    ServerSocket skt;
    Socket Client[]=new Socket[10];;
    Socket Client1=null;
    int i = 0;
    TextArea in;
    int port,k=0,l=0;

//BufferedReader theInputStream;
    PrintStream theOutputStream;
    //String readin;
    Face chat;

public Server(int port, Face chat) {
        try {
            this.port = port;
            skt = new ServerSocket(port);
            this.chat = chat;
        } catch (IOException e) {
            chat.ta.append(e.toString());
        }
    }

public void run() {

chat.ta.append("等待连线......");

while (true) {
            //System.out.print(""+i+"\n");
            try
        {
          Client[k] = skt.accept(); /* 接收客户连接 */
          //当有客户端连接时就新建一个子线程
          if (i < 2) {
            ServerThread server[] = new ServerThread[10];
             server[k]= new ServerThread(Client[k], this.chat, i);
             l=server.length;
             server[k].start();
            chat.ta.append("客户端" + Client[k].getInetAddress() + "已连线\n");
            /*theInputStream = new BufferedReader(new InputStreamReader(Client
                .getInputStream()));*/
            //for(int j=0;j<server.length;j++)
            theOutputStream = new PrintStream(server[k].getClient().getOutputStream());
            i = server[k].getI();
            k++;
          } else {
            //theOutputStream = new PrintStream(null);
          }

} catch (SocketException e) {
            //chat.ta.append("连线中断！\n");

//chat.clientBtn.setEnabled(true);
            //chat.serverBtn.setEnabled(true);
            //chat.tfaddress.setEnabled(true);
            //chat.tfport.setEnabled(true);
            //try {

//skt.close();
                    //Client.close();
                //} catch (IOException err) {
                //    chat.ta.append(err.toString());
                //}
            } catch (IOException e) {
                chat.ta.append(e.toString());
            }
        }

}

public void dataout(String data) {
        //for(int j=0;j<l;j++)
        theOutputStream.println(data);
    }
}

class ServerThread extends Thread {
    ServerSocket skt;
    Socket Client;
    TextArea in;
    int port;
    int i;
    BufferedReader theInputStream;
    PrintStream theOutputStream;
    String readin;
    Face chat;

务端子线程
    public ServerThread(Socket s, Face chat, int i) {
        this.i = ++i;
        Client = s;
        //this.port = port;
        //skt = new ServerSocket(port);
        this.chat = chat;
    }

public int getI() {
        return this.i;
    }
    public Socket getClient() {
        return this.Client;
    }
    public void run() {
        //chat.ta.append("等待连线......");
        try {
            //Client = skt.accept(); /* 接收客户连接 */
            //chat.ta.append("客户端" + Client.getInetAddress() + "已连线\n");
            theInputStream = new BufferedReader(new InputStreamReader(Client.getInputStream()));
            theOutputStream = new PrintStream(Client.getOutputStream());
            while (true) {
                readin = theInputStream.readLine();
                chat.ta.append(readin + "\n");
            }

} catch (SocketException e) {
            chat.ta.append("连线中断！\n");
            chat.clientBtn.setEnabled(true);
            chat.serverBtn.setEnabled(true);
            chat.tfaddress.setEnabled(true);
            chat.tfport.setEnabled(true);
            try {
                i--;
                skt.close();
                Client.close();
            } catch (IOException err) {
                chat.ta.append(err.toString());
            }
        } catch (IOException e) {
            chat.ta.append(e.toString());
        }
    }

public void dataout(String data) {
        theOutputStream.println(data);
    }
}

//Client.java

import java.net.*;
import java.io.*;
import javax.swing.Timer;
class Client extends Thread {
    Socket skt;
    InetAddress host;
    int port;

BufferedReader theInputStream;
    PrintStream theOutputStream;
    String readin;

Face chat;

public Client(String ip, int p, Face chat) {
        try {
            host = InetAddress.getByName(ip);
            port = p;
            this.chat = chat;
        } catch (IOException e) {
            chat.ta.append(e.toString());
        }
    }

public void run() {
        try {
            chat.ta.append("尝试连线......");

skt = new Socket(host, port);
            chat.ta.append("连线成功\n");

theInputStream = new BufferedReader(new InputStreamReader(skt
                    .getInputStream()));

theOutputStream = new PrintStream(skt.getOutputStream());
            //Timer myTimer = new Timer();
            while (true) {
                readin = theInputStream.readLine();
                chat.ta.append(readin + "\n");
            }
        } catch (SocketException e) {
            chat.ta.append("连线中断！\n");
            chat.clientBtn.setEnabled(true);
            chat.serverBtn.setEnabled(true);
            chat.tfaddress.setEnabled(true);
            chat.tfport.setEnabled(true);
            try {
                skt.close();
            } catch (IOException err) {
                chat.ta.append(err.toString());
            }
        } catch (IOException e) {
            chat.ta.append(e.toString());
        }
    }

public void dataout(String data) {
        theOutputStream.println(data);
    }
}

件界面，进行按键监听调用。

//face.java

import java.awt.*;
import java.awt.event.*;

public class Face extends Frame {
    /**
     *
     */
    private static final long serialVersionUID = 1L;
    Button clientBtn, serverBtn;
    TextArea ta;
    TextField tfaddress, tfport, tftype;
    int port;
    Client client;
    Server server;
    boolean iamserver;
    static Face frm;

public Face() {
        clientBtn = new Button("客户端");
        serverBtn = new Button("服务器");
        ta = new TextArea("", 10, 50, TextArea.SCROLLBARS_BOTH);
        tfaddress = new TextField("192.168.1.104", 20);
        tfport = new TextField("2000");
        tftype = new TextField(50);

tftype.addKeyListener(new TFListener());
        ta.setEditable(false);

setLayout(new FlowLayout());
        add(tfaddress);
        add(tfport);
        add(clientBtn);
        add(serverBtn);
        add(ta);
        add(tftype);
        setSize(400, 300);
        setTitle("我的聊天室");
        this.setVisible(true);

clientBtn.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {

port = Integer.parseInt(tfport.getText());

client = new Client(tfaddress.getText(), port, frm);

client.start();

tfaddress.setEnabled(false);
                tfport.setEnabled(false);
                serverBtn.setEnabled(false);
                clientBtn.setEnabled(false);
            }
        });

serverBtn.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {

port = Integer.parseInt(tfport.getText());

server = new Server(port, frm);

server.start();

iamserver = true;
                tfaddress.setText("成为服务器");

addWindowListener(new WindowAdapter() {
            public void windowClosing(WindowEvent e) {
                System.exit(0);
            }
        });

}

public static void main(String args[]) {
        frm = new Face();
    }

private class TFListener implements KeyListener {
        public void keyPressed(KeyEvent e) {

if (e.getKeyCode() == KeyEvent.VK_ENTER) {

ta.append(">" + tftype.getText() + "\n");

if (iamserver)
                    server.dataout(tftype.getText());
                else
                    client.dataout(tftype.getText());

tftype.setText("");
            }
        }

public void keyTyped(KeyEvent e) {
        }

public void keyReleased(KeyEvent e) {
        }
    }
}

这个程序我限制了连接数，大家可以根据自己的需要进行修改。

来源：Heck's Blog
地址：https://www.heckjj.com/Java-Socket-code-chat/
转载时须以链接形式注明作者和原始出处及本声明，否则将追究法律责任，谢谢配合！

Tags: java , socket , 套接字 , 通讯 , 多线程 , 聊天

阅读(1749) | 评论(0) | 引用(0)

< 2026 > < 6 >
日	一	二	三	四	五	六
	1	2	3	4	5	6
7	8	9	10	11	12	13
14	15	16	17	18	19	20
21	22	23	24	25	26	27
28	29	30

Heck's Blog

Java Socket通讯编程——多线程网络聊天程序

关于博主

分类

日历

统计

最新日志

其他

选择模板

链接

最新评论

赞助商链接

归档