|
|
|
|
本视频是解读性视频，所以希望您已经看过了本知识点的内容，并且编写了相应的代码之后，带着疑问来观看，这样收获才多。 不建议一开始就观看视频
4分36秒 本视频采用html5方式播放，如无法正常播放，请将浏览器升级至最新版本，推荐火狐，chrome，360浏览器。 如果装有迅雷，播放视频呈现直接下载状态，请调整 迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)。 chrome 的 视频下载插件会影响播放，如 IDM 等，请关闭或者切换其他浏览器 步骤 1 : 同时收发消息 步骤 2 : 练习-有图形界面的聊天程序 步骤 3 : 答案-有图形界面的聊天程序
在练习-服务端和客户端互聊 中，只能一人说一句，说了之后，必须等待另一个人的回复，才能说下一句。
这是因为接受和发送都在主线程中，不能同时进行。 为了实现同时收发消息，基本设计思路是把收发分别放在不同的线程中进行 1. SendThread 发送消息线程 2. RecieveThread 接受消息线程 3. Server一旦接受到连接，就启动收发两个线程 4. Client 一旦建立了连接，就启动收发两个线程 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;
}
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) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
package socket;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class RecieveThread extends Thread {
private Socket s;
public RecieveThread(Socket s) {
this.s = s;
}
public void run() {
try {
InputStream is = s.getInputStream();
DataInputStream dis = new DataInputStream(is);
while (true) {
String msg = dis.readUTF();
System.out.println(msg);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
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) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
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) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
在查看答案前，尽量先自己完成，碰到问题再来查看答案，收获会更多
本视频是解读性视频，所以希望您已经看过了本答案的内容，带着疑问来观看，这样收获才多。 不建议一开始就观看视频
6分5秒 本视频采用html5方式播放，如无法正常播放，请将浏览器升级至最新版本，推荐火狐，chrome，360浏览器。 如果装有迅雷，播放视频呈现直接下载状态，请调整 迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)。 chrome 的 视频下载插件会影响播放，如 IDM 等，请关闭或者切换其他浏览器 package socket;
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.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
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();
}
}
});
}
}
package socket;
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;
import java.net.UnknownHostException;
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();
}
}
});
}
}
HOW2J公众号，关注后实时获知最新的教程和优惠活动，谢谢。
问答区域
2024-07-17
GUI界面完善客户端与服务器通信
回答已经提交成功，正在审核。 请于 我的回答 处查看回答记录，谢谢
2024-07-17
基于 多线程 和 网络 实现客户端和服务端通信
回答已经提交成功，正在审核。 请于 我的回答 处查看回答记录，谢谢
2022-02-11
想问一下站长 如果想要通过输入一个特定的消息来关闭这个程序 怎么可以实现。
2022-01-15
练习 - 有图形界面的聊天程序
2021-03-19
图形界面的聊天工具写出来了
提问太多，页面渲染太慢，为了加快渲染速度，本页最多只显示几条提问。还有 20 条以前的提问，请 点击查看
提问之前请登陆
提问已经提交成功，正在审核。 请于 我的提问 处查看提问记录，谢谢
|
