Java Scoket實現(xiàn)雙向通信代碼詳解
你好我是辰兮,很高興你能來閱讀,本篇總結(jié)了Java Scoket類的相關(guān)知識,并且整理了實現(xiàn)雙向通信的相關(guān)代碼也有案例實現(xiàn)截圖,分享獲取新知,大家一起進(jìn)步。
一、網(wǎng)絡(luò)通信
網(wǎng)絡(luò)通信,在網(wǎng)絡(luò)中程序(發(fā)送者)與程序(接受者)之間的數(shù)據(jù)交互。
通信要素①ip + 端口號 ②傳輸協(xié)議
java.net包: 包含了Java用于網(wǎng)絡(luò)通信所需的類。
ServerSocket類,用于表示網(wǎng)絡(luò)服務(wù)
創(chuàng)建網(wǎng)絡(luò)服務(wù)(創(chuàng)建ServerSocket對象)
//構(gòu)造器public ServerSocket(int port)//創(chuàng)建網(wǎng)絡(luò)服務(wù)ServerSocket server = new ServerSocket(9999);
接收網(wǎng)絡(luò)請求
//接收網(wǎng)絡(luò)請求的方法public Socket accept()//網(wǎng)絡(luò)服務(wù)接收請求(阻塞)Socket socket = server.accept();
Socket類,網(wǎng)絡(luò)套接字,表示網(wǎng)絡(luò)連接
發(fā)送網(wǎng)絡(luò)請求//構(gòu)造器public Socket(String ip, int port)//獲取網(wǎng)絡(luò)連接中的輸入流public InputStream getInputStream()//獲取網(wǎng)絡(luò)連接中的輸出流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接受到信息,然后回復(fù)
點開Sender控制臺,看到回復(fù)的信息然后繼續(xù)回復(fù)
雙向溝通交流實現(xiàn)
到此這篇關(guān)于Java Scoket實現(xiàn)雙向通信代碼詳解的文章就介紹到這了,更多相關(guān)Java Scoket 雙向通信內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!
相關(guān)文章:
