多線程Socket的InputStream的問題

這幾天都在開發(fā)一個學(xué)生時代的一個小項目(SSH開發(fā))，導(dǎo)致沒有時間去學(xué)習(xí)理論基礎(chǔ)。沒錯，我匯編都還不太懂就開發(fā)了(就更別說我懂操作系統(tǒng)了)，這導(dǎo)致在寫項目的時候遇到很多瓶頸。當(dāng)自己想寫一個程序?qū)崿F(xiàn)一個底層功能的時候發(fā)現(xiàn)特別雞肋。

因此，寫一篇自己遇到的一個底層與單片機(jī)通信的問題。

在這里大家發(fā)現(xiàn)了，單片機(jī)怎么用socket來做呢？沒錯，大家挺聰明的。這個單片機(jī)有一個網(wǎng)卡模塊，所以用到我們所學(xué)的TCP/IP協(xié)議棧中的TCP來實現(xiàn)。

描述自己遇到的一個問題：發(fā)送指令給單片機(jī)，單片機(jī)回復(fù)相應(yīng)數(shù)據(jù)，這是正常的。但是，例如：發(fā)送指令a后，回復(fù)指令a相應(yīng)該返回的數(shù)據(jù)后。再一次向單片機(jī)發(fā)送指令b，發(fā)現(xiàn)回復(fù)的還是a相應(yīng)的數(shù)據(jù)。

第一次嘗試排錯：遇到這個BUG的時候，我首先是想著，是否是自己發(fā)送的數(shù)據(jù)寫錯。發(fā)現(xiàn)沒有！

第二次嘗試排錯：這個時候想得是，既然自己寫的代碼沒有錯。那我應(yīng)該寫一個模擬發(fā)送數(shù)據(jù)和接收數(shù)據(jù)的單元，如下代碼：

//異常直接拋就行了，畢竟測試。記住端口異常，很容易忘記停止當(dāng)前demo就有開啟一個ServerSocket public static void main(String[] args) throws Exception {ServerSocket ss = new ServerSocket(port); //服務(wù)器端口號Socket socket = ss.accept(); //單片機(jī)InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream();byte com1[] = new byte[]{*}; //指令abyte com2[] = new byte[]{*}; //指令bbyte line[] = new byte[n]; //回復(fù)數(shù)據(jù)長度outputStream.write(com1);outputStream.write(com2);while(inputStream.read(line)!=-1){System.out.println(Arrays.toString(line)); //將讀取到指令a的2條返回}}

此刻，納悶了，為什么單片機(jī)會發(fā)送2次回復(fù)數(shù)據(jù)呢？然后開啟串口調(diào)試工具，用TCP模擬器實驗單片機(jī)與模擬器之間的一個回復(fù)情況，并沒有出現(xiàn)回復(fù)2次數(shù)據(jù)的異常！！這下懵逼了，就去百度有沒有清空InputStream流的方法，發(fā)現(xiàn)沒有。這個時候就去看了一下API流的繼承關(guān)系，可以看出：每個流都有對應(yīng)的功能(比如文件流，緩沖流，套接字流)。這下子反應(yīng)過來了，套接字應(yīng)該會提供一個提供流讀取的方法。

于是第三次嘗試：API查找相應(yīng)的方法，發(fā)現(xiàn)一個shutdownInput()方法。功能是：此套接字的輸入流置于“流的末尾”。感覺跟清空的方式差不多，都是講讀寫頭移動到了下次讀取的數(shù)據(jù)開始位置。于是改進(jìn)一下代碼：

//異常直接拋就行了，畢竟測試。記住端口異常，很容易忘記停止當(dāng)前demo就有開啟一個ServerSocket public static void main(String[] args) throws Exception {ServerSocket ss = new ServerSocket(port); //服務(wù)器端口號Socket socket = ss.accept(); //單片機(jī)InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream();byte com1[] = new byte[]{*}; //指令abyte com2[] = new byte[]{*}; //指令bbyte line[] = new byte[n]; //回復(fù)數(shù)據(jù)長度outputStream.write(com1);outputStream.write(com2); //這條指令及時加上了n次，控制臺就只輸出1次數(shù)據(jù)while(inputStream.read(line)!=-1){System.out.println(Arrays.toString(line));socket.shutdownInput();}}

于是，解決了這個問題。

總結(jié)

以上是生活随笔為你收集整理的多线程Socket的InputStream的困扰一天才解决的问题的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。