用java實現socket C/S通信很簡單，很多教科書上都有。但是這些通信模型大都是阻塞式的，其弊端也很明顯：一方必須要接收的到對方的消息后，才能編輯自己的消息發出。同樣對方也要一直等待這條消息收到后才能發送新的消息。用網絡通信的知識講，大概就是半雙工通信吧。這就好比聊天的時候，兩個人只能一人一句的聊天。不能一個人連着發送多句話。
而要實現非阻塞通信呢，也就是實現全雙工通信。我不想使用java的NIO包。因為那樣有點小題大做了。其實只要使用多線程就能實現了。
Socket和ServerSocket
這個就不多說了，默認大家都懂了。顧名思義，ServerSocket是服務器（S）端使用的。Socket是客戶端（C）使用的。也就是所謂的C/S。
ServerSocket的構造方法要指定程序使用的端口（Port）。從網絡通信的角度來看，要通信的話，必須要指定一個端口，因為在應用層中的程序太多了。這樣才能把數據發送給對應的應用程序。端口號的值要小於65535，並且大於1023。而客戶端除了要指定端口以外還要指定服務器的IP地址。在本機上測試的話可以使用“回環地址(localhost)”127.0.0.1。
//服務端：
ServerSocket ss = new ServerSocket(5432);
//客戶端：
Socket s = new Socket("127.0.0.1",5432);
————————————————————————————————————————————
端口號要小於65535的原因是，通信過程都是通過IP數據報完成的。IP數據報的報頭中包含一個16位字段用來指定端口號。而2的16次方就是65536。所以其范圍應該是0~65535
端口號之所以要大於1023是因為小於1023的都是知名端口號，也就是已經確定了某些特殊用途的端口號。比如，FTP服務器的TCP端口號是21，Telnet是23，Http的端口是80。
————————————————————————————————————————————
但是要實現通信雙方都必須通過Socket來通信。服務端可以通過ServerSocket的accept方法來獲得一個Socket對象。
//服務端： Socket s = ss.accept();注意以上的代碼要捕獲相應的異常。這就不多說了，eclipse會幫助我們。
此時呢，服務端和客戶端的類中都持有了一個Socket對象。要完成數據交換，就要涉及IO了。
IO操作
socket的IO流
Socket有相應的get方法來獲得輸入輸出流。
InputStream in = s.getInputStream(); OutputStream out = s.getOutputStream();由此獲得的兩個字節IO流就是接下來所有數據交互的基礎了。然后為了提高效率要進行一下包裝。我是用的是DataInputStream/DataOutputStream。你也可以轉換為字符流。
DataInputStream din = new DataInputStream(in); DataOutputStream dout = new DataOutputStream(out);
很多人可能會把輸入流和輸出流搞混淆掉哦。
標准輸入的包裝
我們要實現從控制台中輸入，然后發送到網絡的輸入流（上文中的din），必須要對標准輸入（System.in）進行封裝。
誤區：
起初我覺得既然從標准輸入獲得的數據，要傳遞給DataOutputStream類型的對象dout發送出去，那么就用DataInputStream來包裝System.in吧。然后調用它的readUTF方法獲得字符串，在通過dout的writeUTF方法發送。
DataInputStream dis = new DataInputStream(System.in)); String msg = dis.readUTF(); dout.writeUTF(msg);但是當程序運行的時候，就會發現在一方的控制台窗口無論輸入多少行，對方都無法收到。也就是這里也陷入了阻塞，百度下，究其原因呢，是因為在控制台輸入的字符並不是UTF格式的。所以readUTF根本無法返回字符串。
————————————————————————————————————————————
DataInputStream/DataOutputStream提供了對於基本數據類型的寫入與讀取方法如：
| DataInputStream | DataOutputStream |
| readInt() | writeInt() |
| readChar() | writeChar() |
| readDouble() | writeDouble() |
————————————————————————————————————————————
接着我對控制台的標准輸入的包裝使用了BufferedReader(也可以使用Scanner包裝哦)。
接着我對控制台的標准輸入的包裝使用了BufferedReader(也可以使用Scanner包裝哦)。
BufferedReader bf = new BufferedReader(new InputStreamReader(System.in)); String msg = bf.readLine(); dout.writeUTF(msg);
【下面進入本片博客的重要環節（上面的內容你都可以認為是湊字數的鋪墊）】
多線程的使用
————————————————————————————————————————————
一般我們運行的程序只有一個主線程，也就是main函數創建的那個線程。一個線程中所有的操作呢都是線性的，但如果你想同時做多件事的話，就需要創建多個線程。記得《射雕》里面老頑童有個絕技“左右互博術”，他在傳授給郭靖的時候，就是讓郭靖不停的左手畫圓，右手畫方。這就相當於郭靖要同時開兩個線程，一個線程負責不停地左手畫圓，另一線程負責不停的右手畫方。當然不論是電腦還是人腦實際上都是無法同時做兩件事的，只不過CPU在兩個線程之間快速切換，給人的感覺像是同時一樣。
Java本身提供了對於多線程的支持。通過繼承Thread類，或者實現Runnable接口來創建新的線程。兩者都要重寫run()方法。不過采用Runnable，只是實現了Runnable接口的run方法還不夠，還要用此實現的接口來創建Thread對象才可以。最后調用Thread對象的start()方法就是創建這一進程了。
————————————————————————————————————————————
實現非阻塞的通信，我們要完成的事情只有兩個：
- 一個是從socket的輸入流中獲取對方的消息並打印在屏幕上。
- 從標准輸入中鍵入的消息要通過socket的輸出流發送給對方。
以上行為要開辟新的線程來完成來避免阻塞。為此我定義兩個類，取名為SendThread和PrintThread
為了便於操作，我將socket的包裝后的輸出流作為參數傳遞給SendThread。同樣PrintThread中也會傳如socket的包裝后的輸入流參數
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
public class SendThread implements Runnable {
private DataOutputStream dout;
public SendThread(DataOutputStream dout){
super();
this.dout= dout;
}
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
String msg;
try {
BufferedReader bf = new BufferedReader(
new InputStreamReader(System.in));
//注意不能直接用DataInputStream來封裝標准輸入，原因前文已提到
msg = bf.readLine();
dout.writeUTF(msg);
} catch (IOException e) {
// TODO Auto-generated catch block
break;
}
}
}
}
為了增強可讀性，我也把IP地址傳入了PrintThread中。大家也可無視
import java.io.DataInputStream;
import java.io.IOException;
class PrintThread implements Runnable{
private DataInputStream din;
private String ip;
public PrintThread(DataInputStream din,String ip) {
super();
this.din = din;
this.ip = ip;
}
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
try {
String msg = din.readUTF();
System.out.println("["+ip+"]"+":"+msg);
} catch (IOException e) {
// TODO Auto-generated catch block
break;
}
}
}
}
接着在主類Server和Client中要做的事就很簡單了。
//Server
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
private static String ip;
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
@SuppressWarnings("resource")
ServerSocket ss = new ServerSocket(5432);
Socket s = ss.accept();
ip = s.getInetAddress().toString();
ip = ip.substring(ip.indexOf("/")+1);
System.out.println(ip+"上線了");
InputStream in = s.getInputStream();
OutputStream out = s.getOutputStream();
DataInputStream din = new DataInputStream(in);
DataOutputStream dout = new DataOutputStream(out);
SendThread it = new SendThread(dout);
PrintThread ot = new PrintThread(din,ip);
new Thread(ot).start();
new Thread(it).start();
}
}
//Client
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class Client {
private static String ip = "127.0.0.1";
public static void main(String[] args) throws IOException{
@SuppressWarnings("resource")
Socket s = new Socket(ip,5432);
OutputStream out = s.getOutputStream();
InputStream in = s.getInputStream();
DataOutputStream dout = new DataOutputStream(out);
DataInputStream din = new DataInputStream(in);
SendThread it = new SendThread(dout);
PrintThread ot = new PrintThread(din,ip);
new Thread(ot).start();
new Thread(it).start();
}
}
基本的代碼就是這些，當然這是簡單實現，還可以有很多繼續完善的地方。比如使Server可以監聽多個Client的連接請求，或者你可以加個Swing的界面（個人比較不在乎界面）。細節我也有很多未仔細處理的地方，比如里面的Socket和各種IO流，都沒有寫關閉，（囧，沒有找到個合適的地方）所以代碼中會有一句
@SuppressWarnings("resource")
來忽略流未關閉的警告。。哈，有點水啊。
————————————————————后記的瑣事———————————————————
這段程序，我成功在電腦和虛擬機上實現了通信。虛擬機的原理就是把你的一台電腦當成兩台電腦來用了。只需要修改上述代碼中的IP地址就行了，虛擬機相當於和你處在一個局域網里，你可以使用ipconfig命令查看在這個局域網之下的虛擬機的ip地址，通常host-only的就是虛擬機的ip了。比如在這個虛擬的局域網中我本身的電腦IP地址是192.168.56.101，而虛擬機是192.168.56.1。
還有就是那天數據結構上機課的時候，我發現機房電腦里裝了java（但是沒eclipse）。。於是我就用記事本手寫了上面兩個程序，果然用慣了IDE，記事本會很不習慣啊。但最后還是完成了，我把Client的程序通過U盤傳給了旁邊的同學，最后兩台電腦實現了通信，呵呵。雖然是小事，還是蠻驕傲的呢。
————————————————————————————————————————————