1.1 ServerSocket類
創建一個ServerSocket類，同時在運行該語句的計算機的指定端口處建立一個監聽服務，如：
ServerSocket MyListener=new ServerSocket(600)；
這里指定提供監聽服務的端口是600，一台計算機可以同時提供多個服務，這些不同的服務之間通過端口號來區別，不同的端口號上提供不同的服務。為了隨時監聽可能的Client請求，執行如下的語句：
Socket LinkSocket=MyListener．accept()；
該語句調用了ServerSocket對象的accept()方法，這個方法的執行將使Server端的程序處於等待狀態，程序將一直阻塞直到捕捉到一個來自Client端的請求，並返回一個用於與該Client通信的Socket對象Link-Socket。此后Server程序只要向這個Socket對象讀寫數據，就可以實現向遠端的Client讀寫數據。結束監聽時，關閉ServerSocket對象：
Mylistener．close()；
1．2 Socket類
當Client程序需要從Server端獲取信息及其他服務時，應創建一個Socket對象：
Socket MySocket=new Socket(“ServerComputerName”，600)；
Socket類的構造函數有兩個參數，第一個參數是欲連接到的Server計算機的主機地址，第二個參數是該Server機上提供服務的端口號。
Socket對象建立成功之后，就可以在Client和Server之間建立一個連接，並通過這個連接在兩個端點之間傳遞數據。利用Socket類的方法getOutputStream()和getInputStream()分別獲得向Socket讀寫數據的輸入／輸出流，最后將從Server端讀取的數據重新返還到Server端。
當Server和Client端的通信結束時，可以調用Socket類的close()方法關閉Socket，拆除連接。
ServerSocket 一般僅用於設置端口號和監聽，真正進行通信的是服務器端的Socket與客戶端的Socket，在ServerSocket 進行accept之后，就將主動權轉讓了。
1. 服務器端程序設計
在服務器端，利用ServerSocket類的構造函數ServerSocket(int port)創建一個ServerSocket類的對象，port參數傳遞端口，這個端口就是服務器監聽連接請求的端口，如果在這時出現錯誤將拋出IOException異常對象，否則將創建ServerSocket對象並開始准備接收連接請求。
服務程序從調用ServerSocket的accept()方法開始，直到連接建立。在建立連接后，accept()返回一個最近創建的Socket對象，該Socket對象綁定了客戶程序的IP地址或端口號。
2.客戶端程序設計
當客戶程序需要與服務器程序通信時，需在客戶機創建一個Socket對象。Socket類有構造函數Socket(InetAddress addr，int port)和Socket(String host，intport)，兩個構造函數都創建了一個基於Socket的連接服務器端流套接字的流套接字。對於第一個InetAd-dress子類對象通過addr參數獲得服務器主機的IP地址，對於第二個函數host參數包被分配到InetAddress對象中，如果沒有IP地址與host參數相一致，那么將拋出UnknownHostException異常對象。兩個函數都通過參數port獲得服務器的端口號。假設已經建立連接了，網絡API將在客戶端基於Socket的流套接字中捆綁客戶程序的IP地址和任意一個端口號，否則兩個函數都會拋出一個IOException對象。
如果創建了一個Socket對象，那么它可通過get-InputStream()方法從服務程序獲得輸入流讀傳送來的信息，也可通過調用getOutputStream()方法獲得輸出流來發送消息。在讀寫活動完成之后，客戶程序調用close()方法關閉流和流套接字。
Tcp實例
//客戶端 public class TcpClientDemo02 { public static void main(String[] args) throws Exception { //1.創建一個socket連接 Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9000); //2.創建一個輸出流 OutputStream os = socket.getOutputStream(); //3.讀取文件 FileInputStream fis = new FileInputStream(new File("shuaige.jpg")); //4.寫出文件 byte[] buffer = new byte[1024]; //大公司不允許這樣寫，會造成資源浪費 int len; while((len = fis.read(buffer))!=-1){ os.write(buffer,0,len); } //通知服務器，我已經傳輸完成 socket.shutdownOutput(); //確定服務器接受完畢，才能夠斷開連接 InputStream inputStream = socket.getInputStream(); //String byte[] ByteArrayOutputStream baos = new ByteArrayOutputStream(); byte[] buffer2 = new byte[2014]; int len2; while((len2 = inputStream.read(buffer2))!=-1){ //管道里面的字節流信息未輸出完，就一直輸出 baos.write(buffer2,0,len2); //從服務器的管道流信息寫入進來，然后載輸出 } System.out.println(baos.toString()); //5.關閉資源 baos.close(); inputStream.close(); fis.close(); os.close(); socket.close(); }
//服務器端 public class TcpServerDemo02 { public static void main(String[] args) throws Exception { //1.創建一個端口，也就是創建一個服務 ServerSocket serverSocket = new ServerSocket(9000); //2.監聽客戶端的連接 Socket socket = serverSocket.accept();//阻塞式監聽，會一直等待客戶端連接 //3.獲取輸入流 InputStream is = socket.getInputStream(); //4.文件輸出 FileOutputStream fos = new FileOutputStream(new File("receive.jpg")); byte[] buffer = new byte[1024]; int len; while((len = is.read(buffer))!= -1){ fos.write(buffer,0,len); } //通知客戶端我接受完畢了 OutputStream os = socket.getOutputStream(); os.write("我接受完畢了，你可以斷開了".getBytes()); //關閉資源 fos.close(); is.close(); socket.close(); serverSocket.close(); Scanner scanner = new Scanner(System.in); scanner.next(); }