how2j.cn


工具版本兼容问题
如果使用单线程开发Socket应用,那么同一时间,要么收消息,要么发消息,不能同时进行。

为了实现同时收发消息,就需要用到多线程

本视频是解读性视频,所以希望您已经看过了本知识点的内容,并且编写了相应的代码之后,带着疑问来观看,这样收获才多。 不建议一开始就观看视频



4分36秒
本视频采用html5方式播放,如无法正常播放,请将浏览器升级至最新版本,推荐火狐,chrome,360浏览器 如果装有迅雷,播放视频呈现直接下载状态,请调整 迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)



步骤 1 : 同时收发消息   
步骤 2 : 练习-有图形界面的聊天程序   
步骤 3 : 答案-有图形界面的聊天程序   

步骤 1 :

同时收发消息

练习-服务端和客户端互聊 中,只能一人说一句,说了之后,必须等待另一个人的回复,才能说下一句。

这是因为接受和发送都在主线程中,不能同时进行。 为了实现同时收发消息,基本设计思路是把收发分别放在不同的线程中进行

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(); } } }
步骤 2 :

练习-有图形界面的聊天程序

Or  姿势不对,事倍功半! 点击查看做练习的正确姿势
练习-有图形界面的聊天程序
步骤 3 :

答案-有图形界面的聊天程序

在查看答案前,尽量先自己完成,碰到问题再来查看答案,收获会更多
本视频是解读性视频,所以希望您已经看过了本答案的内容,带着疑问来观看,这样收获才多。 不建议一开始就观看视频

6分5秒 本视频采用html5方式播放,如无法正常播放,请将浏览器升级至最新版本,推荐火狐,chrome,360浏览器 如果装有迅雷,播放视频呈现直接下载状态,请调整 迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)


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公众号,关注后实时获知布最新的教程和优惠活动,谢谢。


问答区域    
2017-08-11 请问那两个接收线程不是一直在工作吗。为什么只有在发送一条信息后才会显示一条?我觉得即使不发送也应该不停的显示 “客户端/(服务端)发过来的信息为null” 才对啊?
4654646



请问那两个接收线程不是一直在工作吗。为什么只有在发送一条信息后才会显示一条?我觉得即使不发送也应该不停的显示 “客户端/(服务端)发过来的信息为null” 才对啊? 发送线程是因为scanner.next()才会假装“暂停”的, 但是接受线程一直都是true在循环啊,为什么他不会连续输出,即便是没有输入过来也应该是连续的输出: “客户端/(服务端)发过来的信息为null” 才对啊? 有输入过来才会显示一条 “客户端(服务端)发过来的信息为+(我所发的信息)”
//service的
new Thread() {
				public void run() {
					try {
						while (true) {
							String receive = dataInputStream.readUTF();
							System.out.println("客户端发过来信息:" + receive);
						}
					} catch (IOException e) {
						// TODO 自动生成的 catch 块
						e.printStackTrace();
					}
				};
			}.start();


//client的
new Thread() {
				public void run() {
					try {
						while (true) {
							String receive = dataInputStream.readUTF();
							System.out.println("服务端发过来信息:" + receive);
						}
					} catch (IOException e) {
						// TODO 自动生成的 catch 块
						e.printStackTrace();
					}
				};
			}.start();

							


2 个答案

zzxssb1997 答案时间:2018-03-21
receive()方法是阻塞方法,在没有接受到消息是,线程会卡在这一个方法不往下执行。

how2j 答案时间:2017-08-14
是一直在工作呀,而且会等到客户端有发消息过来才有反应,这样不是更好吗? 如果一直在打印null,那么间隔多少时间合适呢?1毫秒吗? 那么CPU不是会被占用光了嘛




答案 或者 代码至少填写一项, 如果是自己有问题,请重新提问,否则站长有可能看不到





2016-08-20 拼写错误
西门有雪
RecieveThread -- ReceiveThread




1 个答案

how2j 答案时间:2016-08-22
谢谢提醒 :)




答案 或者 代码至少填写一项, 如果是自己有问题,请重新提问,否则站长有可能看不到




2016-04-19 疑惑
2016-04-19 疑惑,求教




提问之前请登陆
关于 JAVA 中级-网络编程-多线程聊天 的提问

尽量提供截图代码异常信息,有助于分析和解决问题。 也可进本站QQ群交流: 620943819
提问尽量提供完整的代码,环境描述,越是有利于问题的重现,您的问题越能更快得到解答。
对教程中代码有疑问,请提供是哪个步骤,哪一行有疑问,这样便于快速定位问题,提高问题得到解答的速度
在已经存在的几千个提问里,有相当大的比例,是因为使用了和站长不同版本的开发环境导致的,比如 jdk, eclpise, idea, mysql,tomcat 等等软件的版本不一致。
请使用和站长一样的版本,可以节约自己大量的学习时间。 站长把教学中用的软件版本整理了,都统一放在了这里, 方便大家下载: http://how2j.cn/k/helloworld/helloworld-version/1718.html

上传截图