|
好久沒(méi)寫(xiě)博客了，前段時(shí)間忙于做項(xiàng)目，耽誤了些時(shí)間，今天開(kāi)始繼續(xù)寫(xiě)起~ 今天來(lái)講下關(guān)于Socket通信的簡(jiǎn)單應(yīng)用，關(guān)于什么是Socket以及一些網(wǎng)絡(luò)編程的基礎(chǔ)，這里就不提了，只記錄最簡(jiǎn)單易懂實(shí)用的東西。
1、首先先來(lái)看下基于TCP協(xié)議Socket服務(wù)端和客戶(hù)端的通信模型：
Socket通信步驟：（簡(jiǎn)單分為4步） 1.建立服務(wù)端ServerSocket和客戶(hù)端Socket 2.打開(kāi)連接到Socket的輸出輸入流 3.按照協(xié)議進(jìn)行讀寫(xiě)操作 4.關(guān)閉相對(duì)應(yīng)的資源
2、相關(guān)聯(lián)的API：
1.首先先來(lái)看下ServerSocket 類(lèi) ServerSocket此類(lèi)實(shí)現(xiàn)服務(wù)器套接字。服務(wù)器套接字等待請(qǐng)求通過(guò)網(wǎng)絡(luò)傳入。它基于該請(qǐng)求執(zhí)行某些操作，然后可能向請(qǐng)求者返回結(jié)果。 服務(wù)器套接字的實(shí)際工作由 一些重要的方法：（具體大家查看官方api吧）
2.再來(lái)看下Socket 類(lèi) Socket此類(lèi)實(shí)現(xiàn)客戶(hù)端套接字（也可以就叫“套接字”）。套接字是兩臺(tái)機(jī)器間通信的端點(diǎn)。 套接字的實(shí)際工作由 一些重要的方法：（具體大家查看官方api吧）
3、代碼實(shí)現(xiàn)：（注釋很全，這里就不詳細(xì)多說(shuō)了） 服務(wù)端Server.java 1.創(chuàng)建ServerSocket對(duì)象，綁定并監(jiān)聽(tīng)端口 2.通過(guò)accept監(jiān)聽(tīng)客戶(hù)端的請(qǐng)求 3.建立連接后，通過(guò)輸出輸入流進(jìn)行讀寫(xiě)操作 4.關(guān)閉相關(guān)資源  1 import java.io.BufferedReader; 2 import java.io.IOException; 3 import java.io.InputStream; 4 import java.io.InputStreamReader; 5 import java.io.OutputStream; 6 import java.io.PrintWriter; 7 import java.net.ServerSocket; 8 import java.net.Socket; 9 10 11 public class Server { 12 13 /** 14 * Socket服務(wù)端 15 */ 16 public static void main(String[] args) { 17 try { 18 ServerSocket serverSocket=new ServerSocket(8888); 19 System.out.println("服務(wù)端已啟動(dòng)，等待客戶(hù)端連接.."); 20 Socket socket=serverSocket.accept();//偵聽(tīng)并接受到此套接字的連接,返回一個(gè)Socket對(duì)象 21 22 23 //根據(jù)輸入輸出流和客戶(hù)端連接 24 InputStream inputStream=socket.getInputStream();//得到一個(gè)輸入流，接收客戶(hù)端傳遞的信息 25 InputStreamReader inputStreamReader=new InputStreamReader(inputStream);//提高效率，將自己字節(jié)流轉(zhuǎn)為字符流 26 BufferedReader bufferedReader=new BufferedReader(inputStreamReader);//加入緩沖區(qū) 27 String temp=null; 28 String info=""; 29 while((temp=bufferedReader.readLine())!=null){ 30 info+=temp; 31 System.out.println("已接收到客戶(hù)端連接"); 32 System.out.println("服務(wù)端接收到客戶(hù)端信息："+info+",當(dāng)前客戶(hù)端ip為："+socket.getInetAddress().getHostAddress()); 33 } 34 35 OutputStream outputStream=socket.getOutputStream();//獲取一個(gè)輸出流，向服務(wù)端發(fā)送信息 36 PrintWriter printWriter=new PrintWriter(outputStream);//將輸出流包裝成打印流 37 printWriter.print("你好，服務(wù)端已接收到您的信息"); 38 printWriter.flush(); 39 socket.shutdownOutput();//關(guān)閉輸出流 40 41 42 43 //關(guān)閉相對(duì)應(yīng)的資源 44 printWriter.close(); 45 outputStream.close(); 46 bufferedReader.close(); 47 inputStream.close(); 48 socket.close(); 49 50 } catch (IOException e) { 51 e.printStackTrace(); 52 } 53 } 54 55 }
客戶(hù)端Client.java 1.創(chuàng)建Socket對(duì)象，指定服務(wù)端的地址和端口號(hào) 2.建立連接后，通過(guò)輸出輸入流進(jìn)行讀寫(xiě)操作 3.通過(guò)輸出輸入流獲取服務(wù)器返回信息 4.關(guān)閉相關(guān)資源 1 import java.io.BufferedReader; 2 import java.io.IOException; 3 import java.io.InputStream; 4 import java.io.InputStreamReader; 5 import java.io.OutputStream; 6 import java.io.PrintWriter; 7 import java.net.Socket; 8 import java.net.UnknownHostException; 9 10 11 public class Client { 12 13 /** 14 * Socket客戶(hù)端 15 */ 16 public static void main(String[] args) { 17 try { 18 //創(chuàng)建Socket對(duì)象 19 Socket socket=new Socket("localhost",8888); 20 21 //根據(jù)輸入輸出流和服務(wù)端連接 22 OutputStream outputStream=socket.getOutputStream();//獲取一個(gè)輸出流，向服務(wù)端發(fā)送信息 23 PrintWriter printWriter=new PrintWriter(outputStream);//將輸出流包裝成打印流 24 printWriter.print("服務(wù)端你好，我是Balla_兔子"); 25 printWriter.flush(); 26 socket.shutdownOutput();//關(guān)閉輸出流 27 28 InputStream inputStream=socket.getInputStream();//獲取一個(gè)輸入流，接收服務(wù)端的信息 29 InputStreamReader inputStreamReader=new InputStreamReader(inputStream);//包裝成字符流，提高效率 30 BufferedReader bufferedReader=new BufferedReader(inputStreamReader);//緩沖區(qū) 31 String info=""; 32 String temp=null;//臨時(shí)變量 33 while((temp=bufferedReader.readLine())!=null){ 34 info+=temp; 35 System.out.println("客戶(hù)端接收服務(wù)端發(fā)送信息："+info); 36 } 37 38 //關(guān)閉相對(duì)應(yīng)的資源 39 bufferedReader.close(); 40 inputStream.close(); 41 printWriter.close(); 42 outputStream.close(); 43 socket.close(); 44 } catch (UnknownHostException e) { 45 e.printStackTrace(); 46 } catch (IOException e) { 47 e.printStackTrace(); 48 } 49 50 } 51 52 }
4、效果截圖： 服務(wù)端：
客戶(hù)端：
以上代碼實(shí)現(xiàn)了單客戶(hù)端和服務(wù)端的連接，若要實(shí)現(xiàn)多客戶(hù)端操作，需要涉及到多線(xiàn)程，只要你把每個(gè)接收到的Socket對(duì)象單獨(dú)開(kāi)一條線(xiàn)程操作，然后用一個(gè)死循環(huán)while(true)去監(jiān)聽(tīng)端口就行，這邊直接給代碼了
線(xiàn)程操作類(lèi)：SocketThread.java 1 import java.io.BufferedReader; 2 import java.io.IOException; 3 import java.io.InputStream; 4 import java.io.InputStreamReader; 5 import java.io.OutputStream; 6 import java.io.PrintWriter; 7 import java.net.Socket; 8 9 /** 10 * Socket多線(xiàn)程處理類(lèi) 用來(lái)處理服務(wù)端接收到的客戶(hù)端請(qǐng)求（處理Socket對(duì)象） 11 */ 12 public class SocketThread extends Thread { 13 private Socket socket; 14 15 public SocketThread(Socket socket) { 16 this.socket = socket; 17 } 18 19 public void run() { 20 // 根據(jù)輸入輸出流和客戶(hù)端連接 21 try { 22 InputStream inputStream = socket.getInputStream(); 23 // 得到一個(gè)輸入流，接收客戶(hù)端傳遞的信息 24 InputStreamReader inputStreamReader = new InputStreamReader( 25 inputStream);// 提高效率，將自己字節(jié)流轉(zhuǎn)為字符流 26 BufferedReader bufferedReader = new BufferedReader( 27 inputStreamReader);// 加入緩沖區(qū) 28 String temp = null; 29 String info = ""; 30 while ((temp = bufferedReader.readLine()) != null) { 31 info += temp; 32 System.out.println("已接收到客戶(hù)端連接"); 33 System.out.println("服務(wù)端接收到客戶(hù)端信息：" + info + ",當(dāng)前客戶(hù)端ip為：" 34 + socket.getInetAddress().getHostAddress()); 35 } 36 37 OutputStream outputStream = socket.getOutputStream();// 獲取一個(gè)輸出流，向服務(wù)端發(fā)送信息 38 PrintWriter printWriter = new PrintWriter(outputStream);// 將輸出流包裝成打印流 39 printWriter.print("你好，服務(wù)端已接收到您的信息"); 40 printWriter.flush(); 41 socket.shutdownOutput();// 關(guān)閉輸出流 42 43 // 關(guān)閉相對(duì)應(yīng)的資源 44 bufferedReader.close(); 45 inputStream.close(); 46 printWriter.close(); 47 outputStream.close(); 48 } catch (IOException e) { 49 e.printStackTrace(); 50 } 51 52 } 53 54 }
服務(wù)端類(lèi)：Server.java 1 import java.io.IOException; 2 import java.net.ServerSocket; 3 import java.net.Socket; 4 5 public class Server { 6 7 /** 8 * Socket服務(wù)端 9 */ 10 public static void main(String[] args) { 11 try { 12 ServerSocket serverSocket = new ServerSocket(8888); 13 System.out.println("服務(wù)端已啟動(dòng)，等待客戶(hù)端連接.."); 14 15 while (true) { 16 Socket socket = serverSocket.accept();// 偵聽(tīng)并接受到此套接字的連接,返回一個(gè)Socket對(duì)象 17 SocketThread socketThread = new SocketThread(socket); 18 socketThread.start(); 19 } 20 21 } catch (IOException e) { 22 e.printStackTrace(); 23 } 24 } 25 26 } 
客戶(hù)端類(lèi):Client.java 1 import java.io.BufferedReader; 2 import java.io.IOException; 3 import java.io.InputStream; 4 import java.io.InputStreamReader; 5 import java.io.OutputStream; 6 import java.io.PrintWriter; 7 import java.net.Socket; 8 import java.net.UnknownHostException; 9 10 11 public class Client { 12 13 /** 14 * Socket客戶(hù)端 15 */ 16 public static void main(String[] args) { 17 try { 18 //創(chuàng)建Socket對(duì)象 19 Socket socket=new Socket("localhost",8888); 20 21 //根據(jù)輸入輸出流和服務(wù)端連接 22 OutputStream outputStream=socket.getOutputStream();//獲取一個(gè)輸出流，向服務(wù)端發(fā)送信息 23 PrintWriter printWriter=new PrintWriter(outputStream);//將輸出流包裝成打印流 24 printWriter.print("服務(wù)端你好，我是客戶(hù)1"); 25 printWriter.flush(); 26 socket.shutdownOutput();//關(guān)閉輸出流 27 28 InputStream inputStream=socket.getInputStream();//獲取一個(gè)輸入流，接收服務(wù)端的信息 29 InputStreamReader inputStreamReader=new InputStreamReader(inputStream);//包裝成字符流，提高效率 30 BufferedReader bufferedReader=new BufferedReader(inputStreamReader);//緩沖區(qū) 31 String info=""; 32 String temp=null;//臨時(shí)變量 33 while((temp=bufferedReader.readLine())!=null){ 34 info+=temp; 35 System.out.println("客戶(hù)端接收服務(wù)端發(fā)送信息："+info); 36 } 37 38 //關(guān)閉相對(duì)應(yīng)的資源 39 bufferedReader.close(); 40 inputStream.close(); 41 printWriter.close(); 42 outputStream.close(); 43 socket.close(); 44 } catch (UnknownHostException e) { 45 e.printStackTrace(); 46 } catch (IOException e) { 47 e.printStackTrace(); 48 } 49 50 } 51 52 }
看下效果實(shí)現(xiàn)圖：
這里只是拋磚引玉，在實(shí)際開(kāi)發(fā)中，基于Socket編程，一般傳遞的并非字符串，很多情況下是對(duì)象，我們可以使用ObjectOutputStream將輸出流對(duì)象序列化。 例如： 1 OutputStream outputStream = socket.getOutputStream(); 2 ObjectOutputStream objectOutputStream=new ObjectOutputStream(outputStream); 3 User user=new User("admin","123456"); 4 objectOutputStream.writeObject(user);
作者：Balla_兔子 |
|
|
來(lái)自： 我的java之路 > 《待分類(lèi)》
