会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132433个问题
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 2763楼



服务器端:

package com.sxt.a1;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Test {
	

	public static void main(String[] args) throws IOException {
		System.out.println("=====服务器端已启动=======");
		//(1)创建ServerSocket对象
		ServerSocket server = new ServerSocket(9999);
		//(2)监听是否有客户端发送请求连接
		Socket client = server.accept();
		//(3)获取输入流
		InputStream is = client.getInputStream();
		System.out.println((char)is.read());
		//(4)获取输出流
		OutputStream os = client.getOutputStream();
		
		os.write("收到了".getBytes());
		
		//(5)关闭流,关闭Socket
		if(os!=null) {
			os.close();
		}
		if(is!=null) {
			is.close();
		}
		if(client!=null) {
			client.close();
		}
	}
	
}
	
	

	
	


客户端:

package com.sxt.a2;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;


public class Test {
	public static void main(String[] args) throws IOException {
		System.out.println("=========客户端============");
		//(1)创建Socket对象
		Socket client = new Socket("198.168.31.113",9999);
		//(2)获取输出流
		OutputStream os = client.getOutputStream();
		os.write('a');
		//(3)获取输入流
		InputStream is = client.getInputStream();
		byte[] buf = new byte[1024];//中转站
		
		int len = 0;//读到的字节的个数
		while((len = is.read(buf))!=-1) {
			System.out.println(new String(buf,0,len));
		}
		//(4)关闭流
		
		if(is!=null) {
			is.close();
		}
		if(os!=null) {
			client.close();
		}
	
	}
}

运行结果:

服务器端:

blob.png


客户端

blob.png


老师你好,我先启动的服务器端,然后启动客户端,都启动了,运行正常但是没有任何动静(消息传动),老师连接视频上连接都有:“收到了”和“a”的传送,我的过了一段时间客户端报异常了,是网络连接超时,为什么我的服务器端和客户端连接不上呢?

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 2764楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 2765楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 2766楼

老师为什么实用if-else返回的结果是这样的

package com.bjsxt.thread.prosumer2;

/** 
 * <p>Title: TestProducer</p>  
 * <p>Description: 生产者模式</p>  
 * @author xiaoding
 * @date Jul 20, 2020  
 * @version 1.0 
 */
public class TestProducer implements Runnable{
    //功能属性
    private TestSupermarket supermarket;    //超市
    //构造方法
    public TestProducer(TestSupermarket supermarket) {
        this.supermarket = supermarket;
    }
    
    //定义线程体
    @Override
    public void run() {
        for (int i = 0;i<10;i++) {
            if (i % 2 != 0) {
                supermarket.set("旺仔", "小馒头");
            }else {
                supermarket.set("康师傅", "方便面");
            }
        }
    }
}

public class TestSupermarket {
    // 功能属性    
    private String brand;    //品牌
    private String name;    //名称
    private boolean flag;    //开关判断是否需要唤醒线程
    
    //构造方法
    public TestSupermarket() {}
    public TestSupermarket(String brand,String name) {
        this.brand = brand;
        this.name = name;
    }
    
    //get、set
    public String getBrand() {
        return brand;
    }
    public void setBrand(String brand) {
        this.brand = brand;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    
    //定义一个存储的方法
    public synchronized void set(String brand,String name) {
        if (flag) {
            try {
                this.wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }else {
            this.setBrand(brand);
            try {
                Thread.sleep(300);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            this.setName(name);
            System.out.println("=========生产者产生了:==========" + this.getBrand() + this.getName());
            this.notify();
            flag = true;
        }    
    }
    //定义一个取值的方法
    public synchronized void get() {
        if (flag) {
            System.out.println("消费者取走了:=============" + this.getBrand() + this.getName());
            this.notify();
            flag = false;
        }else {
            try {
                this.wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
}

public class TestConsumer implements Runnable{
    //功能属性
    private TestSupermarket supermarket;    //超市
    //构造方法
    public TestConsumer(TestSupermarket supermarket) {
        this.supermarket = supermarket;
    }
    
    //定义线程体
    @Override
    public void run() {
        for (int i = 0;i<10;i++) {
            supermarket.get();
        }
    }
}

public class Test {
    public static void main(String[] args) {
        //创建超市类
        TestSupermarket sup = new TestSupermarket();
        //创建生产者类
        TestConsumer p = new TestConsumer(sup);
        //创建消费者类
        TestProducer p2 = new TestProducer(sup);
        
        //创建代理角色线程类,并启动线程
        new Thread(p).start();
        new Thread(p2).start();
    }
}


JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 2767楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 2768楼

老师,是不是我那个地方写错了

package com.bjsxt.thread.prosumer2;

/** 
 * <p>Title: TestConsumer</p>  
 * <p>Description: 消费者模式</p>  
 * @author xiaoding
 * @date Jul 20, 2020  
 * @version 1.0 
 */
public class TestConsumer implements Runnable{
    //功能属性
    private TestSupermarket supermarket;    //超市
    //构造方法
    public TestConsumer(TestSupermarket supermarket) {
        this.supermarket = supermarket;
    }
    
    //定义线程体
    @Override
    public void run() {
        for (int i = 0;i<10;i++) {
            supermarket.getConsumer();
        }
    }
}


package com.bjsxt.thread.prosumer2;

/** 
 * <p>Title: TestProducer</p>  
 * <p>Description: 生产者模式</p>  
 * @author xiaoding
 * @date Jul 20, 2020  
 * @version 1.0 
 */
public class TestProducer implements Runnable{
    //功能属性
    private TestSupermarket supermarket;    //超市
    //构造方法
    public TestProducer(TestSupermarket supermarket) {
        this.supermarket = supermarket;
    }
    
    //定义线程体
    @Override
    public void run() {
        for (int i = 0;i<10;i++) {
            if (i % 2 != 0) {
                supermarket.setProducer("旺仔","小馒头");
            }else {
                supermarket.setProducer("康师傅","红烧牛肉面");
            }
        }
    }
}

package com.bjsxt.thread.prosumer2;

/** 
 * <p>Title: TestSupermarket</p>  
 * <p>Description: 超市(存储)</p>  
 * @author xiaoding
 * @date Jul 20, 2020  
 * @version 1.0 
 */
public class TestSupermarket {
    // 功能属性    
    private String brand;    //品牌
    private String name;    //名称
    
    //构造方法
    public TestSupermarket() {}
    public TestSupermarket(String brand,String name) {
        this.brand = brand;
        this.name = name;
    }
    
    //get、set
    public String getBrand() {
        return brand;
    }
    public void setBrand(String brand) {
        this.brand = brand;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    
    //定义同步方法Producer
    public synchronized void setProducer(String brand,String name) {
        this.setBrand(brand);
        try {
            Thread.sleep(300);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        this.setName(name);
        System.out.println("生产者生产了:" + this.getBrand() + this.getName());
    }
    public synchronized void getConsumer() {
        System.out.println("消费者消费了:" + this.getBrand() + this.getName());
    }
}

测试结果:

1.png

JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 2769楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/异常机制 2770楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 2771楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 2774楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

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