• <tr id="yyy80"></tr>
  • <sup id="yyy80"></sup>
  • <tfoot id="yyy80"><noscript id="yyy80"></noscript></tfoot>
  • 99热精品在线国产_美女午夜性视频免费_国产精品国产高清国产av_av欧美777_自拍偷自拍亚洲精品老妇_亚洲熟女精品中文字幕_www日本黄色视频网_国产精品野战在线观看 ?

    基于Flink的電子疾病檔案數(shù)據(jù)處理模型設(shè)計(jì)與實(shí)現(xiàn)

    2023-10-25 10:46:50季英凱
    無(wú)線互聯(lián)科技 2023年16期
    關(guān)鍵詞:數(shù)據(jù)流數(shù)據(jù)處理算子

    劉 瀟,季英凱

    (江蘇省疾病預(yù)防控制中心 公共衛(wèi)生信息所,江蘇 南京 210009)

    0 引言

    隨著疾控信息化工作的不斷深入,疾控的傳染病、公共衛(wèi)生突發(fā)事件、慢性病、免疫規(guī)劃、精神衛(wèi)生等業(yè)務(wù)條線的信息系統(tǒng)在不斷地建立與完善,由于業(yè)務(wù)系統(tǒng)在建設(shè)之初缺乏總體規(guī)劃,各自為政,各類(lèi)數(shù)據(jù)難以支撐有效的業(yè)務(wù)協(xié)同服務(wù),造成信息孤島[1]。在當(dāng)前各級(jí)疾控業(yè)務(wù)協(xié)作日漸緊密、內(nèi)部一體化集成日漸成熟的大背景下[2],為了有效地對(duì)業(yè)務(wù)數(shù)據(jù)進(jìn)行匯聚與利用,中國(guó)疾病預(yù)防控制中心制定的《疾病預(yù)防控制信息系統(tǒng)建設(shè)指導(dǎo)方案(2018年版)》要求,以國(guó)家和省統(tǒng)籌區(qū)域兩級(jí)建設(shè)為重點(diǎn),依托全員人口信息庫(kù)等基礎(chǔ)設(shè)施,構(gòu)建實(shí)時(shí)共享的動(dòng)態(tài)電子疾病檔案(electronic diseases records,EDR)[3-4],以個(gè)人健康為核心,貫穿整個(gè)生命周期,以出生和死亡2個(gè)重要的生命節(jié)點(diǎn)為開(kāi)始和結(jié)束,全程記錄疾病發(fā)生、發(fā)展及轉(zhuǎn)歸的監(jiān)測(cè)信息,形成以個(gè)人基礎(chǔ)信息(人口學(xué)信息、出生登記、死亡登記)為基礎(chǔ),包含體檢篩查史、疾病診斷史、檢驗(yàn)檢測(cè)史、治療隨訪史、流行病學(xué)史和預(yù)防接種史等內(nèi)容的主題數(shù)據(jù)目錄[5],以支撐疾控各類(lèi)業(yè)務(wù)的交互協(xié)同,為政府決策分析提供有效的支持。如何利用現(xiàn)有的業(yè)務(wù)系統(tǒng)實(shí)現(xiàn)各類(lèi)業(yè)務(wù)數(shù)據(jù)的匯集,以形成實(shí)時(shí)共享的電子疾病檔案成了疾控信息化建設(shè)面臨的一個(gè)新的問(wèn)題。

    當(dāng)前,疾控的各類(lèi)業(yè)務(wù)系統(tǒng)于不同的時(shí)間由不同的開(kāi)發(fā)公司建設(shè),所采用的技術(shù)架構(gòu)、業(yè)務(wù)流程以及業(yè)務(wù)數(shù)據(jù)的格式各不相同,各業(yè)務(wù)數(shù)據(jù)與電子疾病檔案的數(shù)據(jù)標(biāo)準(zhǔn)均存在一定程度的差異。基于這些問(wèn)題,為了實(shí)現(xiàn)電子疾病檔案所需數(shù)據(jù)的抽取并進(jìn)行有效的匯集,本文基于流式計(jì)算框架Flink建立一個(gè)電子疾病檔案數(shù)據(jù)的實(shí)時(shí)處理模型,使用消息中間件Kafka實(shí)現(xiàn)各類(lèi)業(yè)務(wù)主題數(shù)據(jù)的發(fā)布與訂閱,使用Flink實(shí)現(xiàn)各類(lèi)業(yè)務(wù)數(shù)據(jù)按電子疾病檔案主題目錄數(shù)據(jù)的實(shí)時(shí)處理,使用HBase作為數(shù)據(jù)庫(kù)實(shí)現(xiàn)電子疾病檔案數(shù)據(jù)的匯集與有效關(guān)聯(lián),通過(guò)實(shí)驗(yàn)證明該模型的可行性與高效性。

    1 技術(shù)簡(jiǎn)介

    1.1 Flink介紹

    Apache Flink是一個(gè)低延遲、高吞吐的分布式計(jì)算框架[6],可對(duì)無(wú)界數(shù)據(jù)流與有界數(shù)據(jù)流進(jìn)行計(jì)算[7-8],相對(duì)于以MapReduce為代表的批處理計(jì)算框架、以Spark Streaming為代表的微批處理方案、以Storm為代表的流處理計(jì)算框架,Flink提供了DataStream API與DataSet API分別對(duì)流處理與批處理予以支持,其將批數(shù)據(jù)看成是有界的流數(shù)據(jù),本質(zhì)上還是進(jìn)行數(shù)據(jù)流的處理[9]。這種批流一體的特性使得Flink在執(zhí)行計(jì)算時(shí)具有極高的靈活性與極低的延遲性。

    Flink可在單獨(dú)集群中運(yùn)行,也可以在Yarn、Mesos等資源調(diào)度與管理框架上運(yùn)行[10]。一個(gè)Flink集群總是包含一個(gè)JobManager以及一個(gè)或多個(gè)TaskManager[11]。JobManager負(fù)責(zé)處理Job提交、Job監(jiān)控以及資源管理;TaskManager運(yùn)行worker進(jìn)程,負(fù)責(zé)實(shí)際任務(wù)Tasks的執(zhí)行。這些任務(wù)共同組成了一個(gè)Job。Flink應(yīng)用程序中的任務(wù)由用戶定義的算子轉(zhuǎn)換而來(lái)的流式Dataflows所組成,以構(gòu)成有向無(wú)環(huán)圖(DAG)以對(duì)數(shù)據(jù)流行處理,如圖1所示。Flink的Dataflows由Source、Transformation、Sink3大部分組成。Source可從數(shù)據(jù)源不斷獲取數(shù)據(jù),Transformation通過(guò)Flink提供或用戶自定義的各類(lèi)算子靈活組合將獲取的數(shù)據(jù)流進(jìn)行各種業(yè)務(wù)邏輯的處理,最終由Sink輸出到外部。Source與Sink階段都提供了包括Kafka、 ElasticSearch、MySQL、InfluxDB等多種數(shù)據(jù)庫(kù)引擎的專(zhuān)用算子用以獲取或輸出數(shù)據(jù),使用十分方便。

    圖1 Flink Dataflow

    Flink的開(kāi)發(fā)同時(shí)支持Java和Scala語(yǔ)言,提供了4個(gè)不同抽象層級(jí)的API,提供給用戶以開(kāi)發(fā)應(yīng)用程序。第一層的ProcessFunction API是其他三層的調(diào)用與封裝的基礎(chǔ)。Flink在這個(gè)API上實(shí)現(xiàn)最基礎(chǔ)的流式處理能力。在該層用戶可以進(jìn)行有狀態(tài)編程,實(shí)現(xiàn)復(fù)雜的時(shí)間語(yǔ)義處理。第二層是Core APIs。該層包含應(yīng)用于無(wú)界或有界數(shù)據(jù)流的DataStream API和應(yīng)用于有界數(shù)據(jù)集的DataSet API,提供各種形式的用戶自定義轉(zhuǎn)換(transformations)、聯(lián)接(joins)、聚合(aggregations)、窗口(windows)和狀態(tài)(state)等操作。第三層是Table API。該層通過(guò)定義數(shù)據(jù)的schema提供類(lèi)似于關(guān)系模型中的操作,比如 select、join、group-by 和 aggregate 等。第四層是SQL API。這層在語(yǔ)義和程序表達(dá)式上都類(lèi)似于Table API,但其程序都是通過(guò)SQL表達(dá)式的形式來(lái)實(shí)現(xiàn)。

    1.2 Kafka介紹

    Kafka是一個(gè)分布式的消息發(fā)布-訂閱模式[12]的中間件系統(tǒng)。Kafka在主題中保存消息的信息,生產(chǎn)者向主題寫(xiě)入數(shù)據(jù),消費(fèi)者從主題讀取數(shù)據(jù),從而實(shí)現(xiàn)數(shù)據(jù)的傳遞。這種隱式調(diào)用的風(fēng)格使生產(chǎn)者與消費(fèi)者相互解耦,使其可以相互獨(dú)立的變化。

    高性能、高吞吐、低延時(shí)是Kafka的顯著的特性,雖然Kafka的消息保存在磁盤(pán)上,但由于采用了順序?qū)懭搿MFiles(Memory Mapped Files)、Zero Copy、批量壓縮等技術(shù)優(yōu)化了讀寫(xiě)性能[13],使其可以突破傳統(tǒng)的數(shù)據(jù)庫(kù)、消息隊(duì)列等數(shù)據(jù)引擎所受限的磁盤(pán)IO瓶頸。因此即使是部署在普通的單機(jī)服務(wù)器上,Kafka也能輕松支持每秒百萬(wàn)級(jí)的寫(xiě)入請(qǐng)求[14],讀寫(xiě)速度超過(guò)大部分的消息中間件,這種特性使得Kafka在海量數(shù)據(jù)場(chǎng)景中應(yīng)用廣泛。

    2 設(shè)計(jì)與實(shí)現(xiàn)

    2.1 架構(gòu)設(shè)計(jì)

    本文設(shè)計(jì)的電子疾病檔案數(shù)據(jù)處理模型采用Kafka+Flink+HBase建立實(shí)時(shí)數(shù)據(jù)流的處理框架。在Kafka中建立主題Topic,疾控的各個(gè)業(yè)務(wù)系統(tǒng)作為生產(chǎn)者按規(guī)定的格式向主題中生產(chǎn)數(shù)據(jù),通過(guò)這種模式將數(shù)據(jù)生產(chǎn)的任務(wù)交給各個(gè)數(shù)據(jù)系統(tǒng)的開(kāi)發(fā)維護(hù)單位,避免直接操作多個(gè)業(yè)務(wù)系統(tǒng)帶來(lái)不可預(yù)知的風(fēng)險(xiǎn)。Flink程序作為消費(fèi)者去Kafka的主題中獲取數(shù)據(jù)并發(fā)送至下游進(jìn)行數(shù)據(jù)類(lèi)目的識(shí)別、分流以及格式轉(zhuǎn)換等業(yè)務(wù)邏輯的處理操作,最終寫(xiě)入Hbase進(jìn)行數(shù)據(jù)的持久化,并通過(guò)HBase表結(jié)構(gòu)的設(shè)計(jì)實(shí)現(xiàn)以個(gè)人信息為基礎(chǔ),各類(lèi)電子疾病檔案主題目錄數(shù)據(jù)的關(guān)聯(lián)。模型架構(gòu)設(shè)計(jì)如圖2所示。

    圖2 模型架構(gòu)

    2.2 模型設(shè)計(jì)與實(shí)現(xiàn)

    2.2.1 消息中間件設(shè)計(jì)

    由于疾控業(yè)務(wù)系統(tǒng)多,電子疾病檔案所包含的數(shù)據(jù)類(lèi)目繁雜且數(shù)據(jù)格式各異,而兒童預(yù)防接種等業(yè)務(wù)系統(tǒng)在某些時(shí)間段內(nèi)產(chǎn)生的實(shí)時(shí)數(shù)據(jù)量很大,使用消息隊(duì)列Kafka作為中間件來(lái)接收各類(lèi)業(yè)務(wù)系統(tǒng)產(chǎn)生的數(shù)據(jù)是一個(gè)很適合的選擇。一方面,利用Kafka出色的性能提高業(yè)務(wù)數(shù)據(jù)寫(xiě)入的響應(yīng)時(shí)間,保證穩(wěn)定性;另一方面,使得各個(gè)業(yè)務(wù)系統(tǒng)與Flink數(shù)據(jù)處理程序解耦。數(shù)據(jù)生產(chǎn)層的業(yè)務(wù)系統(tǒng)既可以將業(yè)務(wù)系統(tǒng)完成審批后的實(shí)時(shí)數(shù)據(jù)流接入消息隊(duì)列,也可以批量對(duì)歷史數(shù)據(jù)進(jìn)行處理,業(yè)務(wù)數(shù)據(jù)生產(chǎn)者與消費(fèi)程序各自獨(dú)立運(yùn)行。

    數(shù)據(jù)生產(chǎn)層的各個(gè)業(yè)務(wù)系統(tǒng)按約定的格式將電子疾病檔案系統(tǒng)需要的數(shù)據(jù)寫(xiě)入Kafka的主題中,為了使下游的消費(fèi)者Flink程序能正確解析與處理,數(shù)據(jù)結(jié)構(gòu)可以分為3個(gè)部分:第一部分代表該數(shù)據(jù)所屬的電子疾病檔案主題目錄;第二部分代表該條數(shù)據(jù)的操作類(lèi)型(新增、修改或刪除);第三部分為業(yè)務(wù)數(shù)據(jù)所包含的具體內(nèi)容,各個(gè)數(shù)據(jù)項(xiàng)統(tǒng)一使用制表符分隔(見(jiàn)表1)。

    表1 生產(chǎn)者數(shù)據(jù)結(jié)構(gòu)

    2.2.2 Flink程序設(shè)計(jì)

    Flink程序使用Scala語(yǔ)言設(shè)計(jì)并實(shí)現(xiàn),程序的Source階段使用Flink框架自帶的FlinkKafkaCon-sumer不斷地從Kafka的主題內(nèi)消費(fèi)數(shù)據(jù)。在Transformation階段,對(duì)獲取的數(shù)據(jù)按電子疾病檔案的主題目錄進(jìn)行分流,在各個(gè)主題目錄對(duì)應(yīng)的數(shù)據(jù)流中對(duì)其所屬的數(shù)據(jù)進(jìn)行各自不同的操作類(lèi)型識(shí)別、數(shù)據(jù)格式檢查、數(shù)據(jù)格式轉(zhuǎn)換等操作。由于從Kafak獲取的數(shù)據(jù)包含了電子疾病檔案的各類(lèi)數(shù)據(jù)目錄,程序根據(jù)數(shù)據(jù)的前6位字符判斷該條數(shù)據(jù)所屬的主題目錄,利用Flink提供的旁路輸出Side Output功能對(duì)數(shù)據(jù)流進(jìn)行切分,每類(lèi)主題目錄的數(shù)據(jù)被發(fā)送至其對(duì)應(yīng)的子數(shù)據(jù)流中調(diào)用自定義的各類(lèi)主題目錄的數(shù)據(jù)處理函數(shù)進(jìn)行處理,最終在各個(gè)子數(shù)據(jù)流的Sink階段,將處理好的電子疾病檔案數(shù)據(jù)寫(xiě)入HBase進(jìn)行持久化。由于Flink沒(méi)有提供已封裝好的HBase的Sink算子,自定義算子實(shí)現(xiàn)Flink提供的RichSinkFunction接口來(lái)完成相關(guān)的對(duì)HBase的操作,Flink程序的拓?fù)浣Y(jié)構(gòu),如圖3所示。

    圖3 程序拓?fù)浣Y(jié)構(gòu)

    以死亡報(bào)告主題目錄數(shù)據(jù)為例,Flink程序關(guān)鍵代碼如下:

    val environment = StreamExecutionEnvironment.getExecutionEnvironment//創(chuàng)建可執(zhí)行環(huán)境

    val outsideStream = environment.addSource(new FlinkKafkaConsumer[String](topic,new SimpleStringSchema(),props))//使用FlinkKafkaConsumer 從Kafka消費(fèi)數(shù)據(jù)

    .process(new ProcessFunction[String,String] {//在基本處理函數(shù) ProcessFunction中使用Side Output函數(shù)對(duì)數(shù)據(jù)進(jìn)行分流

    override def processElement(source:String,context:ProcessFunction[String,String]#Context,collector:Collector[String]):Unit = {

    Source.substring(0,6)match {//截取數(shù)據(jù)前六位獲取所屬主題目錄

    case "320601" => context.output(death01,source.substring(7)) //判斷所屬主題目錄為死亡報(bào)告數(shù)據(jù)后獲取剩余數(shù)據(jù)部分并標(biāo)記其對(duì)應(yīng)的數(shù)據(jù)流標(biāo)識(shí)death01進(jìn)行分流

    ...//其他主題目錄判斷與獲取

    case _ => context.output(or,source.substring(7))

    }

    }

    }).setParallelism(1)//分流算子并行度設(shè)置

    val deathStream = outsideStream.getSideOutput(death01) //分流后主題目錄數(shù)據(jù)流的獲取

    ....

    deathStream.map(deathTransformation(_)).setParallelism(2) //在自定義的deathTransformation函數(shù)中完成其對(duì)應(yīng)主題目錄數(shù)據(jù)的操作類(lèi)型識(shí)別、格式檢查、轉(zhuǎn)換操作

    .addSink(new deathHbaseSink()) //自定義deathHbaseSink函數(shù)對(duì)其對(duì)應(yīng)主題目錄數(shù)據(jù)進(jìn)行持久化操作

    2.2.3 HBase設(shè)計(jì)

    在HBase電子疾病檔案所屬的命名空間Name-space中為各類(lèi)主題目錄建立各自所屬的表,考慮到之后的業(yè)務(wù)需要通過(guò)身份證號(hào)以個(gè)人信息為單位對(duì)疾病檔案進(jìn)行綜合展示與分析,對(duì)唯一標(biāo)識(shí)表中的一行數(shù)據(jù)的RowKey[15]使用身份證號(hào)加業(yè)務(wù)主鍵號(hào)的方式來(lái)生成,這樣既保證了表中RowKey的唯一性,又可以使未來(lái)的業(yè)務(wù)端調(diào)用Hbase的API時(shí),通過(guò)其提供的前置過(guò)濾器將身份證提取出來(lái)進(jìn)行匹配與查詢,而無(wú)需再建立二級(jí)索引或借助其他的工具。在Flink程序進(jìn)行數(shù)據(jù)持久化時(shí),使用Protobuf工具提供的功能對(duì)電子疾病檔案數(shù)據(jù)進(jìn)行序列化壓縮后,再關(guān)聯(lián)其對(duì)應(yīng)的RowKey寫(xiě)入Hbase,使每個(gè)RowKey在表中只存儲(chǔ)一個(gè),提升空間的利用率。

    3 仿真實(shí)驗(yàn)

    在疾控內(nèi)部局域網(wǎng)部署應(yīng)用模型進(jìn)行測(cè)試,使用的各類(lèi)軟件信息,如表2所示。集群硬件環(huán)境包含10臺(tái)Cpu8核,內(nèi)存32 G,操作系統(tǒng)為64位Linux Centos 7.7的虛擬機(jī)。其中,7臺(tái)為Hadoop與Hbase集群的部署提供支持。Hadoop集群中包含了2個(gè)互為主從的管理節(jié)點(diǎn)NameNode,5個(gè)計(jì)算節(jié)點(diǎn)DataNode,2個(gè)資源調(diào)度管理節(jié)點(diǎn)ResourceManager;HBase集群中包含了兩個(gè)互為主從的HMaster節(jié)點(diǎn),3個(gè)RegionServer節(jié)點(diǎn);Flink集群部署于DataNode所在的5個(gè)計(jì)算節(jié)點(diǎn),使用Yarn Session的模式對(duì)Flink作業(yè)進(jìn)行調(diào)度與管理。Kafka與ZooKeeper等中間件部署在另外三臺(tái)虛擬機(jī)上。

    表2 軟件版本信息

    實(shí)驗(yàn)從疾控內(nèi)網(wǎng)數(shù)據(jù)庫(kù)批量取出死亡報(bào)告信息與兒童預(yù)防接種信息各10 000條寫(xiě)入Kafka的電子疾病檔案主題內(nèi),對(duì)Flink程序中的分流算子以及死亡報(bào)告信息與兒童預(yù)防接種信息的數(shù)據(jù)處理算子分別設(shè)置不同的并行度的情況下,記錄數(shù)據(jù)全部寫(xiě)入HBase的運(yùn)行時(shí)間情況,運(yùn)行時(shí)間皆為5次實(shí)驗(yàn)后的平均值,結(jié)果如表3所示。

    表3 實(shí)驗(yàn)結(jié)果

    從實(shí)驗(yàn)結(jié)果可以看出,在數(shù)據(jù)量較大的情況下,該模型的數(shù)據(jù)處理的實(shí)時(shí)性良好,且合理的提高分流算子或數(shù)據(jù)處理算子的并發(fā)度能有效地提高模型的數(shù)據(jù)處理能力,實(shí)驗(yàn)證明該模型具有良好的數(shù)據(jù)實(shí)時(shí)處理能力及彈性擴(kuò)展能力。

    4 結(jié)語(yǔ)

    為了建設(shè)電子疾病檔案系統(tǒng),實(shí)現(xiàn)疾控各個(gè)業(yè)務(wù)條線數(shù)據(jù)的有效匯集,進(jìn)而為業(yè)務(wù)協(xié)同以及輔助決策提供數(shù)據(jù)支持,本文根據(jù)疾控業(yè)務(wù)信息化建設(shè)的現(xiàn)狀設(shè)計(jì)了一個(gè)數(shù)據(jù)實(shí)時(shí)處理模型,并使用消息中間件Kafka,流式計(jì)算框架Flink及寬列數(shù)據(jù)庫(kù)HBase給出了模型的具體實(shí)現(xiàn)。實(shí)踐表明,模型具有良好的數(shù)據(jù)處理能力,滿足預(yù)計(jì)的設(shè)計(jì)目標(biāo),其分層設(shè)計(jì)的架構(gòu)風(fēng)格使得每一層都可以靈活根據(jù)需求獨(dú)立的變化而不影響其他層。在業(yè)務(wù)生產(chǎn)數(shù)據(jù)量比較大的場(chǎng)景,可以單獨(dú)為某類(lèi)業(yè)務(wù)數(shù)據(jù)另設(shè)一個(gè)Kafka以提高數(shù)據(jù)吞吐量。在Flink程序的Source階段,先進(jìn)行數(shù)據(jù)的合流后再進(jìn)行接下來(lái)的處理;而對(duì)于某些實(shí)時(shí)處理的數(shù)據(jù)量較大、數(shù)據(jù)處理任務(wù)較復(fù)雜的業(yè)務(wù),也可以提高該業(yè)務(wù)數(shù)據(jù)處理算子的并行度以提高數(shù)據(jù)處理速度。目前,該模型已成功應(yīng)用在江蘇省疾控中心的死亡報(bào)告、預(yù)防接種等部分業(yè)務(wù)條線數(shù)據(jù)的處理與匯集中,下一步的工作是根據(jù)電子疾病檔案的數(shù)據(jù)規(guī)范要求進(jìn)一步匯集數(shù)據(jù),并結(jié)合統(tǒng)計(jì)分析工具與相關(guān)算法進(jìn)行數(shù)據(jù)的利用與分析。

    猜你喜歡
    數(shù)據(jù)流數(shù)據(jù)處理算子
    認(rèn)知診斷缺失數(shù)據(jù)處理方法的比較:零替換、多重插補(bǔ)與極大似然估計(jì)法*
    ILWT-EEMD數(shù)據(jù)處理的ELM滾動(dòng)軸承故障診斷
    擬微分算子在Hp(ω)上的有界性
    各向異性次Laplace算子和擬p-次Laplace算子的Picone恒等式及其應(yīng)用
    汽車(chē)維修數(shù)據(jù)流基礎(chǔ)(下)
    一類(lèi)Markov模算子半群與相應(yīng)的算子值Dirichlet型刻畫(huà)
    一種提高TCP與UDP數(shù)據(jù)流公平性的擁塞控制機(jī)制
    Roper-Suffridge延拓算子與Loewner鏈
    基于希爾伯特- 黃變換的去噪法在外測(cè)數(shù)據(jù)處理中的應(yīng)用
    基于數(shù)據(jù)流聚類(lèi)的多目標(biāo)跟蹤算法
    国产三级在线视频| 午夜日韩欧美国产| 桃色一区二区三区在线观看| 99久久精品国产亚洲精品| 97超级碰碰碰精品色视频在线观看| 亚洲最大成人手机在线| 女人十人毛片免费观看3o分钟| 老汉色av国产亚洲站长工具| 久久精品综合一区二区三区| 久久精品综合一区二区三区| 免费观看人在逋| 99久久无色码亚洲精品果冻| 午夜免费激情av| 国产欧美日韩一区二区精品| 精品无人区乱码1区二区| 亚洲不卡免费看| 啦啦啦观看免费观看视频高清| 精品久久久久久久人妻蜜臀av| 国产伦一二天堂av在线观看| 久久久久免费精品人妻一区二区| 在线观看舔阴道视频| 熟妇人妻久久中文字幕3abv| 欧美日韩精品网址| 日本成人三级电影网站| 熟女电影av网| 中文亚洲av片在线观看爽| 午夜福利在线观看免费完整高清在 | 欧美色视频一区免费| 青草久久国产| 欧美乱妇无乱码| 麻豆国产av国片精品| 在线观看免费午夜福利视频| 久久久久性生活片| 51国产日韩欧美| 在线看三级毛片| svipshipincom国产片| 丰满人妻熟妇乱又伦精品不卡| 国产高清videossex| 欧美另类亚洲清纯唯美| 国产精品久久久久久久久免 | 日韩欧美免费精品| 亚洲国产精品成人综合色| 亚洲aⅴ乱码一区二区在线播放| 国产私拍福利视频在线观看| 99精品欧美一区二区三区四区| 久久久久久久午夜电影| 精品久久久久久久毛片微露脸| 啪啪无遮挡十八禁网站| 中国美女看黄片| 午夜福利视频1000在线观看| 成人av在线播放网站| 免费在线观看亚洲国产| 亚洲欧美激情综合另类| 亚洲第一欧美日韩一区二区三区| 成人亚洲精品av一区二区| 亚洲国产精品久久男人天堂| 国产精品永久免费网站| 亚洲在线观看片| 免费av观看视频| 黄色成人免费大全| 身体一侧抽搐| 亚洲美女黄片视频| 久久亚洲精品不卡| 亚洲av成人av| 欧美黑人欧美精品刺激| 九九热线精品视视频播放| 日韩av在线大香蕉| 男人的好看免费观看在线视频| a在线观看视频网站| 一级作爱视频免费观看| 两人在一起打扑克的视频| 国产精品 欧美亚洲| 欧美大码av| 国产激情欧美一区二区| 日韩欧美在线乱码| 亚洲一区二区三区不卡视频| 白带黄色成豆腐渣| 色哟哟哟哟哟哟| 免费看a级黄色片| 久久精品国产亚洲av香蕉五月| 欧美午夜高清在线| 九色成人免费人妻av| 噜噜噜噜噜久久久久久91| 搡老妇女老女人老熟妇| 国产亚洲av嫩草精品影院| 在线观看日韩欧美| 国产单亲对白刺激| 亚洲国产中文字幕在线视频| 亚洲av成人精品一区久久| 亚洲午夜理论影院| 国产精品99久久99久久久不卡| 999久久久精品免费观看国产| 国产精品影院久久| 久久中文看片网| 黄色视频,在线免费观看| 欧美性猛交╳xxx乱大交人| 亚洲欧美日韩卡通动漫| 欧美成人一区二区免费高清观看| 真人一进一出gif抽搐免费| 欧美3d第一页| 免费观看精品视频网站| 日本熟妇午夜| 精品一区二区三区视频在线观看免费| 久久久久久人人人人人| 日韩欧美精品v在线| 国产欧美日韩一区二区三| 少妇的逼好多水| 国产黄色小视频在线观看| 久久久久九九精品影院| 欧美色视频一区免费| 91麻豆av在线| 精品一区二区三区av网在线观看| 国产精品电影一区二区三区| 亚洲va日本ⅴa欧美va伊人久久| 亚洲成人免费电影在线观看| 日韩欧美国产一区二区入口| 香蕉av资源在线| 亚洲性夜色夜夜综合| 天天躁日日操中文字幕| 男插女下体视频免费在线播放| 18禁黄网站禁片午夜丰满| 国产v大片淫在线免费观看| 真实男女啪啪啪动态图| 国产熟女xx| 中文亚洲av片在线观看爽| 成人三级黄色视频| 琪琪午夜伦伦电影理论片6080| 日韩av在线大香蕉| 精品熟女少妇八av免费久了| 亚洲男人的天堂狠狠| 午夜日韩欧美国产| 国产一级毛片七仙女欲春2| av国产免费在线观看| 十八禁网站免费在线| 天美传媒精品一区二区| 午夜福利视频1000在线观看| 蜜桃亚洲精品一区二区三区| 日韩大尺度精品在线看网址| 欧美不卡视频在线免费观看| 12—13女人毛片做爰片一| 一a级毛片在线观看| 亚洲国产欧美人成| 日本一二三区视频观看| 蜜桃亚洲精品一区二区三区| av专区在线播放| 在线观看免费视频日本深夜| 亚洲国产精品999在线| 五月玫瑰六月丁香| а√天堂www在线а√下载| 别揉我奶头~嗯~啊~动态视频| 亚洲人成网站在线播| 一个人看视频在线观看www免费 | 看免费av毛片| 特级一级黄色大片| 身体一侧抽搐| 亚洲精品色激情综合| 69人妻影院| 在线观看免费午夜福利视频| 国产高清videossex| 欧美乱色亚洲激情| 精品一区二区三区视频在线观看免费| 在线视频色国产色| 亚洲熟妇熟女久久| 色精品久久人妻99蜜桃| 三级毛片av免费| 国产成人a区在线观看| 熟妇人妻久久中文字幕3abv| 悠悠久久av| 高清日韩中文字幕在线| 51午夜福利影视在线观看| 国产成人aa在线观看| 国内久久婷婷六月综合欲色啪| 一本精品99久久精品77| 亚洲精品久久国产高清桃花| 五月伊人婷婷丁香| 亚洲电影在线观看av| 观看免费一级毛片| 亚洲人成网站高清观看| 精品国内亚洲2022精品成人| www日本在线高清视频| 欧美又色又爽又黄视频| 亚洲熟妇熟女久久| 欧美在线一区亚洲| 日本黄色片子视频| 免费人成在线观看视频色| av福利片在线观看| 亚洲成人中文字幕在线播放| 天天添夜夜摸| 亚洲人成伊人成综合网2020| 中文在线观看免费www的网站| 亚洲一区二区三区不卡视频| 成人av一区二区三区在线看| 精品乱码久久久久久99久播| 久久久久国内视频| xxx96com| 99国产精品一区二区三区| 久久欧美精品欧美久久欧美| 丰满人妻一区二区三区视频av | 国产成人欧美在线观看| 国产欧美日韩精品一区二区| 免费无遮挡裸体视频| 99国产极品粉嫩在线观看| 长腿黑丝高跟| 十八禁人妻一区二区| svipshipincom国产片| 亚洲av中文字字幕乱码综合| 在线观看免费视频日本深夜| 成人三级黄色视频| 亚洲av日韩精品久久久久久密| 久久久久国内视频| 又爽又黄无遮挡网站| 国产av麻豆久久久久久久| 中文亚洲av片在线观看爽| 男人舔女人下体高潮全视频| 欧美性猛交╳xxx乱大交人| 国产美女午夜福利| 亚洲在线自拍视频| 午夜两性在线视频| 一a级毛片在线观看| 听说在线观看完整版免费高清| 国产欧美日韩一区二区精品| 国内久久婷婷六月综合欲色啪| 免费无遮挡裸体视频| 国产伦精品一区二区三区视频9 | 特大巨黑吊av在线直播| 99久久99久久久精品蜜桃| 国产午夜福利久久久久久| 热99在线观看视频| 欧美性感艳星| 热99re8久久精品国产| 99精品在免费线老司机午夜| 亚洲精品在线美女| 国产伦精品一区二区三区视频9 | 日韩欧美精品免费久久 | 欧美一区二区亚洲| 免费高清视频大片| а√天堂www在线а√下载| 热99re8久久精品国产| 成人性生交大片免费视频hd| 久99久视频精品免费| av女优亚洲男人天堂| 99久国产av精品| 免费人成在线观看视频色| 欧美日韩黄片免| 国产私拍福利视频在线观看| 久久亚洲真实| 首页视频小说图片口味搜索| 啦啦啦韩国在线观看视频| 悠悠久久av| 亚洲精品美女久久久久99蜜臀| 色播亚洲综合网| 日本黄色片子视频| 亚洲中文日韩欧美视频| 在线观看av片永久免费下载| 日韩欧美一区二区三区在线观看| 色综合站精品国产| 日韩亚洲欧美综合| 一卡2卡三卡四卡精品乱码亚洲| 免费无遮挡裸体视频| 国产不卡一卡二| 制服丝袜大香蕉在线| 少妇人妻精品综合一区二区 | 久久午夜亚洲精品久久| 首页视频小说图片口味搜索| 美女被艹到高潮喷水动态| 白带黄色成豆腐渣| 中文字幕人成人乱码亚洲影| 国内毛片毛片毛片毛片毛片| 亚洲人与动物交配视频| 精品一区二区三区av网在线观看| 三级男女做爰猛烈吃奶摸视频| 亚洲精品日韩av片在线观看 | 久久久久久久精品吃奶| 成人鲁丝片一二三区免费| 亚洲国产日韩欧美精品在线观看 | 国产精品久久久久久人妻精品电影| 欧美黄色淫秽网站| 欧美高清成人免费视频www| 亚洲 国产 在线| 天堂√8在线中文| 男插女下体视频免费在线播放| 中文字幕人妻熟人妻熟丝袜美 | 九九热线精品视视频播放| 俺也久久电影网| 国产久久久一区二区三区| 又黄又爽又免费观看的视频| 嫩草影视91久久| 琪琪午夜伦伦电影理论片6080| 黄片大片在线免费观看| 99久国产av精品| 两性午夜刺激爽爽歪歪视频在线观看| 国产av在哪里看| 久久久久久大精品| 久久久久性生活片| 日韩欧美在线乱码| 成人国产一区最新在线观看| 99在线人妻在线中文字幕| 成人无遮挡网站| 夜夜夜夜夜久久久久| 午夜免费男女啪啪视频观看 | 欧美三级亚洲精品| 综合色av麻豆| 亚洲国产中文字幕在线视频| 国产亚洲精品久久久久久毛片| 国产黄a三级三级三级人| 美女高潮的动态| 两性午夜刺激爽爽歪歪视频在线观看| av国产免费在线观看| a在线观看视频网站| 国产av麻豆久久久久久久| 最好的美女福利视频网| 在线观看美女被高潮喷水网站 | 色精品久久人妻99蜜桃| 国产又黄又爽又无遮挡在线| 国产99白浆流出| 90打野战视频偷拍视频| 狂野欧美激情性xxxx| 久久国产精品人妻蜜桃| 日韩人妻高清精品专区| 90打野战视频偷拍视频| 99久国产av精品| 亚洲av五月六月丁香网| 欧美午夜高清在线| 欧美色视频一区免费| 波多野结衣巨乳人妻| 国产三级在线视频| 欧美激情在线99| 精品久久久久久久久久久久久| 一级黄色大片毛片| 宅男免费午夜| 亚洲国产色片| 国产亚洲精品综合一区在线观看| 2021天堂中文幕一二区在线观| 在线观看美女被高潮喷水网站 | 中亚洲国语对白在线视频| 午夜久久久久精精品| 亚洲 欧美 日韩 在线 免费| 国产成人福利小说| 欧美中文日本在线观看视频| 欧美最新免费一区二区三区 | 色哟哟哟哟哟哟| 亚洲性夜色夜夜综合| 欧美一级毛片孕妇| 又紧又爽又黄一区二区| 亚洲av成人av| 欧美色欧美亚洲另类二区| 欧美+日韩+精品| 少妇丰满av| av在线天堂中文字幕| 亚洲国产中文字幕在线视频| 成年女人看的毛片在线观看| 乱人视频在线观看| 国产久久久一区二区三区| 久久久久久人人人人人| 欧美在线一区亚洲| 精品久久久久久久久久免费视频| 日韩精品青青久久久久久| av视频在线观看入口| 国产在线精品亚洲第一网站| 嫩草影视91久久| 在线观看午夜福利视频| 窝窝影院91人妻| 成人三级黄色视频| 高清毛片免费观看视频网站| 免费观看精品视频网站| 日韩成人在线观看一区二区三区| 免费看十八禁软件| 欧美最黄视频在线播放免费| 在线视频色国产色| 成人无遮挡网站| 国产激情偷乱视频一区二区| 亚洲真实伦在线观看| 中亚洲国语对白在线视频| 国产精品野战在线观看| 五月伊人婷婷丁香| 一本一本综合久久| 久久精品国产亚洲av涩爱 | 白带黄色成豆腐渣| 久久中文看片网| 久久久久性生活片| 免费av不卡在线播放| 亚洲精品国产精品久久久不卡| 美女高潮的动态| 精品不卡国产一区二区三区| 国产一区二区激情短视频| 无人区码免费观看不卡| 亚洲av五月六月丁香网| 亚洲精品美女久久久久99蜜臀| 两人在一起打扑克的视频| 欧美日韩综合久久久久久 | 亚洲精品乱码久久久v下载方式 | 1024手机看黄色片| 中文资源天堂在线| 久久精品国产清高在天天线| 美女高潮的动态| 全区人妻精品视频| 免费观看人在逋| 淫妇啪啪啪对白视频| 国产一区二区在线观看日韩 | 窝窝影院91人妻| 九九久久精品国产亚洲av麻豆| 国产成人av教育| av天堂中文字幕网| 在线观看美女被高潮喷水网站 | 色老头精品视频在线观看| 99精品欧美一区二区三区四区| 亚洲精品456在线播放app | 午夜福利成人在线免费观看| 国产99白浆流出| 老鸭窝网址在线观看| 一区二区三区国产精品乱码| 国内揄拍国产精品人妻在线| 成人av在线播放网站| 99久久九九国产精品国产免费| 久久久久久国产a免费观看| 精品人妻一区二区三区麻豆 | 无遮挡黄片免费观看| 久久精品91无色码中文字幕| 欧美日本视频| 国产欧美日韩一区二区三| 一边摸一边抽搐一进一小说| 精品久久久久久久人妻蜜臀av| 欧美午夜高清在线| 欧美另类亚洲清纯唯美| 日本五十路高清| 麻豆国产av国片精品| av天堂中文字幕网| 51午夜福利影视在线观看| 国产伦精品一区二区三区四那| 久久精品国产亚洲av香蕉五月| 亚洲欧美精品综合久久99| 欧美+亚洲+日韩+国产| 欧美乱妇无乱码| 国产黄片美女视频| 久久久久久大精品| 成人一区二区视频在线观看| 午夜免费观看网址| 亚洲av不卡在线观看| 日韩精品青青久久久久久| www.www免费av| 好看av亚洲va欧美ⅴa在| 亚洲熟妇熟女久久| 国产高清videossex| 3wmmmm亚洲av在线观看| 两性午夜刺激爽爽歪歪视频在线观看| 每晚都被弄得嗷嗷叫到高潮| 最近最新免费中文字幕在线| 国产精品亚洲美女久久久| 国产av不卡久久| 在线播放国产精品三级| 亚洲精品日韩av片在线观看 | 丁香六月欧美| 亚洲av美国av| 国产成人啪精品午夜网站| 日本与韩国留学比较| 99在线视频只有这里精品首页| 国产精品98久久久久久宅男小说| 国产精品女同一区二区软件 | 精品免费久久久久久久清纯| 免费一级毛片在线播放高清视频| 18禁国产床啪视频网站| 首页视频小说图片口味搜索| 国产精品综合久久久久久久免费| 国模一区二区三区四区视频| 搞女人的毛片| 国产精品自产拍在线观看55亚洲| 一级毛片女人18水好多| 他把我摸到了高潮在线观看| 国产单亲对白刺激| 亚洲精品亚洲一区二区| 男人和女人高潮做爰伦理| 女同久久另类99精品国产91| 国产精品久久久久久人妻精品电影| 亚洲国产日韩欧美精品在线观看 | 精品一区二区三区av网在线观看| 久久亚洲精品不卡| 精品99又大又爽又粗少妇毛片 | 国产 一区 欧美 日韩| 18禁国产床啪视频网站| 女警被强在线播放| 久久久久国产精品人妻aⅴ院| 我要搜黄色片| netflix在线观看网站| 90打野战视频偷拍视频| 天堂影院成人在线观看| 一区二区三区高清视频在线| 欧美激情在线99| 国产伦在线观看视频一区| 国产精品久久久久久精品电影| 亚洲人与动物交配视频| 国内少妇人妻偷人精品xxx网站| 亚洲欧美日韩高清专用| 九九在线视频观看精品| av视频在线观看入口| 又黄又粗又硬又大视频| 国内毛片毛片毛片毛片毛片| 中文字幕高清在线视频| 国产三级黄色录像| 怎么达到女性高潮| 日韩欧美三级三区| 欧美另类亚洲清纯唯美| 18禁黄网站禁片免费观看直播| 免费看日本二区| 精品久久久久久,| 成年免费大片在线观看| 久久精品人妻少妇| 又紧又爽又黄一区二区| а√天堂www在线а√下载| 又黄又粗又硬又大视频| 日本免费a在线| 国产精品亚洲美女久久久| 欧美日韩乱码在线| 亚洲国产日韩欧美精品在线观看 | 成人欧美大片| 亚洲国产欧美人成| 精品国内亚洲2022精品成人| 久久精品影院6| 日日夜夜操网爽| 欧美一区二区国产精品久久精品| 午夜日韩欧美国产| 黄色视频,在线免费观看| 欧美+日韩+精品| 51午夜福利影视在线观看| www日本在线高清视频| 亚洲黑人精品在线| 国产老妇女一区| 高清毛片免费观看视频网站| 一级黄色大片毛片| 久久久久九九精品影院| 欧美日韩综合久久久久久 | 午夜免费男女啪啪视频观看 | 中文字幕精品亚洲无线码一区| 国产av在哪里看| 蜜桃亚洲精品一区二区三区| 久久国产乱子伦精品免费另类| 成人鲁丝片一二三区免费| 村上凉子中文字幕在线| 国产单亲对白刺激| 国产成人系列免费观看| 99久国产av精品| 精品国产三级普通话版| 亚洲不卡免费看| 欧美午夜高清在线| 午夜久久久久精精品| 美女高潮喷水抽搐中文字幕| 淫妇啪啪啪对白视频| 久久中文看片网| 淫妇啪啪啪对白视频| 国产成人福利小说| 亚洲av中文字字幕乱码综合| 免费高清视频大片| 怎么达到女性高潮| 国产一区二区激情短视频| 色综合婷婷激情| 国产精品女同一区二区软件 | 国产精品美女特级片免费视频播放器| 精品电影一区二区在线| 免费在线观看成人毛片| 日本五十路高清| 欧美日韩亚洲国产一区二区在线观看| av欧美777| 国产精品 欧美亚洲| 国产欧美日韩一区二区三| 国产 一区 欧美 日韩| 宅男免费午夜| 高潮久久久久久久久久久不卡| 亚洲内射少妇av| 国产探花在线观看一区二区| 久久久久久国产a免费观看| 亚洲国产日韩欧美精品在线观看 | 一个人看视频在线观看www免费 | 亚洲最大成人中文| 女人十人毛片免费观看3o分钟| 国语自产精品视频在线第100页| 国产精品 国内视频| 亚洲人成网站在线播放欧美日韩| 美女cb高潮喷水在线观看| 午夜福利高清视频| 美女 人体艺术 gogo| 亚洲自拍偷在线| 亚洲人成网站在线播| 国产私拍福利视频在线观看| 日韩大尺度精品在线看网址| 欧美一区二区国产精品久久精品| 欧美乱码精品一区二区三区| 69人妻影院| 亚洲专区国产一区二区| 午夜福利视频1000在线观看| 国内少妇人妻偷人精品xxx网站| 成年免费大片在线观看| 欧美bdsm另类| 久久人妻av系列| 九色成人免费人妻av| 国产亚洲精品一区二区www| 亚洲黑人精品在线| 小说图片视频综合网站| 成年人黄色毛片网站| 国产乱人视频| 亚洲一区高清亚洲精品| 男女下面进入的视频免费午夜| 真实男女啪啪啪动态图| 午夜福利免费观看在线| 国产精品国产高清国产av| 高清毛片免费观看视频网站| 一区二区三区高清视频在线| 国产视频内射| 国产精品久久久人人做人人爽| 真实男女啪啪啪动态图| 丰满乱子伦码专区| 伊人久久精品亚洲午夜| 久久久久国内视频| 亚洲 欧美 日韩 在线 免费| 午夜老司机福利剧场| 国产精品1区2区在线观看.| 午夜亚洲福利在线播放|