Java网络编程之简单Socket和ServerSocket

package com.client;

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

public class FirstClient {
public static void main(String[] args) {
// TODO Auto-generated method stub
   Socket client= null;
try{
     client= new Socket( "localhost",6666);
     InputStream in=client.getInputStream();

     OutputStream outs=client.getOutputStream();
     BufferedOutputStream buffs= new BufferedOutputStream(outs);
     Writer out= new OutputStreamWriter(buffs);
     out.write( "hello===");
//out.flush();
     out.close();
//一定要关闭输出流,否则它会一直占用该端口以及资源
   } catch(UnknownHostException e)
   {
     e.printStackTrace();
   } catch(IOException e)
   {
     e.printStackTrace();
   }
 }
}

package com.server;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class FirstServer {
public static void main(String[] args) {
// TODO Auto-generated method stub

try {
     ServerSocket server =  new ServerSocket(6666);
while ( true) {
       Socket client =  null;
try {
         client = server.accept();

         InputStream ins = client.getInputStream();
         BufferedReader read =  new BufferedReader(
new InputStreamReader(ins));
         String res = read.readLine();
         read.close();
         System.out.println( "client request:" + res);
       }  catch (IOException e) {
         e.printStackTrace();
       }  finally {
try {
if (client !=  null)
             client.close();
         }  catch (IOException e) {
           e.printStackTrace();
         }
       }
     }
   }  catch (IOException e) {
     e.printStackTrace();
   }
 }
}

   Socket socket= null;
   BufferedReader netwin= null; //一般在网络中不用这种方式，仅仅一般测试用
try{
     socket= new Socket( "localhost",2222);

     String header= "HTTP/1.0 200 OK\r\n"+
"Server:Apache 7.0\r\n"+
"Content-length:"+107+ "\r\n"+
"Content-type: text/html\r\n\r\n";


//输出流
     OutputStream outfile= new BufferedOutputStream(socket.getOutputStream());
     Writer write= new OutputStreamWriter(outfile);
//输入流
     InputStream inputstream=socket.getInputStream();
     BufferedInputStream in= new BufferedInputStream(inputstream);
     InputStreamReader inr= new InputStreamReader(in);


//对于http请求的需要先判断是否是http协议
//判断请求是否是http协议主要就是处理输入流中的第一行
//第一种处理解析请求头部
     StringBuffer request1= new StringBuffer(100);
while( true)
     {
int c=in.read();
if(c=='\r' || c=='\n' || c==-1)
break;
       request1.append(( char)c);
     }
     String requestHeader1=request1.toString();
if(requestHeader1.indexOf( "HTTP/")!=-1)
       write.write(header);
     write.flush();
     write.close();


//第二种处理解析请求头部
     StringBuffer request2= new StringBuffer(100);
while( true)
     {
int c=in.read();
if(c=='\r' || c=='\n' || c==-1)
break;
       request2.append(( char)c);
     }
//截取第一行每一部分
//一般http请求格式GET /index.html HTTP/1.0
     String requestHeader2=request2.toString();
int firstSpace=requestHeader2.indexOf(' ');
int secondSpace=requestHeader2.indexOf(' ', firstSpace+1);
     String fileName=requestHeader2.substring(firstSpace+1,secondSpace);
if(requestHeader1.indexOf( "HTTP/")!=-1)
     {
       write.write(header);
       write.flush();
       write.close();
     }


//第三种处理解析请求头部
     StringBuffer request3= new StringBuffer(100);
while( true)
     {
int c=in.read();
if(c=='\r' || c=='\n' || c==-1)
break;
       request3.append(( char)c);
     }
//截取第一行每一部分
//一般http请求格式GET /index.html HTTP/1.0
     String requestHeader3=request3.toString();
//使用默认分隔符，包括空白字符，制表符，换行符，回车符，换页符
     StringTokenizer st= new StringTokenizer(requestHeader3);
     String method=st.nextToken();
     String version="";
     String filename=st.nextToken();
     String httpT="";
if(st.hasMoreTokens())
       httpT=st.nextToken();
if(httpT.indexOf( "HTTP/")!=-1)
     {
       write.write(header);
       write.flush();
       write.close();
     }

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

       socket= new Socket( "localhost",2222);
       OutputStream outs=socket.getOutputStream();
//利用缓冲来
       BufferedOutputStream buffer= new BufferedOutputStream(outs);
       writer= new OutputStreamWriter(buffer); 

//在写入的过程中每一行必须要以\r\n结束
       writer.write( "hello");

//这里是一般请求则，只需要加上\r\n即可
       writer.write( "\r\n");
//当是http请求的时候需要这样处理,请求最后加上\r\n
//writer.write("GET /index.html http/1.0 ")
//writer.write("\r\n\r\n")
       writer.flush();
       writer.close();

//这里写入的只是一些小型文件的处理
     InputStream in= new FileInputStream( "f:\\t.txt");
     ByteArrayOutputStream out= new ByteArrayOutputStream();
int b;
while((b=in.read())!=-1)out.write(b);
byte[] data=out.toByteArray();

//下面的是读取大文件处理的方式
//      File file=new File("f:\\t.txt");
//      DataInputStream fis=new DataInputStream(
//          new BufferedInputStream(new FileInputStream(file)));
//      //存放数据
//      byte[] data=new byte[(int)file.length()];
//      fis.readFully(data);//将文件读入到字节数组中
//      fis.close();//直接在输出流中加入该data


//编写MIME首部的格式
     String header= "HTTP/1.0 200 OK\r\n"+
"Server:Apache 7.0\r\n"+
"Content-length:"+data.length+ "\r\n"+
"Content-type: text/html\r\n\r\n";

//开始写入输出流
     socket= new Socket( "localhost",2222);
//利用缓冲来
     OutputStream outfile= new BufferedOutputStream(socket.getOutputStream());
     Writer write= new OutputStreamWriter(outfile);
//这里一般要先判断是否是http协议，
//if(request.indexof("HTTP")!=-1)
//write.write(header);
     write.flush();
     write.close();

//发送文件一般直接用输出流，不要用书写器
     outfile.write(data);
     outfile.flush();
     outfile.close();

//当文件不存在的时候
//这里还是要判断是否是http协议，如果是先要添加MIME首部
       write.write( "HTTP/1.0 404 File Not Found\r\n");
       write.write( "Server:Apache 7.0\r\n");
       write.write( "Content-type:text/html");
       write.write( "\r\n\r\n");

//当不是http协议还要输出显示
       write.write( "<HTML>\r\n");
       write.write( "<HEAD><TITLE>File Not Found</TITLE></HEAD>\r\n");
       write.write( "<BODY>HTTP ERROR 404 :File Not Found\r\n");
       write.write( "</BODY></HTML>\r\n");
       write.flush();
       write.close();

本文转自 zhao_xiao_long 51CTO博客，原文链接:http://blog.51cto.com/computerdragon/1192073