JavaSocket应答与HTTP服务器的瓜葛-宜宾勤盛利枫建站

新闻中心

这里有您想知道的互联网营销解决方案

JavaSocket应答与HTTP服务器的瓜葛

Java Socket应答一直伴随着我们的编程生活，在不断的发展中有很多知识需要我们学习。下面我们就先来看看有关Java Socket应答的代码，有点长，但是看下去就会让你豁然开朗。

公司主营业务：网站建设、网站制作、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联推出吴堡免费做网站回馈大家。

HTTP/1.1表示这个HTTP服务器是1.1版，200是服务器对客户请求的应答状态码，OK是对应答状态码的解释，之后是这个文档的元信息和文档正文。(相关应答状态码和元信息的解释请参阅Inetrnet标准草案:RFC2616)。

 
 
 
  
  
  Http.java  
  
  
  import java.net.*;  
  
  
  import java.io.*;  
  
  
  import java.util.Properties;  
  
  
  import java.util.Enumeration;  
  
  
  public class Http {  
  
  
  protected Socket client;  
  
  
  protected BufferedOutputStream sender;  
  
  
  protected BufferedInputStream receiver;  
  
  
  protected ByteArrayInputStream byteStream;  
  
  
  protected URL target;  
  
  
  private int responseCode=-1;  
  
  
  private String responseMessage="";  
  
  
  private String serverVersion="";  
  
  
  private Properties header = new Properties();  
  
  
  public Http() { }  
  
  
  public Http(String url) {  
  
  
  GET(url) ;  
  
  
  }  
  
  
  /* GET方法根据URL，会请求文件、数据库查询结果、程序运行结果等多种内容 */  
  
  
  public void GET(String url) {  
  
  
  try {  
  
  
  checkHTTP(url);  
  
  
  openServer(target.getHost(),target.getPort() );  
  
  
  String cmd = "GET "+ getURLFormat(target) +" HTTP/1.0\r\n"  
  
  
  + getBaseHeads()+"\r\n";  
  
  
  sendMessage(cmd);  
  
  
  receiveMessage();  
  
  
  } catch(ProtocolException p) {  
  
  
  p.printStackTrace();  
  
  
  return;  
  
  
  } catch(UnknownHostException e) {  
  
  
  e.printStackTrace();  
  
  
  return;  
  
  
  } catch(IOException i) {  
  
  
  i.printStackTrace();  
  
  
  return;  
  
  
  }  
  
  
  }  
  
  
  /*  
  
  
  * HEAD方法只请求URL的元信息，不包括URL本身。若怀疑本机和服务器上的  
  
  
  * 文件相同，用这个方法检查最快捷有效。  
  
  
  */  
  
  
  public void HEAD(String url) {  
  
  
  try {  
  
  
  checkHTTP(url);  
  
  
  openServer(target.getHost(),target.getPort() );  
  
  
  String cmd = "HEAD "+getURLFormat(target)+" HTTP/1.0\r\n"  
  
  
  +getBaseHeads()+"\r\n";  
  
  
  sendMessage(cmd);  
  
  
  receiveMessage();  
  
  
  }catch(ProtocolException p) {  
  
  
  p.printStackTrace();  
  
  
  return;  
  
  
  }catch(UnknownHostException e) {  
  
  
  e.printStackTrace();  
  
  
  return;  
  
  
  }catch(IOException i) {  
  
  
  i.printStackTrace();  
  
  
  return;  
  
  
  }  
  
  
  }  
  
  
  /*  
  
  
  * POST方法是向服务器传送数据，以便服务器做出相应的处理。例如网页上常用的  
  
  
  * 提交表格。  
  
  
  */  
  
  
  public void POST(String url,String content) {  
  
  
  try {  
  
  
  checkHTTP(url);  
  
  
  openServer(target.getHost(),target.getPort() );  
  
  
  String cmd = "POST "+ getURLFormat(target) +"HTTP/1.0\r\n"+getBaseHeads();  
  
  
  cmd += "Content-type: application/x-www-form-urlencoded\r\n";  
  
  
  cmd += "Content-length: " + content.length() + "\r\n\r\n";  
  
  
  cmd += content+"\r\n";  
  
  
  sendMessage(cmd);  
  
  
  receiveMessage();  
  
  
  }catch(ProtocolException p) {  
  
  
  p.printStackTrace();  
  
  
  return;  
  
  
  }catch(UnknownHostException e) {  
  
  
  e.printStackTrace();  
  
  
  return;  
  
  
  }catch(IOException i) {  
  
  
  i.printStackTrace();  
  
  
  return;  
  
  
  }  
  
  
  }  
  
  
  protected void checkHTTP(String url) throws ProtocolException {  
  
  
  try {  
  
  
  URL target = new URL(url);  
  
  
  if(target==null || !target.getProtocol().toUpperCase().equals("HTTP") )  
  
  
  throw new ProtocolException("这不是HTTP协议");  
  
  
  this.target = target;  
  
  
  } catch(MalformedURLException m) {  
  
  
  throw new ProtocolException("协议格式错误");  
  
  
  }  
  
  
  }  
  
  
  /*  
  
  
  * 与Web服务器连接。若找不到Web服务器，InetAddress会引发UnknownHostException  
  
  
  * 异常。若Socket连接失败，会引发IOException异常。  
  
  
  */  
  
  
  protected void openServer(String host,int port) throws  
  
  
  UnknownHostException,IOException {  
  
  
  header.clear();  
  
  
  responseMessage=""; responseCode=-1;  
  
  
  try {  
  
  
  if(client!=null) closeServer();  
  
  
  if(byteStream != null) {  
  
  
  byteStream.close(); byteStream=null;  
  
  
  }  
  
  
  InetAddress address = InetAddress.getByName(host);  
  
  
  client = new Socket(address,port==-1?80:port);  
  
  
  sender = new BufferedOutputStream(client.getOutputStream());  
  
  
  receiver = new BufferedInputStream(client.getInputStream());  
  
  
  }catch(UnknownHostException u) {  
  
  
  throw u;  
  
  
  }catch(IOException i) {  
  
  
  throw i;  
  
  
  }  
  
  
  }  
  
  
  /* 关闭与Web服务器的连接 */  
  
  
  protected void closeServer() throws IOException {  
  
  
  if(client==null) return;  
  
  
  try {  
  
  
  client.close(); sender.close(); receiver.close();  
  
  
  } catch(IOException i) {  
  
  
  throw i;  
  
  
  }  
  
  
  client=null; sender=null; receiver=null;  
  
  
  }  
  
  
  protected String getURLFormat(URL target) {  
  
  
  String spec = "http://  
  
  
  +target.getHost();  
  
  
  if(target.getPort()!=-1)  
  
  
  spec+=":"+target.getPort();  
  
  
  return spec+=target.getFile();  
  
  
  }  
  
  
  /* 向Web服务器传送数据 */  
  
  
  protected void sendMessage(String data) throws IOException{  
  
  
  sender.write(data.getBytes(),0,data.length());  
  
  
  sender.flush();  
  
  
  }  
  
  
  /* 接收来自Web服务器的数据 */  
  
  
  protected void receiveMessage() throws IOException{  
  
  
  byte data[] = new byte[1024];  
  
  
  int count=0;  
  
  
  int word=-1;  
  
  
  // 解析***行  
  
  
  while( (word=receiver.read())!=-1 ) {  
  
  
  if(word=='\r'||word=='\n') {  
  
  
  word=receiver.read();  
  
  
  if(word=='\n') word=receiver.read();  
  
  
  break;  
  
  
  }  
  
  
  if(count == data.length) data = addCapacity(data);  
  
  
  data[count++]=(byte)word;  
  
  
  }  
  
  
  String message = new String(data,0,count);  
  
  
  int mark = message.indexOf(32);  
  
  
  serverVersion = message.substring(0,mark);  
  
  
  while( mark
  
  
  
responseCode = Integer.parseInt(message.substring(mark+1,mark+=4));  
  
  
  responseMessage = message.substring(mark,message.length()).trim();  
  
  
  // 应答状态码和处理请读者添加  
  
  
  switch(responseCode) {  
  
  
  case 400:  
  
  
  throw new IOException("错误请求");  
  
  
  case 404:  
  
  
  throw new FileNotFoundException( getURLFormat(target) );  
  
  
  case 503:  
  
  
  throw new IOException("服务器不可用" );  
  
  
  }  
  
  
  if(word==-1) throw new ProtocolException("信息接收异常终止");  
  
  
  int symbol=-1;  
  
  
  count=0;  
  
  
  // 解析元信息  
  
  
  while( word!='\r' && word!='\n' && word>-1) {  
  
  
  if(word=='\t') word=32;  
  
  
  if(count==data.length) data = addCapacity(data);  
  
  
  data[count++] = (byte)word;  
  
  
  parseLine: {  
  
  
  while( (symbol=receiver.read()) >-1 ) {  
  
  
  switch(symbol) {  
  
  
  case '\t':  
  
  
  symbol=32; break;  
  
  
  case '\r':  
  
  
  case '\n':  
  
  
  word = receiver.read();  
  
  
  if( symbol=='\r' && word=='\n') {  
  
  
  word=receiver.read();  
  
  
  if(word=='\r') word=receiver.read();  
  
  
  }  
  
  
  if( word=='\r' || word=='\n' || word>32) break parseLine;  
  
  
  symbol=32; break;  
  
  
  }  
  
  
  if(count==data.length) data = addCapacity(data);  
  
  
  data[count++] = (byte)symbol;  
  
  
  }  
  
  
  word=-1;  
  
  
  }  
  
  
  message = new String(data,0,count);  
  
  
  mark = message.indexOf(':');  
  
  
  String key = null;  
  
  
  if(mark>0) key = message.substring(0,mark);  
  
  
  mark++;  
  
  
  while( mark
  
  
  
String value = message.substring(mark,message.length() );  
  
  
  header.put(key,value);  
  
  
  count=0;  
  
  
  }  
  
  
  // 获得正文数据  
  
  
  while( (word=receiver.read())!=-1) {  
  
  
  if(count == data.length) data = addCapacity(data);  
  
  
  data[count++] = (byte)word;  
  
  
  }  
  
  
  if(count>0) byteStream = new ByteArrayInputStream(data,0,count);  
  
  
  data=null;  
  
  
  closeServer();  
  
  
  }  
  
  
  public String getResponseMessage() {  
  
  
  return responseMessage;  
  
  
  }  
  
  
  public int getResponseCode() {  
  
  
  return responseCode;  
  
  
  }  
  
  
  public String getServerVersion() {  
  
  
  return serverVersion;  
  
  
  }  
  
  
  public InputStream getInputStream() {  
  
  
  return byteStream;  
  
  
  }  
  
  
  public synchronized String getHeaderKey(int i) {  
  
  
  if(i>=header.size()) return null;  
  
  
  Enumeration enum = header.propertyNames();  
  
  
  String key = null;  
  
  
  for(int j=0; j<=i; j++)  
  
  
  key = (String)enum.nextElement();  
  
  
  return key;  
  
  
  }  
  
  
  public synchronized String getHeaderValue(int i) {  
  
  
  if(i>=header.size()) return null;  
  
  
  return header.getProperty(getHeaderKey(i));  
  
  
  }  
  
  
  public synchronized String getHeaderValue(String key) {  
  
  
  return header.getProperty(key);  
  
  
  }  
  
  
  protected String getBaseHeads() {  
  
  
  String inf = "User-Agent: myselfHttp/1.0\r\n"+  
  
  
  "Accept: www/source; text/html; image/gif; */*\r\n";  
  
  
  return inf;  
  
  
  }  
  
  
  private byte[] addCapacity(byte rece[]){  
  
  
  byte temp[] = new byte[rece.length+1024];  
  
  
  System.arraycopy(rece,0,temp,0,rece.length);  
  
  
  return temp;  
  
  
  }  
  
  
  public static void main(String[] args) {  
  
  
  Http http=new Http();  
  
  
  //http.GET("http://192.168.1.5  
  
  
  );  
  
  
  int i;  
  
  
  for (i=0; i<50000; i++) {  
  
  
  http.GET("http://www.model-dl.com/modelinfo.asp?modelid=101 );  
  
  
  http.POST("http://www.model-dl.com/modelinfo.asp?modelid=101,"ratecontd=101&MM_insert=form1 ");  
  
  
  }  
  
  
  }  
  
  
  }

以上就是对Java Socket应答的相关介绍，希望大家有所发现。

网页名称：JavaSocket应答与HTTP服务器的瓜葛
浏览路径：http://aqpgk.com/article/djgeepj.html

新闻中心

其他资讯