java怎么實現socket連接方法封裝

這篇文章主要介紹了java怎么實現socket連接方法封裝，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

Java實現socket連接技巧

Socket通信幾乎無時不在，當然能夠搜集到的信息也大量存在, 為了避免重復的勞作， 抽取了關于客戶端和服務端的Socket， 并將其應用到適合JVM(LInux/Windows)或者DVM(Android)平臺。

這個封裝好的API具有以下優勢：

1.滿足具有Socket客戶端需求的基本應用。

2.滿足具有Socket服務端的基本應用。具備并發能力, 能滿足可設定個數客戶端連接。

本文的目的就是為了對Socket做一個封裝， 方便客戶端和服務端能直接使用Socket.封裝好的API可以從下面獲取

Java Socket的封裝

其中src/中的是API源碼; usage/目錄是使用例程

1 客戶端Socket API要點

1）客戶端和指定的服務端相連, 因此客戶端需要指明服務端對應的IP地址和端口號

2）需要設置超時返回

3）需要設置循環等待, 因為基本的Socket通信都是一來一回, 這種來回是通過阻塞來完成的。

4）每個客戶端連入服務端的時候, 都具備本身的ID, 類似于HTTP的Session, 這點容易被忽視。在多客戶端連接中, 可以重點關注。本文提供的代碼也有所提及, 但沒有深入, 這點留給讀者進一步發掘。

代碼參照/usage目錄下的客戶端測試代碼, 注意, 先啟動服務端,或者你拿著NetAssis 來測試也不錯.

2 服務端Socket API要點

1）服務端一般是被多個客戶端連接的, 并且這些連接要求服務端做相似的處理, 因此這里就將這些相似處理, 抽象成一個SingleTask.java 接口, 具體的業務只需要實現這樣的接口, 就可以并行的處理這些Task.

2）不能無限制的讓客戶端連入Server, 因此需要設置上限值

3）啟動線程池, 每個線程針對一個具體的客戶端連接

4）注意接收阻塞位置, 需要設置死循環, 讀不到數據將死守著等待(但別耽誤其它線程處理事情)

5）注意服務端要在死循環中偵聽, 這樣保證不錯過任何來自客戶端的請求。

代碼參照:/usage目錄下的Server端測試代碼。

代碼中注釋很多，因此這里就不詳細述說。

常見問題

1、客戶端Client的時候, 如果存在網絡問題, 為了避免網絡問題，造成客戶端長時間等待, 此時要設置一個TimeOut

clientSocket = new Socket(); 
//這個TimeOut是連接等待時間
clientSocket.connect(tcpAddress, timeOut);

2、當客戶端已經連接, 每次收到一個數據, 客戶端將啟動處理, 假如服務器長久不發數據， 此時客戶端會阻塞等待, 為了避免這個時候的等待, 可以設置一個超時

clientSocket.setSoTimeout(timeOut);

Java使用socket實現一個多線程web服務器的方法

除了服務器類，還包括請求類和響應類

請求類：獲取客戶的HTTP請求，分析客戶所需要的文件響應類：獲得用戶請求后將用戶需要的文件讀出，添加上HTTP應答頭。發送給客戶端。

服務器處理類

package com.lp.app.webserver;
import java.io.*;
import java.net.*;
//使用Socket創建一個WEB服務器，本程序是多線程系統以提高反應速度。
class WebServer
{ 
public static String WEBROOT = "";//默認目錄
 public static String defaultPage = "index.htm";//默認文件
 public static void main (String [] args) throws IOException
 {
 System.out.println ("服務器啟動...\n");
  //使用8080端口提供服務
 ServerSocket server = new ServerSocket (8080);
 while (true)
 {
  //阻塞，直到有客戶連接
  Socket sk = server.accept ();
  System.out.println ("Accepting Connection...\n");
  //啟動服務線程
  new WebThread (sk).start ();
 }
 }
}
//使用線程，為多個客戶端服務
class WebThread extends Thread
{
 private Socket sk;
 WebThread (Socket sk)
 {
  this.sk = sk;
 }
 //線程體
 public void run ()
 {
  InputStream in = null;
  OutputStream out = null;
  try{
  in = sk.getInputStream();
  out = sk.getOutputStream();
  //接收來自客戶端的請求。
  Request rq = new Request(in);
  //解析客戶請求
  String sURL = rq.parse();
  System.out.println("sURL="+sURL);
  if(sURL.equals("/"))
    sURL = WebServer.defaultPage;
  Response rp = new Response(out);
  rp.Send(sURL);
   }
  catch (IOException e)
  {
  System.out.println (e.toString ());
  }
  finally
  {
  System.out.println ("關閉連接...\n");
  //最后釋放資源
  try{
   if (in != null)
   in.close ();
   if (out != null)
   out.close ();
   if (sk != null)
   sk.close ();
  }
  catch (IOException e)
  {
  }
  }
 }
}

請求類

package com.lp.app.webserver;
import java.io.*;
import java.net.*;
//獲取客戶的HTTP請求，分析客戶所需要的文件
public class Request{
 InputStream in = null;
 //獲得輸入流。這是客戶的請求數據。
 public Request(InputStream input){
 this.in = input;
 }
 //解析客戶的請求
 public String parse() {
 //從Socket讀取一組數據
 StringBuffer requestStr = new StringBuffer(2048);
 int i;
 byte[] buffer = new byte[2048];
 try {
 i = in.read(buffer);
 }
 catch (IOException e) {
 e.printStackTrace();
 i = -1;
 }
 for (int j=0; j<i; j++) {
 requestStr.append((char) buffer[j]);
 }
 System.out.print(requestStr.toString());
 return getUri(requestStr.toString());
 }
 //獲取URI信息字符
 private String getUri(String requestString) {
 int index1, index2;
 index1 = requestString.indexOf(' ');
 if (index1 != -1) {
 index2 = requestString.indexOf(' ', index1 + 1);
 if (index2 > index1)
  return requestString.substring(index1 + 1, index2);
 }
 return null;
 }
}

響應類

package com.lp.app.webserver;
import java.io.*;
import java.net.*;
//獲得用戶請求后將用戶需要的文件讀出，添加上HTTP應答頭。發送給客戶端。
public class Response{
 OutputStream out = null;
 //發送請求的文件 public void Send(String ref) throws IOException {
 byte[] bytes = new byte[2048];
 FileInputStream fis = null;
 try {
 //構造文件
 File file = new File(WebServer.WEBROOT, ref);
 if (file.exists()) {
  //構造輸入文件流
  fis = new FileInputStream(file);
  int ch = fis.read(bytes, 0, 2048);
  //讀取文件
  String sBody = new String(bytes,0);
  //構造輸出信息
  String sendMessage = "HTTP/1.1 200 OK\r\n" +
  "Content-Type: text/html\r\n" +
  "Content-Length: "+ch+"\r\n" +
  "\r\n" +sBody;
  //輸出文件
  out.write(sendMessage.getBytes());
 }else {
  // 找不到文件
  String errorMessage = "HTTP/1.1 404 File Not Found\r\n" +
  "Content-Type: text/html\r\n" +
  "Content-Length: 23\r\n" +
  "\r\n" +
  "<h2>File Not Found</h2>";
  out.write(errorMessage.getBytes());
 }
 }
 catch (Exception e) {
 // 如不能實例化File對象，拋出異常。
 System.out.println(e.toString() );
 }
 finally {
 if (fis != null)
  fis.close();
 }
 }
 //獲取輸出流
 public Response(OutputStream output) {
 this.out = output;
}
}

感謝你能夠認真閱讀完這篇文章，希望小編分享的“java怎么實現socket連接方法封裝”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!