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

class ManTou {
    private int id;

    public ManTou(int id) {
        this.id = id;
    }

    public int getId() {
        return this.id;
    }
}

/**
 * 定义缓冲区类
 */
class SyncStack {
    //定义存放馒头的盒子
    private ManTou[] manTous = new ManTou[10];
    //定义操作盒子的索引
    private int index;

    /**
     * 放馒头的方法
     */

    public synchronized void put(ManTou manTou) {
        //判断盒子是否已满
        while (this.index == this.manTous.length) {
            try {
                this.wait();    //wait()必须在synchronized块中调用  wait()执行后 线程会将持有的对象锁释放 并进入阻塞状态 其他需要该对象锁的线程就可以继续运行了
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //唤醒取馒头的线程
        this.notify();      //该方法必须在synchronized块中调用 会唤醒处于等待状态队列中的一个线程
        this.manTous[this.index] = manTou;
        this.index++;
    }

    /**
     * 取馒头的方法
     */
    public synchronized ManTou get() {
        //判断盒子是否已空
        while (this.index == 0) {
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.notify();
        this.index--;
        return this.manTous[this.index];
    }
}

/**
 * 定义生产者线程类
 */
class ShengChan extends Thread {
    private SyncStack syncStack;

    public ShengChan(SyncStack syncStack) {
        this.syncStack = syncStack;
    }
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            ManTou manTou = new ManTou(i);
            syncStack.put(manTou);
            System.out.println("生产第"+(i+1)+"个馒头");
        }
    }
}

/**
 * 定义消费者线程类
 */
class Xiaofei extends Thread {
    private SyncStack syncStack;

    public Xiaofei(SyncStack syncStack) {
        this.syncStack = syncStack;
    }
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            ManTou manTou = this.syncStack.get();
            System.out.println("消费了" + (i+1) + "个馒头");

        }
    }
}

public class ProduceThread {
    public static void main(String[] args) {
        SyncStack syncStack = new SyncStack();
        new ShengChan(syncStack).start();
        new Xiaofei(syncStack).start();
    }
}

image.png

image.png

image.png

image.png

老师为什么我这里会出现先消费的现象啊? 

JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 3872楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 3874楼

你好,老师,我是按照视频中的代码敲得,但是最后在浏览器没有显示登陆成功的字样

package com.hy.test;
/***
 * 在html中使用post方法,通过程序然后获取输入的信息,并且对web浏览器做出回应
 */

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.net.ServerSocket;
import java.net.Socket;



public class Server3 {
	public static void main(String[] args) {
		String BLANK="\n";
		String CRLF="\r\n";//换行
		//1创建ServerSocket对象
		ServerSocket server=null;
		//2监听是否有客户端发来请求
		Socket client=null;
		//3创建Socket对象	
				//4创建输入流
		InputStream is=null;
		try {
			server = new ServerSocket(8080);	
			client = server.accept();
			is=client.getInputStream();
			byte[] buf=new byte[10240];
			int len=is.read(buf);
			System.out.println(new String(buf,0,len));
			/***
			 * 以下代码是对浏览器的请求做出响应
			 */
			StringBuilder sb=new StringBuilder();
			StringBuilder sbContent=new StringBuilder();//响应的文本
			sbContent.append("<html><head><title>响应结果</title></head>");
			sbContent.append("<body>登陆成功</body></html>");
			//1拼接像迎头
			sb.append("HTTP/1.1").append(BLANK).append(200).append(BLANK).append("ok");
			sb.append(CRLF);//换行
			sb.append("Content-Type: text/html;charset=utf-8");
			sb.append(CRLF);
			sb.append("Content-Length:").append(sbContent.toString().getBytes().length).append(CRLF);//换行,代表响应头和相应正文之间的空行
			sb.append(sbContent);
			
			//通过流输出
			BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(client.getOutputStream(),"utf-8"));
			bw.write(sb.toString());
			bw.flush();
			bw.close();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
		//关闭流
		try {
			IOClose.closeAll(is,client,server);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		}
	}

	private static InputStream InputStream(InputStream inputStream) {
		// TODO Auto-generated method stub
		return null;
	}
}

html代码

<html>
<head>
<title>我的第一个html</title>
</head>
<body>
<h1>hello world</h1>
<form action="http://localhost:8080/index.html" method="post">
<p>用户名:<input type="text" id="uname" name="username" /></p>
<p>密码:<input type="password" id="pwd" name="password" /></p>
<p><input type="submit" value="登陆"/></p>
</form>
</body>
</html>


image.png


 浏览器没有显示,但是eclipse控制台输出的正常的,所以想问一下是什么原因,感谢

image.png

JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3880楼

package cn;

import java.io.IOException;
import java.net.*;
import java.util.Scanner;
/**客户端1
*/
public class UDPClient1 {
    public static void main(String[] args) throws IOException {
        //创建DatagramSocket对象
        DatagramSocket ds = new DatagramSocket(8888);//本应用程序端口
        while (true){
            try {
                //准备要发送的数据
                byte[]buf = talk().getBytes();
                //创建数据对象
                DatagramPacket dp1 = new DatagramPacket(
                        buf, buf.length, InetAddress.getByName("localhost"), 9999);
                //发送数据
                ds.send(dp1);
                byte[]buf2 = new byte[8196];
                DatagramPacket dp2 = new DatagramPacket(
                        buf, buf.length);
                ds.receive(dp2);
                System.out.println(new String(dp2.getData()));
                buf2=null;
                buf2 = new byte[1024];//清空残余数据
            } catch (IOException e) {
                e.printStackTrace();
                //关闭
                ds.close();
            }
        }
    }

    /**
     * 用户输入聊天信息
     * @return
     */
    public static String talk(){
        Scanner sc = new Scanner(System.in);
        return "客户端1:"+sc.nextLine();
    }
}
package cn;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;
/**客户端2
*/
public class UDPCLient2 {
    public static void main(String[] args) throws IOException {
        DatagramSocket ds1 = new DatagramSocket(9999);
        byte []buf = new byte[8196];

        while (true){
            DatagramPacket dp1 = new DatagramPacket(
                    buf,buf.length);
            //查看接收到的数据
            ds1.receive(dp1);
            String str = new String(dp1.getData());
            buf=null;//清空残余数据,重新分配新的空间
            buf = new byte[8196];
            System.out.println(str);
            byte[]buf2 = talk().getBytes();
            DatagramPacket dp2 = new DatagramPacket(
                    buf2,buf2.length,dp1.getAddress(),dp1.getPort());
            try {
                ds1.send(dp2);
            } catch (IOException e) {
                e.printStackTrace();
                //关闭流
                ds1.close();
            }
        }
    }

    /**
     * 用户输入聊天信息
     * @return
     */
    public static String talk(){
        Scanner sc = new Scanner(System.in);
        return "客户端2:"+sc.nextLine();
    }
}

    上述代码实现了两个客户端的简单通信。

     但是有BUG,就是两个客户端启动后,只有客户端1给客户端2发送数据后,双方通信才正常。

     原因可能是客户端2在通信前不知道客户端的地址和端口号

     目前暂时找不到解决办法,请老师给指导指导呗,谢谢@_@

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 3882楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3885楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

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