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

while(true){ String msg=br.readLine(); synchronized("abc"){ //把读取到的数据写入公共数据区 ChatRoomServer.buf="["+this.socket.getInetAddress()+"]:"+msg; //唤醒发送消息的线程对象。 "abc".notifyAll(); } } while(true){ synchronized("abc"){ //把读取到的数据写入公共数据区 ChatRoomServer.buf="["+this.socket.getInetAddress()+"]:"+br.readLine(); //唤醒发送消息的线程对象。 "abc".notifyAll(); } }分析一下在实现一对多交流的过程中为什么前面的代码可以实现功能,而后面那段代码会进入阻塞class ChatSend extends Thread{
    private Socket socket;
    /**创建发送数据线程*/
    /**
     * 向客户端发送消息的线程类
     */
    public ChatSend(Socket socket){
        this.socket=socket;
    }

    @Override
    public void run() {
        this.sendMsg();
    }

    /**
     * 将公共数据区的消息发送给客户端
     */
    public 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();
        }
    }
}
/**
 * 接收客户端消息的线程类
 */
class ChatReceive extends Thread{
    private Socket socket;
    public ChatReceive(Socket socket){
        this.socket=socket;
    }

    @Override
    public void run() {
            this.receiveMsg();
    }

    /**
     * 实现接收客户端发送的消息
     */
    public void receiveMsg(){
        try(BufferedReader br=new BufferedReader(new InputStreamReader(this.socket.getInputStream()))){
            while(true){
                String msg=br.readLine();
                synchronized("abc"){
                    //把读取到的数据写入公共数据区
                ChatRoomServer.buf="["+this.socket.getInetAddress()+"]:"+msg;
                    //唤醒发送消息的线程对象。
                "abc".notifyAll();
            }
            }

        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
//定义公共数据区
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 serverSocket=new ServerSocket(8888)){
            while(true){

                Socket socket=serverSocket.accept();
                System.out.println("连接到: "+socket.getInetAddress());
                new ChatReceive(socket).start();
                new ChatSend(socket).start();

            }

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

老师,为什么我一开始用的后面那段代码运行后是陷入阻塞的,用了课上老师的前面那段代码就好了,我个人感觉br.readLine()放在哪里好像没什么影响,就不是很理解为什么会陷入阻塞

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

老师我的main方法没有问题怎么会报这种错误?

package com.bjsxt.server;
import java.io.File;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
/**
 * 解析xml
 * @author ADMIN
 *
 */
public class webDom4j {
 private List<Entity> entityList;//用于存储N多Entity,而每一个Entity都是servlet-name与servlet-class
 private List<Mapping>mappingList;//用于存储N多Mapping,而每一个Mapping都是一个servlet-name与N多个url-pattern
 public List<Entity> getEntityList() {
  return entityList;
 }
 public void setEntityList(List<Entity> entityList) {
  this.entityList = entityList;
 }
 public List<Mapping> getMappingList() {
  return mappingList;
 }
 public void setMappingList(List<Mapping> mappingList) {
  this.mappingList = mappingList;
 }
 public webDom4j(List<Entity> entityList, List<Mapping> mappingList) {
  super();
  this.entityList = entityList;
  this.mappingList = mappingList;
 }
 public webDom4j() {
  entityList=new ArrayList<Entity>();//初始化集合
  mappingList=new ArrayList<Mapping>();
 
 }
 //获取Document对象的方法 
 private Document getDocument(){
   try {
    //(1)创建SAXReader对象
    SAXReader reader=new SAXReader(); 
    //(2)调用read方法
    return reader.read(new File("src/WEB_INFO/web.xml"));
   } catch (DocumentException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   return null;
  }
 public void parse(Document doc){
  //(1)获取根元素
  Element root=doc.getRootElement();//web-app
  //(2)获取servlet子元素
  for(Iterator<Element>ite=root.elementIterator("servlet");ite.hasNext();){
   Element subElement=ite.next();//得到每一个servlet
   //创建一个实体类
   Entity ent=new Entity();//用于存储servlet-name与servlet-class
    for(Iterator<Element>subIte=subElement.elementIterator();subIte.hasNext();){
      Element ele=subIte.next();//可能是servlet-name,也可能是servlet-class
      if("servlet-name".equals(ele.getName())){
       ent.setName(ele.getText());//给实体中类中的name赋值
      }else if("serblet-class".equals(ele.getName())){
       ent.setClazz(ele.getText());//给实体类中的clazz赋值
      }
    }
    //将Entity添加到集合中
    entityList.add(ent);
  }
  //测试
  for (Entity entity : entityList) {
   System.out.println(entity.getName()+"\t"+entity.getClazz());
  }
 }
 //用于测试
 public static void main(String[] args){
  webDom4j web=new webDom4j();
  web.parse(web.getDocument());
 } 
 
 
}

image.png

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

老师您好! 我都是按照视频来敲的 但是跟老师的不一样我这些地方都会报错,能帮忙看看吗?,谢谢


package com.bjsxt.servlet;


import com.bjsxt.server.Request;

import com.bjsxt.server.Response;


public class LoginServlet extends Servlet {


@Override

public void doGet(Request req, Response rep) throws Exception {

//获取请求参数

String nameString=req.getParamter("username");

String pwdString=req.getParamter("pwd");

if (this.login(name, pwd)) {

//调用响应中的构建内容的方法

rep.println(name+"登陆成功");

}else {

rep.println(name+"登陆失败,对不起,账号或密码不正确");

}

}

private boolean login(String name,String pwd){

if ("bjsxt".equals(name)&&"123".equals(pwd)) {

return true;

}

return false;

}


@Override

public void doPost(Request req, Response rep) throws Exception {

// TODO Auto-generated method stub

}


}

截图:image.png

代码:

package com.bjsxt.server;

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

import com.bjsxt.servlet.Servlet;
import com.bjsxt.util.IOCloseutil;

public class Dispatcher implements Runnable{
	private Request req;
	private Response rep;
	private	Socket	client;
	private	int code=200;//状态码
	//构造方法初始化属性
	public Dispatcher(Socket client){
		//将局部变量的值赋给成员变量
		this.client=client;
		try {
			req=new Request(this.client.getInputStream());
			rep=new Response(this.client.getOutputStream());
		} catch (IOException e) {
			code=500;
			return;
		}
	}
	@Override
	public void run() {
		//根据不同的url创建指定的Servlet对象
		//System.out.println(req.getUrl());
		Servlet servlet=WebApp.getServlet(req.getUrl());
		if (servlet==null) {
			this.code=404;
		}else{
			//调用相应的Servlet中的service
			try {
				servlet.service(req, rep);
			} catch (Exception e) {
				this.code=500;
			}
		}
		//将响应结果推送到客户机的浏览器
		rep.pushToClient(code);
		IOCloseutil.closeAll(client);
	}

}

截图:image.png这个老师那里没有错 但是我这边就报错了


代码:

package com.bjsxt.server;


import java.io.BufferedWriter;

import java.io.IOException;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.UnsupportedEncodingException;


import org.omg.IOP.Codec;


import com.bjsxt.util.IOCloseutil;


public class Response {/*响应*/

private StringBuilder headInfo;//响应头

private StringBuilder content;//响应内容

private int length;//响应内容的长度

//流

private BufferedWriter bw;

//两个常量,换行和空格

private static final String CRLF="\r\n";//换行

private static final String BLANK=" ";//空格

//构造方法

public Response(){

headInfo=new StringBuilder();

content=new StringBuilder();

}

//带参构造方法

public Response(OutputStream os){

this();//调用本类的无参构造方法

try {

bw=new BufferedWriter(new OutputStreamWriter(os, "utf-8"));

} catch (UnsupportedEncodingException e) {

headInfo=null;

}

}

//构造正文部分

public Response print(String info){

content.append(info);

try {

length+=info.getBytes("utg=f-8").length;

} catch (UnsupportedEncodingException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return this;

}

public Response println(String info){


content.append(info).append(CRLF);

try {

length+=(info+CRLF).getBytes("utf-8").length;

} catch (UnsupportedEncodingException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return this;

}

//构造响应头

private void createHeadInfo(){

Object code;

headInfo.append("HTTP/1.1").append(BLANK).append(code).append(BLANK);

switch (code) {

case 200:

headInfo.append("OK");

break;

case 500:

headInfo.append("SERVER ERROR");

break;

default:

headInfo.append("NOT FOUND");

break;

}

headInfo.append(CRLF);

headInfo.append("Content-Type:text/html;charset=ytf-8").append(CRLF);

headInfo.append("Content-Length:"+length).append(CRLF);

headInfo.append(CRLF);

}

/**

* 推动到客户机的浏览器

* @param code

*/

public void pushToClient(int code){

if (headInfo==null) {

code=500;

}

try {

//调用本类中的构造响应头

this.createHeadInfo(code);

bw.write(headInfo.toString());

bw.write(content.toString());

bw.flush();

this.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

private void createHeadInfo(int code) {

// TODO Auto-generated method stub

}

public void close(){

IOCloseutil.closeAll(bw);

}

}

截图:image.png这个提示的是:不能打开类型 Object 的值。只允许使用可转换的 int 值或枚举常量


代码:

package com.bjsxt.server;


import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStreamWriter;

import java.net.ServerSocket;

import java.net.Socket;


import com.bjsxt.servlet.Servlet;

import com.bjsxt.util.IOCloseutil;


public class Server {//服务器,用于启动和停止服务

private ServerSocket server;

private boolean isShutDown=false;//默认没有出错

public static void main(String[] args) {

Server server=new Server();//创建服务器对象

server.start();

}

public void start(){

this.start(8888);

}

public void start(int port){

try {

server=new ServerSocket(port);

this.receive();//调用接受请求信息的方法

} catch (IOException e) {

isShutDown=true;

}

}

private void receive() {

try {

while(!isShutDown){

//(1)监听

Socket client=server.accept();

//创建线程类的对象

Dispatcher dis=new Dispatcher(client);

//创建代理类并启动线程

new Thread(dis).start();

}

} catch (IOException e) {

this.stop();//关闭服务器

}

}

public void stop(){

isShutDown=true;

IOCloseutil.closeAll(server);

}

}

截图:image.png提示:类型 IOCloseutil 中的方法 closeAll(Closeable...)对于参数(ServerSocket)不适用

 问题出现的比较多  辛苦老师帮忙解答一下,谢谢!

JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3634楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 3636楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3637楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 3642楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/数据结构 3643楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

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