libquic-client-server-example.zip资源-CSDN文库

共2000个文件

h：522个

cc：375个

o：357个

quic

udp

需积分: 13 199 浏览量 2019-07-11 15:01:31 上传评论 4 收藏 36.53MB ZIP 举报

资源推荐

资源详情

资源评论

收起资源包目录

libquic-client-server-example.zip （2000个子文件）

server_run_10_._quic_perf_server_delay=12_loss=2.5_bw=10 581B

server_run_22_._quic_perf_server_delay=12_loss=2.5_bw=10 581B

server_run_18_._quic_perf_server_delay=50_loss=2.5_bw=10 580B

server_run_0_._quic_perf_server_delay=12_loss=7.5_bw=10 578B

server_run_14_._quic_perf_server_delay=50_loss=7.5_bw=10 578B

server_run_23_._quic_perf_server_delay=12_loss=7.5_bw=10 577B

server_run_12_._quic_perf_server_delay=12_loss=7.5_bw=10 577B

server_run_16_._quic_perf_server_delay=250_loss=7.5_bw=10 577B

server_run_20_._quic_perf_server_delay=50_loss=7.5_bw=10 577B

server_run_23_._quic_perf_server_delay=250_loss=7.5_bw=10 576B

server_run_1_._quic_perf_server_delay=50_loss=7.5_bw=10 576B

server_run_6_._quic_perf_server_delay=250_loss=7.5_bw=10 576B

server_run_6_._quic_perf_server_delay=12_loss=7.5_bw=10 576B

server_run_12_._quic_perf_server_delay=250_loss=7.5_bw=10 557B

server_run_18_._tcp_perf_server_delay=250_loss=7.5_bw=10 350B

server_run_20_._tcp_perf_server_delay=250_loss=7.5_bw=10 335B

server_run_6_._tcp_perf_server_delay=250_loss=7.5_bw=10 327B

server_run_25_._tcp_perf_server_delay=12_loss=7.5_bw=10 325B

server_run_21_._tcp_perf_server_delay=250_loss=7.5_bw=10 323B

server_run_15_._tcp_perf_server_delay=250_loss=2.5_bw=10 321B

server_run_9_._tcp_perf_server_delay=250_loss=2.5_bw=10 321B

server_run_5_._tcp_perf_server_delay=12_loss=7.5_bw=10 316B

server_run_13_._tcp_perf_server_delay=50_loss=7.5_bw=10 315B

server_run_11_._tcp_perf_server_delay=250_loss=7.5_bw=10 315B

server_run_24_._tcp_perf_server_delay=250_loss=7.5_bw=10 315B

server_run_10_._tcp_perf_server_delay=12_loss=7.5_bw=10 315B

server_run_14_._tcp_perf_server_delay=250_loss=7.5_bw=10 314B

server_run_19_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_6_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_25_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_4_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_24_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_10_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_24_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_25_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_2_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_9_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_18_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_10_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_23_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_2_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_13_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_0_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_23_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_14_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_21_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_3_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_14_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_0_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_6_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_11_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_22_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_22_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_8_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_7_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_23_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_12_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_24_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_8_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_10_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_5_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_0_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_7_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_1_._tcp_perf_server_delay=12_loss=2.5_bw=10 311B

server_run_2_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_16_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_19_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_12_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_4_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_21_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_7_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_1_._tcp_perf_server_delay=50_loss=2.5_bw=10 311B

server_run_18_._tcp_perf_server_delay=250_loss=2.5_bw=10 311B

server_run_4_._tcp_perf_server_delay=12_loss=7.5_bw=10 309B

server_run_22_._tcp_perf_server_delay=250_loss=7.5_bw=10 309B

server_run_26_._tcp_perf_server_delay=12_loss=7.5_bw=10 307B

server_run_7_._tcp_perf_server_delay=50_loss=7.5_bw=10 307B

server_run_11_._tcp_perf_server_delay=50_loss=7.5_bw=10 306B

server_run_7_._tcp_perf_server_delay=250_loss=7.5_bw=10 305B

server_run_17_._tcp_perf_server_delay=12_loss=7.5_bw=10 304B

server_run_11_._tcp_perf_server_delay=12_loss=7.5_bw=10 303B

server_run_3_._tcp_perf_server_delay=250_loss=7.5_bw=10 303B

server_run_17_._tcp_perf_server_delay=50_loss=7.5_bw=10 302B

server_run_6_._tcp_perf_server_delay=50_loss=7.5_bw=10 302B

server_run_2_._tcp_perf_server_delay=250_loss=7.5_bw=10 302B

server_run_2_._tcp_perf_server_delay=50_loss=7.5_bw=10 302B

server_run_12_._tcp_perf_server_delay=250_loss=7.5_bw=10 302B

server_run_21_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_15_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_17_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_18_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_15_._tcp_perf_server_delay=50_loss=2.5_bw=10 301B

server_run_5_._tcp_perf_server_delay=250_loss=2.5_bw=10 301B

server_run_5_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_19_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_8_._tcp_perf_server_delay=12_loss=7.5_bw=10 301B

server_run_26_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_16_._tcp_perf_server_delay=12_loss=2.5_bw=10 301B

server_run_17_._tcp_perf_server_delay=250_loss=2.5_bw=10 301B

server_run_26_._tcp_perf_server_delay=50_loss=2.5_bw=10 301B

共 2000 条

WriteyourownQUICapplication

TowriteanapplicationthatusesQUIC,youwillhavetosubclasssomeoftheQUICclassesaswellascreatingsomenew

classes.ThisdocumenttriestoprovideanintroductiononhowtouseQUICinyourownapplication,byusingtheQUIC

performancetestclientandserverasexample.

Intheexample,epollisusedtogetnotifiedonavailableincomingpacketsorwhennewdatacanbewrittentothe

connection.ThisisbecauseperformancetestclientandserverarebasedontheexampleintheChromiumprojectinthe

net/tools/quicfolder.ItisnotnecessarytouseepollwhenwritinganapplicationthatusesQUIC.

Newclasses

TofacilitatethehandlingofalltheQUICclasses,youwillprobablywanttocreateclassesthatwraptheclientandthe

serverfunctionality.Also,youneedtocreateatleasttheQuicPacketWriterhelperclass.

QUICclientapplication

Youwillneedaclassthatwillcreateasession(e.g.QuicClient),connectionandapacketwriterandconnectsallthose

classes.Itmustalsoreadthenetworkpackagesanddispatchesthemtothesession.

CreatingaQUICclientanbedividedintoseveralsteps.FirstyouhavetodeterminetheIPaddresstoconnectto,theserver

idandtheQUICversionsyouwanttouse.Theserverididentifiestheservertoconnecttoandconsistsofascheme(http

orhttps),ahostandaport.Theexampleclientreceivesthoseintheconstructorandstorestheminhisattributes

(includingtheepollserver).

QuicClient::QuicClient(IPEndPointserver_address,

constQuicServerId&server_id,

constQuicVersionVector&supported_versions,

EpollServer*epoll_server)

:server_address_(server_address),

server_id_(server_id),

epoll_server_(epoll_server),

...

supported_versions_(supported_versions){

}

ThenyouneedtoopentheUDPsocketanregisteritwiththeepollserver.

boolQuicClient::Initialize(){

...

if(!CreateUDPSocket()){

returnfalse;

}

epoll_server_->RegisterFD(fd_,this,kEpollFlags);

initialized_=true;

returntrue;

}

WiththeUDPsocketopen,wecanopentheQUICconnection.WeneedtofirstcreateaQuickPacketWriterandapacket

writerfactoryandinitializeanewQuicConnectionwithit.ThenwecancreateanewQuicClientSessionusingthe

connection.Thesessionmustthenbeinitializedandfinallywecanstartthecryptohandshakeandwaitforittofinish.

boolQuicClient::Connect(){

QuicPacketWriter*writer=newQuicDefaultPacketWriter(fd_);

DummyPacketWriterFactoryfactory(writer);

session_.reset(newQuicClientSession(

config_,

newQuicConnection((QuicConnectionId)QuicRandom::GetInstance()->RandUint64(),

server_address_,helper_.get(),

factory,

/*owns_writer=*/false,Perspective::IS_CLIENT,

server_id_.is_https(),supported_versions_)));

//Reset|writer_|after|session_|sothattheoldwriteroutlivestheold

//session.

if(writer_.get()!=writer){

writer_.reset(writer);

}

//Initializethesession

session_->InitializeSession(server_id_,&crypto_config_);

//Startthecryptohandshake

session_->CryptoConnect();

//Waitforthecryptohandshaketofinish

while(!session_->IsEncryptionEstablished()&&

session_->connection()->connected()){

epoll_server_->WaitForEventsAndExecuteCallbacks();

}

returnsession_->connection()->connected();

}

Forthistowork,theclientmustalsoreadtheUDPpacketswhenitisnotifiedbytheepollserver.WhenanQUICpacketis

readsuccessfullyithastobedispatchedtotheQuicConnectionusingtheProcessUdpPacketmethod.

voidQuicClient::OnEvent(intfd,EpollEvent*event){

if(event->in_events&EPOLLIN){

while(connected()&&ReadAndProcessPacket()){

}

}

...

}

boolQuicClient::ReadAndProcessPacket(){

//Allocatesomeextraspacesowecansendanerroriftheservergoesover

//thelimit.

charbuf[2*kMaxPacketSize];

IPEndPointserver_address;

IPAddressNumberclient_ip;

//ReadoneUDPpacketandtheIPaddresses

intbytes_read=QuicSocketUtils::ReadPacket(

fd_,buf,arraysize(buf),

overflow_supported_?&packets_dropped_:nullptr,&client_ip,

&server_address);

if(bytes_read<0){

returnfalse;

}

//EachUDPpacketcontainsoneencryptedQUICpacket,

//soweinitializeaninstanceofQuicEncryptedPacketwiththecontentoftheUDPpacket

QuicEncryptedPacketpacket(buf,bytes_read,false);

IPEndPointclient_address(client_ip,client_address_.port());

//PasstheencryptedQUICpackettotheQuicConnection

session_->connection()->ProcessUdpPacket(client_address,server_address,packet);

returntrue;

}

Tosendorreceivedata,aQUICstreamhastobecreated.Thenewstreamhastobecreatedinthesession,asthe

protectedActivateStreammethodhastobecalledwiththenewstream.

QuicClientStream*QuicClient::CreateClientStream(){

if(!connected()){

returnnullptr;

}

returnsession_->CreateClientStream();

}

QuicClientStream*QuicClientSession::CreateClientStream(){

QuicDataStream*stream=newQuicClientStream(GetNextStreamId(),this);

ActivateStream(stream);

return(QuicClientStream*)stream;

}

DatacanthenbewrittentothestreamusingtheWriteOrBufferDatamethod.

QUICserverapplication

Theserversideismorecomplex,asithastohandlemultiplesessionswithmultipleconnections.Therefore,theserver

class(QuicServer)usuallyusesadispatcherclass(QuicDispatcher).Itwillhandlethereadingofnetworkpacketssimilarto

theclient(usingepoll)butinsteadofhandingittotheconnectiondirectlyitwillhandittothedispatcher.

FirstyouneedaQuicConfigthatwilllatebepassedtothesessions,aQuicCryptoServerConfigthatmustbeinitializedwith

adefaultconfigandavectorofQUICversionsthatshouldbesupported.

QuicServer::QuicServer(constQuicConfig&config,

constQuicVersionVector&supported_versions)

:...,

config_(config),

crypto_config_(kSourceAddressTokenSecret,QuicRandom::GetInstance()),

supported_versions_(supported_versions){

...

QuicEpollClockclock(&epoll_server_);

scoped_ptr<CryptoHandshakeMessage>scfg(

crypto_config_.AddDefaultConfig(

QuicRandom::GetInstance(),&clock,

QuicCryptoServerConfig::ConfigOptions()));

}

ThenyouhavetostarttolistenonaUPDsocketandbindtotherequestedaddress.Withthesocketyoucantheninitialize

anewdispatcher.

boolQuicServer::Listen(constIPEndPoint&address){

port_=address.port();

intaddress_family=address.GetSockAddrFamily();

fd_=socket(address_family,SOCK_DGRAM|SOCK_NONBLOCK,IPPROTO_UDP);

...

sockaddr_storageraw_addr;

socklen_traw_addr_len=sizeof(raw_addr);

address.ToSockAddr(reinterpret_cast<sockaddr*>(&raw_addr),&raw_addr_len);

rc=bind(fd_,reinterpret_cast<constsockaddr*>(&raw_addr),sizeof(raw_addr));

评论收藏

内容反馈

weixin_37086626

粉丝: 1
资源: 1

libquic-client-server-example.zip

谷歌QUIC协议源代码及示例

cpp-quicprotquicgoquiclibquic源码中文注释分析

lsquic:LiteSpeed QUIC和HTTP3库

北航 离散数学 模拟题

quic、prot_quic、goquic、libquic源码中文注释分析

androidpn-client-0.5.0.zip和androidpn-server-0.5.0-bin.zip

instantclient.zip

最新 instantclient-basic-linux.x64-11.2.0.4.0

rocketmq-client-3.6.2.Final-API文档-中文版.zip

jetty-client-9.4.43.v20210629-API文档-中文版.zip

nacos-client-2.0.4.RELEASE-API文档-中文版.zip

oracle-instantclient11.2.x86-64.rpm.zip

hadoop最新版本3.1.1全量jar包

hadoop-mapreduce-client-core-2.5.1-API文档-中文版.zip

rocketmq-client-3.6.2.Final-API文档-中英对照版.zip

Instant Client 11.2.0.4.0(Linux)

clickhouse-22.2.2.1-2.x86_64.rpm离线安装包

oracle-instantclient11.2-sqlplus-11.2.0.4.0-1.x86_64.zip

oracle-instantclient19.10-sqlplus-base-devel(x86 arm架构)

instantclient-basic-linux.x64-21.1.0.0.0.zip

wildfly-client-config-1.0.1.Final-API文档-中文版.zip

instantclient-basic-windows.x64-11.2.0.4.0.zip

softether-client-v4.34-9745-beta-2020.04.05-windows-x86_x64-intel.zip

instantclient-basic-windows.x64-12.1.0.2.0.zip

上海一网通办 社保插件：FileOperatorWSInstaller.zip

华为ensp模拟器安装包

天邑su计算工具-魔尊版

SecureCRT 9.2.3 Build 2829(Windows X64) 官方原版 + ZWT官方

小旋风蜘蛛池，小旋风蜘蛛池程序pro2.8版

最新资源

北航离散数学模拟题

上海一网通办社保插件：FileOperatorWSInstaller.zip