会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132774个问题
JAVA 全系列/第一阶段:JAVA 快速入门/数组和数据存储 37202楼
JAVA 全系列/第六阶段:项目管理与SSM框架/Maven 37204楼
Python 全系列/第一阶段:Python入门/编程基本概念 37205楼

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class ChatRoomServer {

   //定义公共数据区
   public static String buf;
   public static void main(String[] args) {
       System.out.println("Chat  Server Version 1.0");
       System.out.println("Listen at 8888");
       try (ServerSocket ss = new ServerSocket(8888)) {

           while(true){
               Socket socket = ss.accept();
               System.out.println("连接到 "+socket.getInetAddress());
               new ChatReceive(socket).start();
               new ChatSend(socket).start();
           }
       } catch (IOException e) {
           throw new RuntimeException(e);
       }



   }
}

class ChatReceive extends Thread{
   private Socket socket;
   public ChatReceive(Socket socket){
       this.socket = socket;
   }

   @Override
   public void run() {
          doChatReceive();
   }



   public  void doChatReceive(){
        try(BufferedReader bf = new BufferedReader(new InputStreamReader(socket.getInputStream()))){
            while(true){
                String str = bf.readLine();
                synchronized ("abc"){
                    ChatRoomServer.buf = "["+socket.getInetAddress()+"]"+ str;
                    "abc".notifyAll();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
   }
}

class ChatSend extends Thread{
   private Socket socket;
   public ChatSend (Socket socket){
       this.socket = socket;
   }

   @Override
   public void run() {
       sendMsg();
   }
   private  void sendMsg() {
        try(PrintWriter pw = new PrintWriter(socket.getOutputStream())){
            while (true) {
                synchronized ("abc "){
                  //先让发送消息的线程处于等待状态
                    "abc".wait();
                    //将公共数据区中的消息发送给客户端
                    pw.println(ChatRoomServer.buf);
                    pw.flush();

                }

            }
        }catch (Exception e){
            e.printStackTrace();
        }
   }
}

老师想问一下连接后客户端一直循环输出null是什么问题呢?


image.pngimage.png

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程 37207楼
Python 全系列/第十二阶段:Python_Django3框架/Django进阶 37208楼
Python 全系列/第九阶段:Python_Django2 框架(隐藏)/Django模型层 37209楼
Python 全系列/第二阶段:Python 深入与提高/GUI编程(隐藏) 37212楼
Python 全系列/第一阶段:Python入门/序列 37214楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 37215楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637