摘要:具備發(fā)送和接受功能,在進(jìn)行傳輸時(shí),需要明確一個(gè)是發(fā)送端,一個(gè)是接收端。指定發(fā)送端口,不指定系統(tǒng)會(huì)隨機(jī)分配。傳輸兩個(gè)端點(diǎn)的建立連接后會(huì)有一個(gè)傳輸數(shù)據(jù)的通道,這通道稱為流,而且是建立在網(wǎng)絡(luò)基礎(chǔ)上的流,稱之為流。
端口:
物理端口:
邏輯端口:
用于標(biāo)識(shí)進(jìn)程的邏輯地址,不同進(jìn)程的標(biāo)識(shí);有效端口:0~65535,其中0~1024系統(tǒng)使用或保留端口。
java 中ip對(duì)象:InetAddress.
import java.net.*; class IPDemo{ public static void main(String[] args) throws UnknownHostException{ //通過名稱(ip字符串or主機(jī)名)來獲取一個(gè)ip對(duì)象。 InetAddress ip = InetAddress.getByName("www.baidu.com");//java.net.UnknownHostException System.out.println("addr:"+ip.getHostAddress()); System.out.println("name:"+ip.getHostName()); } }
Socket:★★★★,套接字,通信的端點(diǎn)。
就是為網(wǎng)絡(luò)服務(wù)提供的一種機(jī)制,通信的兩端都有Socket,網(wǎng)絡(luò)通信其實(shí)就是Socket間的通信,數(shù)據(jù)在兩個(gè)Socket間通過IO傳輸。
UDP傳輸:
1,只要是網(wǎng)絡(luò)傳輸,必須有socket 。
2,數(shù)據(jù)一定要封裝到數(shù)據(jù)包中,數(shù)據(jù)包中包括目的地址、端口、數(shù)據(jù)等信息。
直接操作udp不可能,對(duì)于java語言應(yīng)該將udp封裝成對(duì)象,易于我們的使用,這個(gè)對(duì)象就是DatagramSocket. 封裝了udp傳輸協(xié)議的socket對(duì)象。
因?yàn)閿?shù)據(jù)包中包含的信息較多,為了操作這些信息方便,也一樣會(huì)將其封裝成對(duì)象。這個(gè)數(shù)據(jù)包對(duì)象就是:DatagramPacket.通過這個(gè)對(duì)象中的方法,就可以獲取到數(shù)據(jù)包中的各種信息。
DatagramSocket具備發(fā)送和接受功能,在進(jìn)行udp傳輸時(shí),需要明確一個(gè)是發(fā)送端,一個(gè)是接收端。
udp的發(fā)送端:
1,建立udp的socket服務(wù),創(chuàng)建對(duì)象時(shí)如果沒有明確端口,系統(tǒng)會(huì)自動(dòng)分配一個(gè)未被使用的端口。
2,明確要發(fā)送的具體數(shù)據(jù)。
3,將數(shù)據(jù)封裝成了數(shù)據(jù)包。
4,用socket服務(wù)的send方法將數(shù)據(jù)包發(fā)送出去。
import java.net.*; class UdpSend{ public static void main(String[] args)throws Exception { //1,建立udp的socket服務(wù)。 DatagramSocket ds = new DatagramSocket(8888);//指定發(fā)送端口,不指定系統(tǒng)會(huì)隨機(jī)分配。 //2,明確要發(fā)送的具體數(shù)據(jù)。 String text = "udp傳輸演示 哥們來了"; byte[] buf = text.getBytes(); //3,將數(shù)據(jù)封裝成了數(shù)據(jù)包。 DatagramPacket dp = new DatagramPacket(buf, buf.length,InetAddress.getByName("10.1.31.127"),10000); //4,用socket服務(wù)的send方法將數(shù)據(jù)包發(fā)送出去。 ds.send(dp); //5,關(guān)閉資源。 ds.close(); } }
udp的接收端:
1,創(chuàng)建udp的socket服務(wù),必須要明確一個(gè)端口,作用在于,只有發(fā)送到這個(gè)端口的數(shù)據(jù)才是這個(gè)接收端可以處理的數(shù)據(jù)。
2,定義數(shù)據(jù)包,用于存儲(chǔ)接收到數(shù)據(jù)。
3,通過socket服務(wù)的接收方法將收到的數(shù)據(jù)存儲(chǔ)到數(shù)據(jù)包中。
4,通過數(shù)據(jù)包的方法獲取數(shù)據(jù)包中的具體數(shù)據(jù)內(nèi)容,比如ip、端口、數(shù)據(jù)等等。
5,關(guān)閉資源。
class UdpRece { public static void main(String[] args) throws Exception{ //1,創(chuàng)建udp的socket服務(wù)。 DatagramSocket ds = new DatagramSocket(10000); //2,定義數(shù)據(jù)包,用于存儲(chǔ)接收到數(shù)據(jù)。先定義字節(jié)數(shù)組,數(shù)據(jù)包會(huì)把數(shù)據(jù)存儲(chǔ)到字節(jié)數(shù)組中。 byte[] buf = new byte[1024]; DatagramPacket dp = new DatagramPacket(buf,buf.length); //3,通過socket服務(wù)的接收方法將收到的數(shù)據(jù)存儲(chǔ)到數(shù)據(jù)包中。 ds.receive(dp);//該方法是阻塞式方法。 //4,通過數(shù)據(jù)包的方法獲取數(shù)據(jù)包中的具體數(shù)據(jù)內(nèi)容,比如ip,端口,數(shù)據(jù)等等。 String ip = dp.getAddress().getHostAddress(); int port = dp.getPort(); String text = new String(dp.getData(),0,dp.getLength());//將字節(jié)數(shù)組中的有效部分轉(zhuǎn)成字符串。 System.out.println(ip+":"+port+"--"+text); //5,關(guān)閉資源。 ds.close(); } }
TCP傳輸:兩個(gè)端點(diǎn)的建立連接后會(huì)有一個(gè)傳輸數(shù)據(jù)的通道,這通道稱為流,而且是建立在網(wǎng)絡(luò)基礎(chǔ)上的流,稱之為socket流。該流中既有讀取,也有寫入。
tcp的兩個(gè)端點(diǎn):一個(gè)是客戶端,一個(gè)是服務(wù)端。
客戶端:對(duì)應(yīng)的對(duì)象,Socket
服務(wù)端:對(duì)應(yīng)的對(duì)象,ServerSocket
TCP客戶端:
1,建立tcp的socket服務(wù),最好明確具體的地址和端口。這個(gè)對(duì)象在創(chuàng)建時(shí),就已經(jīng)可以對(duì)指定ip和端口進(jìn)行連接(三次握手)。
2,如果連接成功,就意味著通道建立了,socket流就已經(jīng)產(chǎn)生了。只要獲取到socket流中的讀取流和寫入流即可,只要通過getInputStream和getOutputStream就可以獲取兩個(gè)流對(duì)象。
3,關(guān)閉資源。
import java.net.*; import java.io.*; //需求:客戶端給服務(wù)器端發(fā)送一個(gè)數(shù)據(jù)。 class TcpClient{ public static void main(String[] args) throws Exception{ Socket s = new Socket("10.1.31.69",10002); OutputStream out = s.getOutputStream();//獲取了socket流中的輸出流對(duì)象。 out.write("tcp演示,哥們又來了!".getBytes()); s.close(); } }
TCP服務(wù)端:
1,創(chuàng)建服務(wù)端socket服務(wù),并監(jiān)聽一個(gè)端口。
2,服務(wù)端為了給客戶端提供服務(wù),獲取客戶端的內(nèi)容,可以通過accept方法獲取連接過來的客戶端對(duì)象。
3,可以通過獲取到的socket對(duì)象中的socket流和具體的客戶端進(jìn)行通訊。
4,如果通訊結(jié)束,關(guān)閉資源。注意:要先關(guān)客戶端,再關(guān)服務(wù)端。
class TcpServer{ public static void main(String[] args) throws Exception{ ServerSocket ss = new ServerSocket(10002);//建立服務(wù)端的socket服務(wù) Socket s = ss.accept();//獲取客戶端對(duì)象 String ip = s.getInetAddress().getHostAddress(); System.out.println(ip+".....connected"); //可以通過獲取到的socket對(duì)象中的socket流和具體的客戶端進(jìn)行通訊。 InputStream in = s.getInputStream();//讀取客戶端的數(shù)據(jù),使用客戶端對(duì)象的socket讀取流 byte[] buf = new byte[1024]; int len = in.read(buf); String text = new String(buf,0,len); System.out.println(text); //如果通訊結(jié)束,關(guān)閉資源。注意:要先關(guān)客戶端,在關(guān)服務(wù)端。 s.close(); ss.close(); } }
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.hztianpu.com/yun/73210.html
摘要:傳播安全上下文或使用,通過增加的屬性,來增加相關(guān)的配置來達(dá)到執(zhí)行隔離策略,控制線程數(shù)或者控制并發(fā)請(qǐng)求數(shù)來達(dá)到熔斷降級(jí)的作用。 SpringCloud(第 015 篇)電影Ribbon微服務(wù)集成Hystrix增加隔離策略控制線程數(shù)或請(qǐng)求數(shù)來達(dá)到熔斷降級(jí)的作用 - 一、大致介紹 1、本章節(jié)介紹關(guān)于Hystrix的2種隔離方式(Thread Pool 和 Semaphores); 2、Thr...
摘要:簡(jiǎn)介參考指南參考指南中文全文搜索引擎顧名思義,是做收索用的,因?yàn)槠胀ǖ乃阉髟跀?shù)據(jù)量小的時(shí)候,能應(yīng)對(duì)自如,但是當(dāng)數(shù)據(jù)量上千萬,或者上億的時(shí)候。 sphinx簡(jiǎn)介參考指南參考指南sphinx API中文 sphinx 全文搜索引擎:顧名思義,是做收索用的,因?yàn)槠胀ǖ乃阉髟跀?shù)據(jù)量小的時(shí)候,能應(yīng)對(duì)自如,但是當(dāng)數(shù)據(jù)量上千萬,或者上億的時(shí)候。純粹的sql搜索顯得緩慢,無力。因而為了提高用戶體驗(yàn),增...
摘要:簡(jiǎn)介是開源的搜索引擎,它支持英文的全文檢索。但是往往我們要求的是中文索引,怎么做呢國人提供了一個(gè)可供企業(yè)使用的,基于的中文全文檢索引擎。 Sphinx 簡(jiǎn)介 Sphinx是開源的搜索引擎,它支持英文的全文檢索。所以如果單獨(dú)搭建Sphinx,你就已經(jīng)可以使用全文索引了。但是往往我們要求的是中文索引,怎么做呢?國人提供了一個(gè)可供企業(yè)使用的,基于Sphinx的中文全文檢索引擎。也就是說Cor...
摘要:簡(jiǎn)介是開源的搜索引擎,它支持英文的全文檢索。但是往往我們要求的是中文索引,怎么做呢國人提供了一個(gè)可供企業(yè)使用的,基于的中文全文檢索引擎。 Sphinx 簡(jiǎn)介 Sphinx是開源的搜索引擎,它支持英文的全文檢索。所以如果單獨(dú)搭建Sphinx,你就已經(jīng)可以使用全文索引了。但是往往我們要求的是中文索引,怎么做呢?國人提供了一個(gè)可供企業(yè)使用的,基于Sphinx的中文全文檢索引擎。也就是說Cor...
閱讀 2240·2021-11-24 09:39
閱讀 1760·2021-10-11 10:59
閱讀 2662·2021-09-24 10:28
閱讀 3540·2021-09-08 09:45
閱讀 1432·2021-09-07 10:06
閱讀 1830·2019-08-30 15:53
閱讀 2301·2019-08-30 15:53
閱讀 1568·2019-08-30 15:53