色婷婷AⅤ一区二区三区|亚洲精品第一国产综合亚AV|久久精品官方网视频|日本28视频香蕉

          新聞中心

          EEPW首頁(yè) > 嵌入式系統(tǒng) > 設(shè)計(jì)應(yīng)用 > 基于socket的Java網(wǎng)絡(luò)編程集粹

          基于socket的Java網(wǎng)絡(luò)編程集粹

          作者: 時(shí)間:2012-05-04 來(lái)源:網(wǎng)絡(luò) 收藏

          事實(shí)上簡(jiǎn)單的理解就是兩臺(tái)計(jì)算機(jī)相互通訊數(shù)據(jù)而已,對(duì)于程序員而言,去掌握一種編程接口并使用一種編程模型相對(duì)就會(huì)顯得簡(jiǎn)單的多了,SDK提供一些相對(duì)簡(jiǎn)單的Api來(lái)完成這些工作。Socket就是其中之一,對(duì)于而言,這些Api存在與java.net這個(gè)包里面,因此只要導(dǎo)入這個(gè)包就可以準(zhǔn)備了。

          本文引用地址:http://cafeforensic.com/article/149139.htm

          的基本模型就是客戶機(jī)到服務(wù)器模型,簡(jiǎn)單的說(shuō)就是兩個(gè)進(jìn)程之間相互通訊,然后其中一個(gè)必須提供一個(gè)固定的位置,而另一個(gè)則只需要知道這個(gè)固定的位置。并去建立兩者之間的聯(lián)系,然后完成數(shù)據(jù)的通訊就可以了,這里提供固定位置的通常稱為服務(wù)器,而建立聯(lián)系的通常叫做客戶端,這個(gè)簡(jiǎn)單的模型,就可以進(jìn)入網(wǎng)絡(luò)編程啦。

          對(duì)這個(gè)模型的支持有很多種Api,而這里我只想介紹有關(guān)Socket的編程接口,對(duì)于Java而言已經(jīng)簡(jiǎn)化了Socket的編程接口。首先我們來(lái)討論有關(guān)提供固定位置的服務(wù)方是如何建立的。Java提供了ServerSocket來(lái)對(duì)其進(jìn)行支持.事實(shí)上當(dāng)你創(chuàng)建該類(lèi)的一個(gè)實(shí)力對(duì)象并提供一個(gè)端口資源你就建立了一個(gè)固定位置可以讓其他計(jì)算機(jī)來(lái)訪問(wèn)你,ServerSocketserver=newServerSocket(6789);這里稍微要注意的是端口的分配必須是唯一的。因?yàn)槎丝谑菫榱宋ㄒ粯?biāo)識(shí)每臺(tái)計(jì)算機(jī)唯一服務(wù)的,另外端口號(hào)是從0~65535之間的,前1024個(gè)端口已經(jīng)被Tcp/Ip作為保留端口,因此你所分配的端口只能是1024個(gè)之后的。好了,我們有了固定位置.現(xiàn)在所需要的就是一根連接線了.該連接線由客戶方首先提出要求。因此Java同樣提供了一個(gè)Socket對(duì)象來(lái)對(duì)其進(jìn)行支持,只要客戶方創(chuàng)建一個(gè)Socket的實(shí)例對(duì)象進(jìn)行支持就可以了。Socketclient=newSocket(InetAddress.getLocalHost(),5678);客戶機(jī)必須知道有關(guān)服務(wù)器的IP地址,對(duì)于著一點(diǎn)Java也提供了一個(gè)相關(guān)的類(lèi)InetAddress該對(duì)象的實(shí)例必須通過(guò)它的靜態(tài)方法來(lái)提供,它的靜態(tài)方法主要提供了得到本機(jī)IP和通過(guò)名字或IP直接得到InetAddress的方法。

          上面的方法基本可以建立一條連線讓兩臺(tái)計(jì)算機(jī)相互交流了,可是數(shù)據(jù)是如何傳輸?shù)哪??事?shí)上I/O操作總是和網(wǎng)絡(luò)編程息息相關(guān)的。因?yàn)榈讓拥木W(wǎng)絡(luò)是繼續(xù)數(shù)據(jù)的,除非遠(yuǎn)程調(diào)用,處理問(wèn)題的核心在執(zhí)行上,否則數(shù)據(jù)的交互還是依賴于IO操作的,所以你也必須導(dǎo)入java.io這個(gè)包.java的IO操作也不復(fù)雜,它提供了針對(duì)于字節(jié)流和Unicode的讀者和寫(xiě)者,然后也提供了一個(gè)緩沖用于數(shù)據(jù)的讀寫(xiě)。

          BufferedReaderin=newBufferedReader(newInputStreamReader(server.getInputStream()));

          PrintWriterout=newPrintWriter(server.getOutputStream());

          上面兩句就是建立緩沖并把原始的字節(jié)流轉(zhuǎn)變?yōu)閁nicode可以操作,而原始的字節(jié)流來(lái)源于Socket的兩個(gè)方法,getInputStream()和getOutputStream()方,分別用來(lái)得到輸入和輸出,那么現(xiàn)在有了基本的模型和基本的操作工具,我們可以做一個(gè)簡(jiǎn)單的Socket例程了。

          服務(wù)方:

          importjava.io.*;

          importjava.net.*;

          publicclassMyServer{

          publicstaticvoidmain(String[]args)throwsIOException{

          ServerSocketserver=newServerSocket(5678);

          Socketclient=server.accept();

          BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

          PrintWriterout=newPrintWriter(client.getOutputStream());

          while(true){

          Stringstr=in.readLine();

          System.out.println(str);

          out.println(hasreceive....);

          out.flush();

          if(str.equals(end))

          break;

          }

          client.close();

          }

          }

          這個(gè)程序的主要目的在于服務(wù)器不斷接收客戶機(jī)所寫(xiě)入的信息只到,客戶機(jī)發(fā)送End字符串就退出程序,并且服務(wù)器也會(huì)做出Receive為回應(yīng),告知客戶機(jī)已接收到消息。

          客戶機(jī)代碼:

          importjava.net.*;

          importjava.io.*;

          publicclassClient{

          staticSocketserver;

          publicstaticvoidmain(String[]args)throwsException{

          server=newSocket(InetAddress.getLocalHost(),5678);

          BufferedReaderin=newBufferedReader(newInputStreamReader(server.getInputStream()));

          PrintWriterout=newPrintWriter(server.getOutputStream());

          BufferedReaderwt=newBufferedReader(newInputStreamReader(System.in));

          while(true){

          Stringstr=wt.readLine();

          out.println(str);

          out.flush();

          if(str.equals(end)){

          break;

          }

          System.out.println(in.readLine());

          }

          server.close();

          }

          }

          客戶機(jī)代碼則是接受客戶鍵盤(pán)輸入,并把該信息輸出,然后輸出End用來(lái)做退出標(biāo)識(shí)。

          這個(gè)程序只是簡(jiǎn)單的兩臺(tái)計(jì)算機(jī)之間的通訊,如果是多個(gè)客戶同時(shí)訪問(wèn)一個(gè)服務(wù)器呢?你可以試著再運(yùn)行一個(gè)客戶端,結(jié)果是會(huì)拋出異常的。那么多個(gè)客戶端如何實(shí)現(xiàn)呢?

          其實(shí),簡(jiǎn)單的分析一下,就可以看出客戶和服務(wù)通訊的主要通道就是Socket本身,而服務(wù)器通過(guò)accept方法就是同意和客戶建立通訊.這樣當(dāng)客戶建立Socket的同時(shí)。服務(wù)器也會(huì)使用這一根連線來(lái)先后通訊,那么既然如此只要我們存在多條連線就可以了。那么我們的程序可以變?yōu)槿缦?

          服務(wù)器:

          importjava.io.*;

          importjava.net.*;

          publicclassMyServer{

          publicstaticvoidmain(String[]args)throwsIOException{

          ServerSocketserver=newServerSocket(5678);

          while(true){

          Socketclient=server.accept();

          BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

          PrintWriterout=newPrintWriter(client.getOutputStream());

          while(true){

          Stringstr=in.readLine();

          System.out.println(str);

          out.println(hasreceive....);

          out.flush();


          上一頁(yè) 1 2 下一頁(yè)

          評(píng)論


          相關(guān)推薦

          技術(shù)專(zhuān)區(qū)

          關(guān)閉