本文實例為大家分享了Java網(wǎng)絡(luò)編程實現(xiàn)多線程聊天的具體代碼，供大家參考，具體內(nèi)容如下

聊天程序如果是單線程，會導(dǎo)致沒人只能說一句，并且說了以后，必須等到另一個人的回復(fù)，才能說第二句。收發(fā)都在主線程中，不能同時進行。

解決方法：

將收發(fā)放到兩個不同的線程

1. SendThread 發(fā)送消息線程2. RecieveThread 接受消息線程3. Server一旦接受到連接，就啟動收發(fā)兩個線程4. Client 一旦建立了連接，就啟動收發(fā)兩個線程

1 SendThread

package socket;import java.io.DataOutputStream;import java.io.IOException;import java.io.OutputStream;import java.net.Socket;import java.util.Scanner;public class SendThread extends Thread { private Socket s; public SendThread(Socket s) {this.s = s; } @Override public void run() {try { OutputStream os = s.getOutputStream(); DataOutputStream dos = new DataOutputStream(os); while(true){Scanner sc = new Scanner(System.in);String str = sc.next();dos.writeUTF(str); }} catch (IOException e) { e.printStackTrace();} }}

2 RecieveThread

package socket;import java.io.DataInputStream;import java.io.IOException;import java.io.InputStream;import java.net.Socket;public class RecieveThread extends Thread { private Socket s; public RecieveThread(Socket s) {this.s = s; } @Override public void run() {InputStream is = null;try { is = s.getInputStream(); DataInputStream dis = new DataInputStream(is); while(true){String msg = dis.readUTF();System.out.println(msg); }} catch (IOException e) { e.printStackTrace();} }}

3 Server

package socket;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;public class Server { public static void main(String[] args) {try { ServerSocket ss = new ServerSocket(8888); System.out.println('監(jiān)聽端口號：8888'); Socket s = ss.accept(); new SendThread(s).start(); new RecieveThread(s).start();} catch (IOException e) { e.printStackTrace();} }}

4 Client

package socket;import java.io.IOException;import java.net.Socket;import java.net.UnknownHostException;public class Client { public static void main(String[] args) {try { Socket s = new Socket('127.0.0.1', 8888); new SendThread(s).start(); new RecieveThread(s).start();} catch (UnknownHostException e) { e.printStackTrace();} catch (IOException e) { e.printStackTrace();} }}簡單對話框

Server

package socket;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.DataInputStream;import java.io.DataOutputStream;import java.net.ServerSocket;import java.net.Socket;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JTextArea;import javax.swing.JTextField;public class GUIServer { public static void main(String[] args) throws Exception {JFrame f = new JFrame();f.setTitle('server');f.setSize(400, 300);f.setLocation(100, 200);f.setLayout(null);JButton b = new JButton('send');b.setBounds(10, 10, 80, 30);f.add(b);final JTextField tf = new JTextField();tf.setBounds(10, 110, 80, 30);f.add(tf);final JTextArea ta = new JTextArea();ta.setBounds(110,10, 200, 300);f.add(ta);f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);f.setVisible(true);ServerSocket ss = new ServerSocket(8888);System.out.println('listenning on port:8888');final Socket s = ss.accept();new Thread() { public void run() {while (true) { try {DataInputStream dis = new DataInputStream(s.getInputStream());String text = dis.readUTF();ta.append(text+'rn'); } catch (Exception e) {e.printStackTrace(); }} }}.start();b.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) {String text = tf.getText();ta.append(text+'rn');try { DataOutputStream dos = new DataOutputStream( s.getOutputStream()); dos.writeUTF(text);} catch (Exception ex) { ex.printStackTrace();} }}); }}

Client

package socket;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.DataInputStream;import java.io.DataOutputStream;import java.net.Socket;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JTextArea;import javax.swing.JTextField;public class GUIClient { public static void main(String[] args) throws Exception {JFrame f = new JFrame();f.setTitle('client');f.setSize(400, 300);f.setLocation(600, 200);f.setLayout(null);JButton b = new JButton('send');b.setBounds(10, 10, 80, 30);f.add(b);final JTextField tf = new JTextField();tf.setBounds(10, 110, 80, 30);f.add(tf);final JTextArea ta = new JTextArea();ta.setBounds(110,10, 200, 300);f.add(ta);f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);f.setVisible(true);final Socket s = new Socket('127.0.0.1', 8888);new Thread() { public void run() {while (true) { try {DataInputStream dis = new DataInputStream(s.getInputStream());String text = dis.readUTF();ta.append(text+'rn'); } catch (Exception e) {e.printStackTrace(); }} }}.start();b.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) {String text = tf.getText();ta.append(text+'rn');try { DataOutputStream dos = new DataOutputStream( s.getOutputStream()); dos.writeUTF(text);} catch (Exception ex) { ex.printStackTrace();} }}); }}

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。