以用戶登錄為例：
客戶端發(fā)送用戶名和密碼到服務(wù)器端妒挎，然后服務(wù)器端進(jìn)行響應(yīng)穷躁，返回類似“歡迎登錄之類的信息”
1捶索、創(chuàng)建ServerSocket對(duì)象八孝，綁定監(jiān)聽(tīng)窗口
2董朝、通過(guò)accept（）方法監(jiān)聽(tīng)客戶端請(qǐng)求
3、連接建立后干跛，通過(guò)輸入流讀取客戶端發(fā)送的請(qǐng)求信息
4子姜、通過(guò)輸出流向客戶端發(fā)送響應(yīng)信息
5、關(guān)閉相關(guān)資源
示例代碼：
public class Server {
/*
* 基于TCP的socket通信楼入，實(shí)現(xiàn)用戶登錄
* 服務(wù)器端：
*/
public static void main(String[] args) {
try {
//1哥捕、創(chuàng)建一個(gè)服務(wù)器Socket，即ServerSocket,指定綁定的端口嘉熊，并監(jiān)聽(tīng)此端口
ServerSocket serverSocket=new ServerSocket(8888);
//2扭弧、調(diào)用accept（）方法開(kāi)始監(jiān)聽(tīng)，等待客戶端的連接
System.err.println("~~~服務(wù)器即將啟動(dòng)记舆，等待客戶端的連接~~");
Socket socket=serverSocket.accept();
//3鸽捻、 獲取輸入流，并讀取客戶端信息
InputStream is=socket.getInputStream();
//字節(jié)輸入流
InputStreamReader isr=new InputStreamReader(is);
//將字節(jié)流轉(zhuǎn)換為字符流
BufferedReader br=new BufferedReader(isr);
//為輸入流添加緩沖
String info=null;//循環(huán)讀取客戶端的信息
while((info=br.readLine())!=null){
System.out.println("我是服務(wù)器泽腮，客戶端說(shuō)："+info);
}
socket.shutdownInput();//關(guān)閉輸入流
//4御蒲、獲取輸出流，響應(yīng)客戶端的請(qǐng)求.
OutputStream os=socket.getOutputStream();
PrintWriter pw=new PrintWriter(os);
pw.write("歡迎登錄诊赊！");
pw.flush();
//5厚满、關(guān)閉資源
os.close();
pw.close();
br.close();
isr.close();
is.close();
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
1、創(chuàng)建Socket對(duì)象碧磅，指明需要連接的服務(wù)器的地址和端口號(hào)
2碘箍、連接建立后，通過(guò)輸出流向服務(wù)器端發(fā)送請(qǐng)求信息
3鲸郊、通過(guò)輸入流獲取服務(wù)器響應(yīng)的信息
4丰榴、關(guān)閉相關(guān)資源
public class Client {
public static void main(String[] args) {
try {
//1、創(chuàng)建客戶端Socket秆撮，指定服務(wù)器地址和端口
Socket socket=new Socket("localhost", 8888);
//2四濒、獲取輸出流，向服務(wù)器發(fā)送信息
OutputStream os=socket.getOutputStream();
PrintWriter pw=new PrintWriter(os);//將輸出流包裝為打印流
pw.write("用戶名：admin;密碼：123");
pw.flush();
socket.shutdownOutput();//關(guān)閉輸出流
//3职辨、獲取服務(wù)器端回復(fù)的信息s
InputStream is=socket.getInputStream();
InputStreamReader isr=new InputStreamReader(is);
BufferedReader br=new BufferedReader(isr);
String s=null;
while((s=br.readLine())!=null){
System.out.println("服務(wù)器說(shuō)："+s);
}
socket.shutdownInput();
//4盗蟆、關(guān)閉資源
is.close();
isr.close();
br.close();
pw.close();
os.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
輸出結(jié)果：
進(jìn)階：
- 使用多線程實(shí)現(xiàn)多客戶端通信
在實(shí)際應(yīng)用中往往是一個(gè)服務(wù)器同時(shí)與多個(gè)客戶端實(shí)現(xiàn)通信，并且接受請(qǐng)求舒裤，實(shí)現(xiàn)相應(yīng)的服務(wù)喳资。
應(yīng)用多線程來(lái)實(shí)現(xiàn)服務(wù)器與多客戶端之間的通信的步驟：
1.服務(wù)器端創(chuàng)建SeverSocket，循環(huán)調(diào)用accept()等待客戶端連接
2.服務(wù)器創(chuàng)建一個(gè)socket并請(qǐng)求和服務(wù)器端連接
3.服務(wù)器端接受客戶端請(qǐng)求腾供，創(chuàng)建socket與該客戶端建立專線連接
4.建立連接的兩個(gè)socket在一個(gè)單獨(dú)的線程上對(duì)話
5.服務(wù)器端繼續(xù)等待新的連接
代碼示例：
創(chuàng)建一個(gè)服務(wù)器端線程
跟原本的服務(wù)器端處理的任務(wù)相似仆邓，只不過(guò)獨(dú)立一個(gè)線程出來(lái)處理亏栈。主要工作是接收到客戶端的請(qǐng)求后發(fā)做出的輸出。
public class ServerThread extends Thread {
// 和本線程相關(guān)的Socket
Socket socket = null;
public ServerThread(Socket socket) {
this.socket = socket;
}
//線程執(zhí)行的操作宏赘，響應(yīng)客戶端的請(qǐng)求
public void run(){
InputStream is=null;
InputStreamReader isr=null;
BufferedReader br=null;
OutputStream os=null;
PrintWriter pw=null;
try {
//獲取輸入流，并讀取客戶端信息
is = socket.getInputStream();
isr = new InputStreamReader(is);
br = new BufferedReader(isr);
String info=null;
while((info=br.readLine())!=null){//循環(huán)讀取客戶端的信息
System.out.println("我是服務(wù)器黎侈，客戶端說(shuō)："+info);
}
socket.shutdownInput();//關(guān)閉輸入流
//獲取輸出流察署，響應(yīng)客戶端的請(qǐng)求
os = socket.getOutputStream();
pw = new PrintWriter(os);
pw.write("歡迎您！");
pw.flush();//調(diào)用flush()方法將緩沖輸出
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
//關(guān)閉資源
try {
if(pw!=null)
pw.close();
if(os!=null)
os.close();
if(br!=null)
br.close();
if(isr!=null)
isr.close();
if(is!=null)
is.close();
if(socket!=null)
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
客戶端代碼（依舊）
public class Client {
public static void main(String[] args) {
try {
//1.創(chuàng)建客戶端Socket峻汉，指定服務(wù)器地址和端口
Socket socket=new Socket("localhost", 8888);
//2.獲取輸出流贴汪，向服務(wù)器端發(fā)送信息
OutputStream os=socket.getOutputStream();//字節(jié)輸出流
PrintWriter pw=new PrintWriter(os);//將輸出流包裝為打印流
pw.write("用戶名：alice;密碼：789");
pw.flush();
socket.shutdownOutput();//關(guān)閉輸出流
//3.獲取輸入流，并讀取服務(wù)器端的響應(yīng)信息
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String info=null;
while((info=br.readLine())!=null){
System.out.println("我是客戶端休吠，服務(wù)器說(shuō)："+info);
}
//4.關(guān)閉資源
br.close();
is.close();
pw.close();
os.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
服務(wù)器端代碼：(不斷偵聽(tīng)扳埂，然后新建線程，做出響應(yīng)瘤礁，關(guān)閉資源)
public class Server {
public static void main(String[] args) {
try {
//1.創(chuàng)建一個(gè)服務(wù)器端Socket阳懂，即ServerSocket，指定綁定的端口柜思，并監(jiān)聽(tīng)此端口
ServerSocket serverSocket=new ServerSocket(8888);
Socket socket=null;
//記錄客戶端的數(shù)量
int count=0;
System.out.println("***服務(wù)器即將啟動(dòng)岩调，等待客戶端的連接***");
//循環(huán)監(jiān)聽(tīng)等待客戶端的連接
while(true){
//調(diào)用accept()方法開(kāi)始監(jiān)聽(tīng)，等待客戶端的連接
socket=serverSocket.accept();
//創(chuàng)建一個(gè)新的線程
ServerThread serverThread=new ServerThread(socket);
//啟動(dòng)線程
serverThread.start();
count++;//統(tǒng)計(jì)客戶端的數(shù)量
System.out.println("客戶端的數(shù)量："+count);
InetAddress address=socket.getInetAddress();
System.out.println("當(dāng)前客戶端的IP："+address.getHostAddress());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
