Java Socket網絡編程初級入門 – JAVA編程語言程序開發技術文章

 事實上網絡編程簡單的理解就是兩臺計算機相互通訊數據而已,對於程序員而言,去掌握一種編程接口並使用一種編程模型相對就會顯得簡單的多瞭,Java SDK提供一些相對簡單的Api來完成這些工作。Socket就是其中之一,對於Java而言,這些Api存在與java.net 這個包裡面,因此隻要導入這個包就可以準備網絡編程瞭。

  網絡編程的基本模型就是客戶機到服務器模型,簡單的說就是兩個進程之間相互通訊,然後其中一個必須提供一個固定的位置,而另一個則隻需要知道這個固定的位置。並去建立兩者之間的聯系,然後完成數據的通訊就可以瞭,這裡提供固定位置的通常稱為服務器,而建立聯系的通常叫做客戶端,基於這個簡單的模型,就可以進入網絡編程啦。

  Java對這個模型的支持有很多種Api,而這裡我隻想介紹有關Socket的編程接口,對於Java而言已經簡化瞭Socket的編程接口。首先我們來討論有關提供固定位置的服務方是如何建立的。Java提供瞭ServerSocket來對其進行支持.事實上當你創建該類的一個實力對象並提供一個端口資源你就建立瞭一個固定位置可以讓其他計算機來訪問你,ServerSocket server=new ServerSocket(6789);這裡稍微要註意的是端口的分配必須是唯一的。因為端口是為瞭唯一標識每臺計算機唯一服務的,另外端口號是從0~65535之間的,前1024個端口已經被Tcp/Ip 作為保留端口,因此你所分配的端口隻能是1024個之後的。好瞭,我們有瞭固定位置.現在所需要的就是一根連接線瞭.該連接線由客戶方首先提出要求。因此Java同樣提供瞭一個Socket對象來對其進行支持,隻要客戶方創建一個Socket的實例對象進行支持就可以瞭。Socket client
=new Socket(InetAddress.getLocalHost(),5678);客戶機必須知道有關服務器的IP地址,對於著一點Java也提供瞭一個相關的類InetAddress 該對象的實例必須通過它的靜態方法來提供,它的靜態方法主要提供瞭得到本機IP 和通過名字或IP直接得到InetAddress的方法。

  上面的方法基本可以建立一條連線讓兩臺計算機相互交流瞭,可是數據是如何傳輸的呢?事實上I/O操作總是和網絡編程息息相關的。因為底層的網絡是繼續數據的,除非遠程調用,處理問題的核心在執行上,否則數據的交互還是依賴於IO操作的,所以你也必須導入java.io這個包.java的IO操作也不復雜,它提供瞭針對於字節流和Unicode的讀者和寫者,然後也提供瞭一個緩沖用於數據的讀寫。

BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));
PrintWriter out=new PrintWriter(server.getOutputStream());

  上面兩句就是建立緩沖並把原始的字節流轉變為Unicode可以操作,而原始的字節流來源於Socket的兩個方法,getInputStream()和getOutputStream()方,分別用來得到輸入和輸出,那麼現在有瞭基本的模型和基本的操作工具,我們可以做一個簡單的Socket例程瞭.

  服務方:

import java.io.*;
import java.net.*;
public class MyServer {
 public static void main(String[] args) throws IOException{
  ServerSocket server=new ServerSocket(5678);
  Socket client=server.accept();
  BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream()));
  PrintWriter out=new PrintWriter(client.getOutputStream());
  while(true){
   String str=in.readLine();
   System.out.println(str);
   out.println(“has receive….”);
   out.flush();
   if(str.equals(“end”))
    break;
  }
  client.close();
 }
}

  這個程序的主要目的在於服務器不斷接收客戶機所寫入的信息隻到,客戶機發送”End”字符串就退出程序,並且服務器也會做出”Receive”為回應,告知客戶機已接收到消息。

  客戶機代碼:

import java.net.*;
import java.io.*;

public class Client{
 static Socket server;

 public static void main(String[] args)throws Exception{
  server=new Socket(InetAddress.getLocalHost(),5678);
  BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));
  PrintWriter out=new PrintWriter(server.getOutputStream());
  BufferedReader wt=new BufferedReader(new InputStreamReader(System.in));

  while(true){
   String str=wt.readLine();
   out.println(str);
   out.flush();
   if(str.equals(“end”)){
    break;
   }
   System.out.println(in.readLine());
  }
  server.close();
 }
}

  客戶機代碼則是接受客戶鍵盤輸入,並把該信息輸出,然後輸出”End”用來做退出標識。

  這個程序隻是簡單的兩臺計算機之間的通訊,如果是多個客戶同時訪問一個服務器呢?你可以試著再運行一個客戶端,結果是會拋出異常的。那麼多個客戶端如何實現呢?

  其實,簡單的分析一下,就可以看出客戶和服務通訊的主要通道就是Socket本身,而服務器通過accept方法就是同意和客戶建立通訊.這樣當客戶建立Socket的同時。服務器也會使用這一根連線來先後通訊,那麼既然如此隻要我們存在多條連線就可以瞭。那麼我們的程序可以變為如下:

  服務器:

import java.io.*;
import java.net.*;

public class MyServer {
 public static void main(String[] args) throws IOException{
  ServerSocket server=new ServerSocket(5678);
  while(true){
   Socket client=server.accept();
   BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream()));
   PrintWriter out=new PrintWriter(client.getOutputStream());
   while(true){
    String str=in.readLine();
    System.out.println(str);
    out.println(“has receive….”);
    out.flush();
    if(str.equals(“end”))
     break;
   }
   client.close();
  }
 }
}

  這裡僅僅隻是加瞭一個外層的While循環,這個循環的目的就是當一個客戶進來就為它分配一個Socket直到這個客戶完成一次和服務器的交互,這裡也就是接受到客戶的”End”消息.那麼現在就實現瞭多客戶之間的交互瞭。但是.問題又來瞭,這樣做雖然解決瞭多客戶,可是是排隊執行的。也就是說當一個客戶和服務器完成一次通訊之後下一個客戶才可以進來和服務器交互,無法做到同時服務,那麼要如何才能同時達到既能相互之間交流又能同時交流呢?很顯然這是一個並行執行的問題瞭。所以線程是最好的解決方案。

  那麼下面的問題是如何使用線程.首先要做的事情是創建線程並使得其可以和網絡連線取得聯系。然後由線程來執行剛才的操作,要創建線程要麼直接繼承Thread要麼實現Runnable接口,要建立和Socket的聯系隻要傳遞引用就可以瞭.而要執行線程就必須重寫run方法,而run方法所做的事情就是剛才單線程版本main所做的事情,因此我們的程序變成瞭這樣:

import java.net.*;
import java.io.*;

public class MultiUser extends Thread{
 private Socket client;

 public MultiUser(Socket c){
  this.client=c;
 }

 public void run(){
  try{
   BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream()));
   PrintWriter out=new PrintWriter(client.getOutputStream());
   //Mutil User but cant parallel
   while(true){
    String str=in.readLine();
    System.out.println(str);
    out.println(“has receive….”);
    out.flush();
    if(str.equals(“end”))
     break;
   }
   client.close();
  }catch(IOException ex){
  }finally{
 }
}

public static void main(String[] args)throws IOException{
 ServerSocket server=new ServerSocket(5678);
 while(true){
  //transfer location change Single User or Multi User
  MultiUser mu=new MultiUser(server.accept());
  mu.start();
 }
}
}

  我的類直接從Thread類繼承瞭下來.並且通過構造函數傳遞引用和客戶Socket建立瞭聯系,這樣每個線程就有瞭。一個通訊管道.同樣我們可以填寫run方法,把之前的操作交給線程來完成,這樣多客戶並行的Socket就建立起來瞭。

發佈留言

發佈留言必須填寫的電子郵件地址不會公開。