作者:yarshray


出于多種目的要寫這篇文章,簡單的說是因為最近的工作和Java 的Socket相關(guān).所以工作之余就有了寫點東西的想法.同樣我不希望把文章寫的太復雜,因此淺出自己的一點心得.
事實上網(wǎng)絡(luò)編程簡單的理解就是兩臺計算機相互通訊數(shù)據(jù)而已.對于程序員而言,去掌握一種編程接口并使用一種編程模型相對就會顯得簡單的多了.Java SDK提供一些相對簡單的Api來完成這些工作.Socket就是其中之一.對于Java而言.這些Api存在與java.net 這個包里面.因此只要導入這個包就可以準備網(wǎng)絡(luò)編程了.
網(wǎng)絡(luò)編程的基本模型就是客戶機到服務(wù)器模型.簡單的說就是兩個進程之間相互通訊,然后其中一個必須提供一個固定的位置,而另一個則只需要知道這個固定的位置.并去建立兩者之間的聯(lián)系..然后完成數(shù)據(jù)的通訊就可以了.這里提供固定位置的通常稱為服務(wù)器,而建立聯(lián)系的通常叫做客戶端.基于這個簡單的模型,就可以進入網(wǎng)絡(luò)編程啦.
Java對這個模型的支持有很多種Api.而這里我只想介紹有關(guān)Socket的編程接口.對于Java而言已經(jīng)簡化了Socket的編程接口.首先我們來討論有關(guān)提供固定位置的服務(wù)方是如何建立的.Java提供了ServerSocket來對其進行支持.事實上當你創(chuàng)建該類的一個實力對象并提供一個端口資源你就建立了一個固定位置可以讓其他計算機來訪問你.ServerSocket server=new  ServerSocket(6789);這里稍微要注意的是端口的分配必須是唯一的.因為端口是為了唯一標識每臺計算機唯一服務(wù)的.另外端口號是從0~65535之間的,前1024個端口已經(jīng)被Tcp/Ip 作為保留端口,因此你所分配的端口只能是1024個之后的.好了.我們有了固定位置.現(xiàn)在所需要的就是一根連接線了.該連接線由客戶方首先提出要求.因此Java同樣提供了一個Socket對象來對其進行支持.只要客戶方創(chuàng)建一個Socket的實例對象進行支持就可以了.Socket client
=new Socket(InetAddress.getLocalHost(),5678);客戶機必須知道有關(guān)服務(wù)器的IP地址.對于著一點Java也提供了一個相關(guān)的類InetAddress 該對象的實例必須通過它的靜態(tài)方法來提供.它的靜態(tài)方法主要提供了得到本機IP 和通過名字或IP直接得到InetAddress的方法.
好了.上面的方法基本可以建立一條連線讓兩臺計算機相互交流了.可是數(shù)據(jù)是如何傳輸?shù)哪?事實上I/O操作總是和網(wǎng)絡(luò)編程息息相關(guān)的.因為底層的網(wǎng)絡(luò)是繼續(xù)數(shù)據(jù)的.除非遠程調(diào)用,處理問題的核心在執(zhí)行上.否則數(shù)據(jù)的交互還是依賴于I\O操作的.所以你也必須導入java.io這個包.java的IO操作也不復雜.它提供了針對于字節(jié)流和Unicode的讀者和寫者,然后也提供了一個緩沖用于數(shù)據(jù)的讀寫.
  BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));
  PrintWriter out=new PrintWriter(server.getOutputStream());

上面兩句就是建立緩沖并把原始的字節(jié)流轉(zhuǎn)變?yōu)閁nicode可以操作.而原始的字節(jié)流來源于Socket的兩個方法.getInputStream()和getOutputStream()方.分別用來得到輸入和輸出.那么現(xiàn)在有了基本的模型和基本的操作工具.我們可以做一個簡單的Socket例程了.
服務(wù)方:
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();
}
}

這個程序的主要目的在于服務(wù)器不斷接收客戶機所寫入的信息只到.客戶機發(fā)送"End"字符串就退出程序.并且服務(wù)器也會做出"Receive"為回應(yīng).告知客戶機已接收到消息.

客戶機代碼:
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"用來做退出標識.

這個程序只是簡單的兩臺計算機之間的通訊.如果是多個客戶同時訪問一個服務(wù)器呢?你可以試著再運行一個客戶端,結(jié)果是會拋出異常的.那么多個客戶端如何實現(xiàn)呢?

其實,簡單的分析一下,就可以看出客戶和服務(wù)通訊的主要通道就是Socket本身.而服務(wù)器通過accept方法就是同意和客戶建立通訊.這樣當客戶建立Socket的同時.服務(wù)器也會使用這一根連線來先后通訊.那么既然如此只要我們存在多條連線就可以了.那么我們的程序可以變?yōu)槿缦?

服務(wù)器:

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循環(huán).這個循環(huán)的目的就是當一個客戶進來就為它分配一個Socket直到這個客戶完成一次和服務(wù)器的交互,這里也就是接受到客戶的"End"消息.那么現(xiàn)在就實現(xiàn)了多客戶之間的交互了.但是.問題又來了.這樣做雖然解決了多客戶,可是是排隊執(zhí)行的.也就是說當一個客戶和服務(wù)器完成一次通訊之后下一個客戶才可以進來和服務(wù)器交互.無法做到同時服務(wù).那么要如何才能同時達到既能相互之間交流又能同時交流呢?很顯然這是一個并行執(zhí)行的問題了.所以線程是最好的解決方案.
那么下面的問題是如何使用線程.首先要做的事情是創(chuàng)建線程并使得其可以和網(wǎng)絡(luò)連線取得聯(lián)系.然后由線程來執(zhí)行剛才的操作.要創(chuàng)建線程要么直接繼承Thread要么實現(xiàn)Runnable接口,要建立和Socket的聯(lián)系只要傳遞引用就可以了.而要執(zhí)行線程就必須重寫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 can't 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類繼承了下來.并且通過構(gòu)造函數(shù)傳遞引用和客戶Socket建立了聯(lián)系.這樣每個線程就有了.一個通訊管道.同樣我們可以填寫run方法.把之前的操作交給線程來完成.這樣多客戶并行的Socket就建立起來了.

我的文章寫完了.雖然我的文章到這里就結(jié)束了.可是要和Java的Socket相關(guān)的操作還有很多.各位大俠繼續(xù)努力吧....