会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132358个问题

客户端:

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class MutualChatSocketClient {
    public static void main(String[] args) {
        try (Socket socket = new Socket("127.0.0.1",8888);
             Scanner scanner = new Scanner(System.in);
             BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
             PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
             )
        {

            System.out.println("与服务端连接成功!");

            while (true){
                //这里一定要注意顺序:客户端先发送消息,再接收服务端的消息

                //向服务端发送消息
                String clientInput = scanner.nextLine();
                pw.println(clientInput);
                pw.flush();

                //接收服务端的消息
                System.out.println("服务端说:"+br.readLine());

                //服务端想要结束对话
                if ("exit".equals(br.readLine())){
                    break;
                }

            }
        }catch (Exception e){
            e.printStackTrace();
            System.out.println("客户端启动失败");
        }
    }
}

服务端:

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class MutualChatSocketServer {
    public static void main(String[] args) {
        System.out.println("服务端启动,监听端口号为8888!");
        try (ServerSocket serverSocket = new ServerSocket(8888);
             Socket socket = serverSocket.accept();
             Scanner scanner = new Scanner(System.in);
             BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
             PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
             ){

            System.out.println("与客户端连接成功!");

            while (true){
                //这里一定要注意顺序:服务端先接收客户端的消息,再发送消息

                //接收客户端的消息
                System.out.println("客户端说:"+br.readLine());

                //客户端想要结束对话
                if ("exit".equals(br.readLine())){
                    break;
                }

                //向客户端发送消息
                String serverInput = scanner.nextLine();
                pw.println(serverInput);
                pw.flush();
            }

        }catch(Exception e){
            e.printStackTrace();
            System.out.println("服务端启动失败");
        }
    }
}

130dc8483bdfb12b2d23d3fe3998891.png8b9c09435163ad0478ab6af36e6a59f.png老师您好,我遇到的问题是,客户端向服务端发送消息后,服务端可以收到,但是服务端向客户端发送消息后,客户端却收不到。问题定位到了是循环体中的if语句,我把if语句都注释掉就可以了,请问老师这里的if语句为什么会影响客户端接收服务端口的消息呢,if的条件不满足的话不是直接就跳过了吗?应该不受影响的啊

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程 196楼

//守护线程
class Daemon implements Runnable{

    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            System.out.println(Thread.currentThread().getName()+" "+i);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

//用户线程
class UserThread implements Runnable{

    @Override
    public void run() {

        //守护线程为用户线程服务
        Thread thread1 = new Thread(new Daemon(),"守护线程:");
        //设置该对象为守护线程
        thread1.setDaemon(true);
        //启动守护线程
        thread1.start();

        /*
        守护线程会随着用户线程的死亡而死亡
         */
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName()+" "+i);
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        System.out.println("用户线程结束");
    }
}

public class DaemonThreadTest {
    public static void main(String[] args) {

        //创建用户线程
        Thread thread = new Thread(new UserThread(),"用户线程:");
        //启动用户线程
        thread.start();
        try {
            Thread.sleep(9000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("主线程结束");
    }
}

控制台输出如下:

用户线程: 0
守护线程: 0
用户线程: 1
守护线程: 1
用户线程: 2
用户线程: 3
守护线程: 2
用户线程: 4
用户线程结束
守护线程: 3
守护线程: 4
守护线程: 5
守护线程: 6
守护线程: 7
守护线程: 8
主线程结束

老师您好,在代码中我的守护线程守护的是用户线程,但是当用户线程死亡后守护线程并没有随之死亡,而是等到主线程结束守护线程才死亡,请问是哪里出现了问题呢?

JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 198楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 199楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 200楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器 201楼

430A12BB-17EB-4602-8E26-7143512C2D5B.jpeg

JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 202楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 203楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/反射技术 204楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/反射技术 205楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/反射技术 206楼

/**

 * 账户类

 */

class Account{

  //账号

  private String accountNo;

  //账户的余额

  private double balance;



  public Account() {

   }



  public Account(String accountNo, double balance) {

    this.accountNo = accountNo;

    this.balance = balance;

   }



  public String getAccountNo() {

    return accountNo;

   }



  public void setAccountNo(String accountNo) {

    this.accountNo = accountNo;

   }



  public double getBalance() {

    return balance;

   }



  public void setBalance(double balance) {

    this.balance = balance;

   }

}

/**

 * 取款线程

 */

class DrawThread implements Runnable{

  //账户对象

  private Account account;

  //取款金额

  private double drawMoney;

  public DrawThread(Account account,double drawMoney){

    this.account = account;

    this.drawMoney = drawMoney;

   }



  /**

   * 取款线程

   */

  @Override

  public void run() {

    //判断当前账户余额是否大于或等于取款金额

    if(this.account.getBalance() >= this.drawMoney){

      System.out.println(Thread.currentThread().getName()+" 取钱成功!吐出钞票:"+this.drawMoney);

      try {

        Thread.sleep(1000);

       } catch (InterruptedException e) {

        e.printStackTrace();

       }

      //更新账户余额

      this.account.setBalance(this.account.getBalance()- this.drawMoney);

      System.out.println("\t 余额为:"+this.account.getBalance());

     }else{

      System.out.println(Thread.currentThread().getName()+" 取钱失败,余额不足");

     }

   }

}



public class TestDrawMoneyThread {

  public static void main(String[] args) {

    Account account = new Account("1234",1000);

    new Thread(new DrawThread(account,800),"老公").start();

    new Thread(new DrawThread(account,800),"老婆").start();

   }

}


添加Get  方法是什么作用呢

JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 207楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/异常机制 208楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

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