本文小编为大家详细介绍“Java网络编程如何实现多线程聊天”，内容详细，步骤清晰，细节处理妥当，希望这篇“Java网络编程如何实现多线程聊天”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。
解决方法：
将收发放到两个不同的线程
1. SendThread 发送消息线程
2. RecieveThread 接受消息线程
3. Server一旦接受到连接，就启动收发两个线程
4. Client 一旦建立了连接，就启动收发两个线程
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("监听端口号：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+"\r\n");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}.start();
b.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String text = tf.getText();
ta.append(text+"\r\n");
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+"\r\n");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}.start();
b.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String text = tf.getText();
ta.append(text+"\r\n");
try {
DataOutputStream dos = new DataOutputStream(
s.getOutputStream());
dos.writeUTF(text);
} catch (Exception ex) {
ex.printStackTrace();
}
}
});
}
}读到这里，这篇“Java网络编程如何实现多线程聊天”文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注亿速云行业资讯频道。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/u/4065875/blog/4416396
