ava中的TCP通信程序
TCP可以實(shí)現(xiàn)兩臺(tái)計(jì)算機(jī)之間的數(shù)據(jù)交互通信的兩端，要嚴(yán)格區(qū)分客戶端與服務(wù)端
兩端通信時(shí)的步驟：
1.服務(wù)端程序，需要事先啟動(dòng)，等待客戶端連接
2.客戶端主動(dòng)連接服務(wù)器端，才能成功通信，服務(wù)器端不可以主動(dòng)鏈接客戶端
在java中兩個(gè)類用于實(shí)現(xiàn)TCP通信程序：
客戶端： java.net.Socket 類表示。創(chuàng)建 Socket 對(duì)象，向服務(wù)端發(fā)出連接請(qǐng)求，服務(wù)端響應(yīng)請(qǐng)求，兩者建 立連接開始通信。
服務(wù)端： java.net.ServerSocket 類表示。創(chuàng)建 ServerSocket 對(duì)象，相當(dāng)于開啟一個(gè)服務(wù)，并等待客戶端 的連接。
Socket類
socket類：該類實(shí)現(xiàn)客戶端套接字，套接字是指兩臺(tái)設(shè)備之間的端點(diǎn)
構(gòu)造方法：
public Socket（String host，int port）：創(chuàng)建套接字對(duì)象并將其連接到指定對(duì)象的主機(jī)上，如果指定的host為NULL，則相當(dāng)于指定的地址為回送地址
回送地址
回送地址(127.x.x.x) 是本機(jī)回送地址（Loopback Address），主要用于網(wǎng)絡(luò)軟件測(cè)試以及本 地機(jī)進(jìn)程間通信，無論什么程序，一旦使用回送地址發(fā)送數(shù)據(jù)，立即返回，不進(jìn)行任何網(wǎng)絡(luò)傳輸。
構(gòu)造舉例
Socket client=new Socket（“127.0.0.1”，666）
成員方法：
public InputStream getInputStream() ： 返回此套接字的輸入流。 如果此Scoket具有相關(guān)聯(lián)的通道，則生成的InputStream 的所有操作也關(guān)聯(lián)該通道。 關(guān)閉生成的InputStream也將關(guān)閉相關(guān)的Socket。
public OutputStream getOutputStream() ： 返回此套接字的輸出流。 如果此Scoket具有相關(guān)聯(lián)的通道，則生成的OutputStream 的所有操作也關(guān)聯(lián)該通道。 關(guān)閉生成的OutputStream也將關(guān)閉相關(guān)的Socket
public void close() ：關(guān)閉此套接字。 一旦一個(gè)socket被關(guān)閉，它不可再使用。 關(guān)閉此socket也將關(guān)閉相關(guān)的InputStream和OutputStream 。
public void shutdownOutput() ： 禁用此套接字的輸出流。 任何先前寫出的數(shù)據(jù)將被發(fā)送，隨后終止輸出流。
ServerSocket類
public ServerSocket(int port) ：使用該構(gòu)造方法在創(chuàng)建ServerSocket對(duì)象時(shí)，就可以將其綁定到一個(gè)指 定的端口號(hào)上，參數(shù)port就是端口號(hào)
構(gòu)造舉例代碼如下：
ServerSocket server=new ServerSocket（666）
成員方法 public Socket accept() ：偵聽并接受連接，返回一個(gè)新的Socket對(duì)象，用于和客戶端實(shí)現(xiàn)通信。
兩個(gè)需要明確的事情
1多個(gè)服務(wù)器端與客戶進(jìn)行交互，服務(wù)器必須明確是和哪個(gè)客戶端進(jìn)行交互，這個(gè)accept（）方法用與獲取請(qǐng)求的客戶端對(duì)象
2.多個(gè)客戶端同時(shí)與服務(wù)器進(jìn)行交互就需要使用多個(gè)io流對(duì)象
服務(wù)器是沒有io流的，服務(wù)器可以獲取到請(qǐng)求的客戶端對(duì)象的scoket，使用每一個(gè)客戶端Socket中提供的io流對(duì)象進(jìn)行交互。
服務(wù)器端使用客戶端的字節(jié)輸入流讀取客戶端發(fā)送的數(shù)據(jù)，
服務(wù)器端使用客戶端的字節(jié)輸出流給客戶端回寫數(shù)據(jù)
即服務(wù)器端使用客戶端流與客戶端交互
好比生活中的我請(qǐng)客你買單
在這里插入圖片描述
簡(jiǎn)單的TCP網(wǎng)絡(luò)程序圖解
【服務(wù)端】啟動(dòng),創(chuàng)建ServerSocket對(duì)象，等待連接。 Socket client = new Socket("127.0.0.1", 6666); ServerSocket server = new ServerSocket(6666);
【客戶端】啟動(dòng),創(chuàng)建Socket對(duì)象，請(qǐng)求連接。
【服務(wù)端】接收連接,調(diào)用accept方法，并返回一個(gè)Socket對(duì)象
【客戶端】Socket對(duì)象，獲取OutputStream，向服務(wù)端寫出數(shù)據(jù)
【服務(wù)端】Scoket對(duì)象，獲取InputStream，讀取客戶端發(fā)送的數(shù)據(jù)。
【服務(wù)端】Socket對(duì)象，獲取OutputStream，向客戶端回寫數(shù)據(jù)。
【客戶端】Scoket對(duì)象，獲取InputStream，解析回寫數(shù)據(jù)
【客戶端】釋放資源，斷開連接。
在這里插入圖片描述
該方法 會(huì)一直阻塞直到建立連接。
下面寫一段簡(jiǎn)單的客戶端與服務(wù)器端交互的代碼
服務(wù)器端代碼
package Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
? ? public static void main(String[] args) throws IOException {
? ? ? ? System.out.println("服務(wù)器啟動(dòng)等待連接：");
? ? ? ? //創(chuàng)建服務(wù)器端對(duì)象
? ? ? ? ServerSocket serverSocket = new ServerSocket(8888);
? ? ? ? //使用accept方法接受socket對(duì)象
? ? ? ? Socket accept = serverSocket.accept();
? ? ? ? //通過socket獲取輸入流
? ? ? ? InputStream inputStream = accept.getInputStream();
? ? ? ? //會(huì)不會(huì)阻塞
? ? ? ? System.out.println("XXXXXXXXXXXXXXXXX");
? ? ? ? byte[] bytes = new byte[1024];
? ? ? ? int read = inputStream.read(bytes);
? ? ? ? //通過字節(jié)數(shù)組生成字符串
? ? ? ? String s = new String(bytes,0,read);
? ? ? ? //輸出
? ? ? ? System.out.println(s);
? ? ? ? //向客戶端返回信息
? ? ? ? OutputStream outputStream = accept.getOutputStream();
? ? ? ? //返回內(nèi)容
? ? ? ? outputStream.write("內(nèi)容已經(jīng)收到".getBytes());
? ? ? ? //關(guān)閉資源
? ? ? ? inputStream.close();
? ? ? ? serverSocket.close();
? ? }
}
客戶端代碼
package Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class Client {
? ? public static void main(String[] args) throws IOException {
? ? ? ? //創(chuàng)建Socket對(duì)象
? ? ? ? Socket socket = new Socket("127.0.0.1", 8888);
? ? ? ? //獲取輸出流
? ? ? ? OutputStream outputStream = socket.getOutputStream();
? ? ? ? //給服務(wù)端發(fā)送消息
? ? ? ? outputStream.write("你好".getBytes());
? ? ? ? //創(chuàng)建輸入流對(duì)象
? ? ? ? InputStream inputStream = socket.getInputStream();
? ? ? ? //創(chuàng)建讀取的數(shù)組
? ? ? ? byte[] bytes = new byte[1024];
? ? ? ? //獲取字節(jié)數(shù)組的長(zhǎng)度
? ? ? ? int read = inputStream.read(bytes);
? ? ? ? //輸出結(jié)果
? ? ? ? System.out.println(new String(bytes,0,read));
? ? ? ? //關(guān)閉流
? ? ? ? outputStream.close();
? ? ? ? //關(guān)閉Socket對(duì)象
? ? ? ? socket.close();
? ? }
}
龍華大道1號(hào)?http://www.kinghill.cn/LongHuaDaDao1Hao/index.html
