Java Scoket實現(xiàn)雙向通信代碼詳解
你好我是辰兮,很高興你能來閱讀,本篇總結了Java Scoket類的相關知識,并且整理了實現(xiàn)雙向通信的相關代碼也有案例實現(xiàn)截圖,分享獲取新知,大家一起進步。
一、網(wǎng)絡通信
網(wǎng)絡通信,在網(wǎng)絡中程序(發(fā)送者)與程序(接受者)之間的數(shù)據(jù)交互。
通信要素①ip + 端口號 ②傳輸協(xié)議
java.net包: 包含了Java用于網(wǎng)絡通信所需的類。
ServerSocket類,用于表示網(wǎng)絡服務
創(chuàng)建網(wǎng)絡服務(創(chuàng)建ServerSocket對象)
//構造器public ServerSocket(int port)//創(chuàng)建網(wǎng)絡服務ServerSocket server = new ServerSocket(9999);
接收網(wǎng)絡請求
//接收網(wǎng)絡請求的方法public Socket accept()//網(wǎng)絡服務接收請求(阻塞)Socket socket = server.accept();
Socket類,網(wǎng)絡套接字,表示網(wǎng)絡連接
發(fā)送網(wǎng)絡請求//構造器public Socket(String ip, int port)//獲取網(wǎng)絡連接中的輸入流public InputStream getInputStream()//獲取網(wǎng)絡連接中的輸出流public OuputStream getOutputStream()
二、接受者(Receiver)
代碼實現(xiàn)如下:信息的接受者
public class Receiver { public static void main(String[] args) { try { ServerSocket server = new ServerSocket(8888); Socket socket = server.accept(); System.out.println('----程序已經(jīng)連接++++'); InputStream is = socket.getInputStream(); OutputStream os = socket.getOutputStream(); InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); PrintWriter pw = new PrintWriter(os); Runnable r1 = new Runnable() {@Overridepublic void run() { while (true) { // 接受信息 String str; try { str = br.readLine(); System.out.println('sender的信息' + str); } catch (IOException e) { e.printStackTrace(); } }} }; Runnable r2 = new Runnable() {@Overridepublic void run() { // 返回信息 while (true) { Scanner scan = new Scanner(System.in); String msg = scan.nextLine(); pw.println(msg); pw.flush(); }} }; Thread t1 = new Thread(r1); Thread t2 = new Thread(r2); t1.start(); t2.start(); } catch (IOException e) { e.printStackTrace(); } }}
三、發(fā)送者(Sender)
代碼實現(xiàn)如下:信息的發(fā)送者
public class Sender { public static void main(String[] args) { try { Socket socket = new Socket('192.168.1.6', 8888); InputStream is = socket.getInputStream(); OutputStream os = socket.getOutputStream(); InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); PrintWriter pw = new PrintWriter(os); Runnable r = new Runnable() {@Overridepublic void run() { while (true) { // 發(fā)送信息 try { Scanner scan = new Scanner(System.in); String msg = scan.nextLine(); pw.println(msg); pw.flush(); } catch (Exception e) { } }} }; Runnable r2 = new Runnable() {@Overridepublic void run() { // 接受發(fā)送的信息 while (true) { String str; try { str = br.readLine(); System.out.println('接受者receiver:' + str); } catch (IOException e) { e.printStackTrace(); } }} }; Thread t1 = new Thread(r); Thread t2 = new Thread(r2); t1.start(); t2.start(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }}
四、案例截圖
首先看到開啟Receiver,然后開啟Sender
開啟Sender后----看到Receiver控制臺顯示連接成功

Sender發(fā)送信息

Receiver接受到信息,然后回復

點開Sender控制臺,看到回復的信息然后繼續(xù)回復

雙向溝通交流實現(xiàn)

到此這篇關于Java Scoket實現(xiàn)雙向通信代碼詳解的文章就介紹到這了,更多相關Java Scoket 雙向通信內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持好吧啦網(wǎng)!
相關文章:

網(wǎng)公網(wǎng)安備