javaSE第十五部分网络编程(4)B—S服务器，使用socket徒手实现web服务器-源码交易平台丞旭猿

packagedemo.net.bs_demo;importjava.io.IOException;importjava.io.InputStream;importjava.net.ServerSocket;importjava.net.Socket;publicclassBaseDemo{publicstaticvoidmain(String[]args)throwsIOException{ServerSocketserver=newServerSocket(8000);Socketsocket=server.accept();InputStreamin=socket.getInputStream();byte[]bytes=newbyte[1024];intlen=in.read(bytes);System.out.println(newString(bytes,0,len));socket.close();server.close();}}

GET/HTTP/1.1Host:localhost:8000Connection:keep-aliveUpgrade-Insecure-Requests:1User-Agent:Mozilla/5.0(WindowsNT10.0;WOW64)AppleWebKit/537.36(KHTML,likeGecko)Chrome/76.0.3809.132Safari/537.36Sec-Fetch-Mode:navigateSec-Fetch-User:?1Accept:text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3Sec-Fetch-Site:noneAccept-Encoding:gzip,deflate,brAccept-Language:zh-CN,zh;q=0.9Cookie:_ga=GA1.1.1778445080.1563089064;csrftoken=ZnWKg5ZuuSYd3dwts5iqnfjQvSnp21n9OiuFZAKz11WdGZuXENLhAxYckiLHFTsI

packagedemo.net.bs_demo;importjava.io.IOException;importjava.net.*;importjava.io.*;publicclassBrowserServer{publicstaticvoidmain(String[]args)throwsIOException{//创建一个服务器ServerSocket,和系统要指定的端口号ServerSocketserver=newServerSocket(8080);//使用accept方法获取到请求的客户端对象(浏览器)Socketsocket=server.accept();//使用Socket对象中的方法getInputStream,获取到网络字节输入流InputStream对象InputStreamis=socket.getInputStream();//使用网络字节输入流InputStream对象中的方法read读取客户端的请求信息/*byte[] bytes = new byte[1024];int len = 0;while((len = is.read(bytes))!=-1){System.out.println(new String(bytes,0,len));}*///把is网络字节输入流对象,转换为字符缓冲输入流，使用缓冲流更快BufferedReaderbr=newBufferedReader(newInputStreamReader(is));//把客户端请求信息的第一行读取出来 "GET /webDemo/index.html HTTP/1.1"Stringline=br.readLine();//System.out.println(line);//把读取的信息进行切割,只要中间部分 "/webDemo/index.html"String[]arr=line.split(" ");//把路径前边的/去掉,进行截取 "webDemo/index.html"Stringhtmlpath=arr[1].substring(1);//System.out.println(htmlpath);//创建一个本地字节输入流,构造方法中绑定要读取的html路径FileInputStreamfis=newFileInputStream(htmlpath);//使用Socket中的方法getOutputStream获取网络字节输出流OutputStream对象OutputStreamos=socket.getOutputStream();// 写入HTTP协议响应头,固定写法os.write("HTTP/1.1 200 OK\r\n".getBytes());os.write("Content-Type:text/html\r\n".getBytes());// 必须要写入空行,否则浏览器不解析os.write("\r\n".getBytes());//一读一写复制文件,把服务读取的html文件回写到客户端intlen=0;byte[]bytes=newbyte[1024];while((len=fis.read(bytes))!=-1){os.write(bytes,0,len);}//释放资源fis.close();socket.close();server.close();}}

发现浏览器中出现很多的叉子,说明浏览器没有读取到图片信息导致。
浏览器工作原理是遇到图片会开启一个线程进行单独的访问,因此在服务器端加入线程技术。

packagedemo.net.bs_demo;importjava.io.*;importjava.net.*;publicclassBrowserServerThread{publicstaticvoidmain(String[]args)throwsIOException{//创建一个服务器ServerSocket,和系统要指定的端口号ServerSocketserver=newServerSocket(8080);System.out.println("服务器启动 ...");/*浏览器解析服务器回写的html页面,页面中如果有图片,那么浏览器就会单独的开启一个线程,读取服务器的图片我们就的让服务器一直处于监听状态,客户端请求一次,服务器就回写一次*/while(true){//使用accept方法获取到请求的客户端对象(浏览器)Socketsocket=server.accept();newThread(newRunnable(){@Overridepublicvoidrun(){try{//使用Socket对象中的方法getInputStream,获取到网络字节输入流InputStream对象InputStreamis=socket.getInputStream();//使用网络字节输入流InputStream对象中的方法read读取客户端的请求信息/*byte[] bytes = new byte[1024];int len = 0;while((len = is.read(bytes))!=-1){System.out.println(new String(bytes,0,len));}*///把is网络字节输入流对象,转换为字符缓冲输入流，使用缓冲流更快BufferedReaderbr=newBufferedReader(newInputStreamReader(is));//把客户端请求信息的第一行读取出来 "GET /webDemo/index.html HTTP/1.1"Stringline=br.readLine();//System.out.println(line);//把读取的信息进行切割,只要中间部分 "/webDemo/index.html"String[]arr=line.split(" ");//把路径前边的/去掉,进行截取 "webDemo/index.html"Stringhtmlpath=arr[1].substring(1);//System.out.println(htmlpath);//创建一个本地字节输入流,构造方法中绑定要读取的html路径FileInputStreamfis=newFileInputStream(htmlpath);//使用Socket中的方法getOutputStream获取网络字节输出流OutputStream对象OutputStreamos=socket.getOutputStream();// 写入HTTP协议响应头,固定写法os.write("HTTP/1.1 200 OK\r\n".getBytes());os.write("Content-Type:text/html\r\n".getBytes());// 必须要写入空行,否则浏览器不解析os.write("\r\n".getBytes());//一读一写复制文件,把服务读取的html文件回写到客户端intlen=0;byte[]bytes=newbyte[1024];while((len=fis.read(bytes))!=-1){os.write(bytes,0,len);}//释放资源fis.close();socket.close();}catch(IOExceptione){e.printStackTrace();}}}).start();}//server.close();}}