成人性生交大片免费看视频r_亚洲综合极品香蕉久久网_在线视频免费观看一区_亚洲精品亚洲人成人网在线播放_国产精品毛片av_久久久久国产精品www_亚洲国产一区二区三区在线播_日韩一区二区三区四区区区_亚洲精品国产无套在线观_国产免费www

主頁 > 知識庫 > nginx lua集成kafka的實(shí)現(xiàn)方法

nginx lua集成kafka的實(shí)現(xiàn)方法
熱門標(biāo)簽：百度地圖標(biāo)注公司位置要多少錢 虛假地圖標(biāo)注 地圖標(biāo)注如何改成微信號 承德地圖標(biāo)注公司 400電話號碼辦理多少錢 山東企業(yè)外呼系統(tǒng)公司 靈圖uu電子寵物店地圖標(biāo)注 濮陽好的聯(lián)通400電話申請 地圖標(biāo)注黃河的位置

第一步：進(jìn)入opresty目錄

[root@node03 openresty]# cd /export/servers/openresty/
[root@node03 openresty]# ll
total 356
drwxr-xr-x 2 root root  4096 Jul 26 11:33 bin
drwxrwxr-x 44 1000 1000  4096 Jul 26 11:31 build
drwxrwxr-x 43 1000 1000  4096 Nov 13 2017 bundle
-rwxrwxr-x 1 1000 1000 45908 Nov 13 2017 configure
-rw-rw-r-- 1 1000 1000 22924 Nov 13 2017 COPYRIGHT
drwxr-xr-x 6 root root  4096 Jul 26 11:33 luajit
drwxr-xr-x 6 root root  4096 Aug 1 08:14 lualib
-rw-r--r-- 1 root root  5413 Jul 26 11:32 Makefile
drwxr-xr-x 11 root root  4096 Jul 26 11:35 nginx
drwxrwxr-x 2 1000 1000  4096 Nov 13 2017 patches
drwxr-xr-x 44 root root  4096 Jul 26 11:33 pod
-rw-rw-r-- 1 1000 1000  3689 Nov 13 2017 README.markdown
-rw-rw-r-- 1 1000 1000  8690 Nov 13 2017 README-win32.txt
-rw-r--r-- 1 root root 218352 Jul 26 11:33 resty.index
drwxr-xr-x 5 root root  4096 Jul 26 11:33 site
drwxr-xr-x 2 root root  4096 Aug 1 10:54 testlua
drwxrwxr-x 2 1000 1000  4096 Nov 13 2017 util
[root@node03 openresty]#

說明：接下來我們關(guān)注兩個(gè)目錄 lualib 和 nginx

​ 1.lualib: 是存放opresty所需要的集成軟件包的

​ 2.nginx： 是nginx服務(wù)目錄

接下來，我們進(jìn)入lualib目錄一看究竟：

[root@node03 openresty]# cd lualib/
[root@node03 lualib]# ll
total 116
-rwxr-xr-x 1 root root 101809 Jul 26 11:33 cjson.so
drwxr-xr-x 3 root root  4096 Jul 26 11:33 ngx
drwxr-xr-x 2 root root  4096 Jul 26 11:33 rds
drwxr-xr-x 2 root root  4096 Jul 26 11:33 redis
drwxr-xr-x 9 root root  4096 Aug 1 10:34 resty

這里我們看到了redis和ngx集成軟件包，說明我們可以之間使用nginx和redis而無需導(dǎo)入任何依賴包?。。?！

下面看看resty里面有些說明呢？？？？

[root@node03 lualib]# cd resty/
[root@node03 resty]# ll
total 152
-rw-r--r-- 1 root root 6409 Jul 26 11:33 aes.lua
drwxr-xr-x 2 root root 4096 Jul 26 11:33 core
-rw-r--r-- 1 root root  596 Jul 26 11:33 core.lua
drwxr-xr-x 2 root root 4096 Jul 26 11:33 dns
drwxr-xr-x 2 root root 4096 Aug 1 10:42 kafka  #這是我們自己導(dǎo)入的
drwxr-xr-x 2 root root 4096 Jul 26 11:33 limit
-rw-r--r-- 1 root root 4616 Jul 26 11:33 lock.lua
drwxr-xr-x 2 root root 4096 Jul 26 11:33 lrucache
-rw-r--r-- 1 root root 4620 Jul 26 11:33 lrucache.lua
-rw-r--r-- 1 root root 1211 Jul 26 11:33 md5.lua
-rw-r--r-- 1 root root 14544 Jul 26 11:33 memcached.lua
-rw-r--r-- 1 root root 21577 Jul 26 11:33 mysql.lua
-rw-r--r-- 1 root root  616 Jul 26 11:33 random.lua
-rw-r--r-- 1 root root 9227 Jul 26 11:33 redis.lua
-rw-r--r-- 1 root root 1192 Jul 26 11:33 sha1.lua
-rw-r--r-- 1 root root 1045 Jul 26 11:33 sha224.lua
-rw-r--r-- 1 root root 1221 Jul 26 11:33 sha256.lua
-rw-r--r-- 1 root root 1045 Jul 26 11:33 sha384.lua
-rw-r--r-- 1 root root 1359 Jul 26 11:33 sha512.lua
-rw-r--r-- 1 root root  236 Jul 26 11:33 sha.lua
-rw-r--r-- 1 root root  698 Jul 26 11:33 string.lua
-rw-r--r-- 1 root root 5178 Jul 26 11:33 upload.lua
drwxr-xr-x 2 root root 4096 Jul 26 11:33 upstream
drwxr-xr-x 2 root root 406 Jul 26 11:33 websocket

這里我們看到了熟悉的mysql.lua和redis.lua，好了其他的先不要管

注意：這里的 kafka 這個(gè)包是沒有的,說明opnresty么有集成kafka。此處我已經(jīng)提前導(dǎo)入啦kafka集成包

我們看看kafka里面多有哪些包：

[root@node03 resty]# cd kafka
[root@node03 kafka]# ll
total 48
-rw-r--r-- 1 root root 1369 Aug 1 10:42 broker.lua
-rw-r--r-- 1 root root 5537 Aug 1 10:42 client.lua
-rw-r--r-- 1 root root  710 Aug 1 10:42 errors.lua
-rw-r--r-- 1 root root 10718 Aug 1 10:42 producer.lua
-rw-r--r-- 1 root root 4072 Aug 1 10:42 request.lua
-rw-r--r-- 1 root root 2118 Aug 1 10:42 response.lua
-rw-r--r-- 1 root root 1494 Aug 1 10:42 ringbuffer.lua
-rw-r--r-- 1 root root 4845 Aug 1 10:42 sendbuffer.lua

附上 kafka 集成包：kafka_jb51.rar

第二步：創(chuàng)建kafka測試lua文件

1.退回到openresty

[root@node03 kafka]# cd /export/servers/openresty/

2.創(chuàng)建測試文件

[root@node03 openresty]# mkdir -r testlua
#這里文件名自己取，文件位置自己定，但必須找得到

這里文件名自己取，文件位置自己定，但必須找得到!!!!!!!!!!!下面會(huì)用到!!!!!!!!!!

3.進(jìn)入剛剛創(chuàng)建的文件夾并創(chuàng)建kafkalua.lua腳本文件

創(chuàng)建文件：vim kafkalua.lua或者touch kafkalua.lua

[root@node03 openresty]# cd testlua/
[root@node03 testlua]# ll
total 8
-rw-r--r-- 1 root root 3288 Aug 1 10:54 kafkalua.lua

kafkalua.lua:

--測試語句可以不用
ngx.say('hello kafka file configuration successful!!!!!!')

--數(shù)據(jù)采集閾值限制，如果lua采集超過閾值，則不采集
local DEFAULT_THRESHOLD = 100000
-- kafka分區(qū)數(shù)
local PARTITION_NUM = 6
-- kafka主題名稱
local TOPIC = 'B2CDATA_COLLECTION1'
-- 輪詢器共享變量KEY值
local POLLING_KEY = "POLLING_KEY"
-- kafka集群(定義kafka broker地址，ip需要和kafka的host.name配置一致)
local function partitioner(key, num, correlation_id)
  return tonumber(key)
end
--kafka broker列表
local BROKER_LIST = {{host="192.168.52.100",port=9092},{host="192.168.52.110",port=9092},{host="192.168.52.120",port=9092}}
--kafka參數(shù)，
local CONNECT_PARAMS = { producer_type = "async", socket_timeout = 30000, flush_time = 10000, request_timeout = 20000, partitioner = partitioner }
-- 共享內(nèi)存計(jì)數(shù)器，用于kafka輪詢使用
local shared_data = ngx.shared.shared_data
local pollingVal = shared_data:get(POLLING_KEY)
if not pollingVal then
  pollingVal = 1
  shared_data:set(POLLING_KEY, pollingVal)
end
--獲取每一條消息的計(jì)數(shù)器，對PARTITION_NUM取余數(shù)，均衡分區(qū)
local partitions = '' .. (tonumber(pollingVal) % PARTITION_NUM)
shared_data:incr(POLLING_KEY, 1)

-- 并發(fā)控制
local isGone = true
--獲取ngx.var.connections_active進(jìn)行過載保護(hù)，即如果當(dāng)前活躍連接數(shù)超過閾值進(jìn)行限流保護(hù)
if tonumber(ngx.var.connections_active) > tonumber(DEFAULT_THRESHOLD) then
  isGone = false
end
-- 數(shù)據(jù)采集
if isGone then

  local time_local = ngx.var.time_local
  if time_local == nil then
    time_local = ""
  end

  local request = ngx.var.request
  if request == nil then
    request = ""
  end

  local request_method = ngx.var.request_method
  if request_method == nil then
    request_method = ""
  end

  local content_type = ngx.var.content_type
  if content_type == nil then
    content_type = ""
  end
  ngx.req.read_body()
  local request_body = ngx.var.request_body
  if request_body == nil then
    request_body = ""
  end

  local http_referer = ngx.var.http_referer
  if http_referer == nil then
    http_referer = ""
  end

  local remote_addr = ngx.var.remote_addr
  if remote_addr == nil then
    remote_addr = ""
  end

  local http_user_agent = ngx.var.http_user_agent
  if http_user_agent == nil then
    http_user_agent = ""
  end

  local time_iso8601 = ngx.var.time_iso8601
  if time_iso8601 == nil then
    time_iso8601 = ""
  end

  local server_addr = ngx.var.server_addr
  if server_addr == nil then
    server_addr = ""
  end

  local http_cookie = ngx.var.http_cookie
  if http_cookie == nil then
    http_cookie = ""
  end
--封裝數(shù)據(jù)
  local message = time_local .."#CS#".. request .."#CS#".. request_method .."#CS#".. content_type .."#CS#".. request_body .."#CS#".. http_referer .."#CS#".. remote_addr .."#CS#".. http_user_agent .."#CS#".. time_iso8601 .."#CS#".. server_addr .."#CS#".. http_cookie;
--引入kafka的producer
local producer = require "resty.kafka.producer"
--創(chuàng)建producer
local bp = producer:new(BROKER_LIST, CONNECT_PARAMS)
--發(fā)送數(shù)據(jù)
local ok, err = bp:send(TOPIC, partitions, message)
--打印錯(cuò)誤日志
  if not ok then
    ngx.log(ngx.ERR, "kafka send err:", err)
    return
  end
end

第三步：修改nginx配置文件nginx.conf

1.進(jìn)入ngin/conf目錄

[root@node03 openresty]# cd /export/servers/openresty/nginx/conf/
[root@node03 conf]# ll
total 76
-rw-r--r-- 1 root root 1077 Jul 26 11:33 fastcgi.conf
-rw-r--r-- 1 root root 1077 Jul 26 11:33 fastcgi.conf.default
-rw-r--r-- 1 root root 1007 Jul 26 11:33 fastcgi_params
-rw-r--r-- 1 root root 1007 Jul 26 11:33 fastcgi_params.default
-rw-r--r-- 1 root root 2837 Jul 26 11:33 koi-utf
-rw-r--r-- 1 root root 2223 Jul 26 11:33 koi-win
-rw-r--r-- 1 root root 5170 Jul 26 11:33 mime.types
-rw-r--r-- 1 root root 5170 Jul 26 11:33 mime.types.default
-rw-r--r-- 1 root root 3191 Aug 1 10:52 nginx.conf
-rw-r--r-- 1 root root 2656 Jul 26 11:33 nginx.conf.default
-rw-r--r-- 1 root root 636 Jul 26 11:33 scgi_params
-rw-r--r-- 1 root root 636 Jul 26 11:33 scgi_params.default
-rw-r--r-- 1 root root 664 Jul 26 11:33 uwsgi_params
-rw-r--r-- 1 root root 664 Jul 26 11:33 uwsgi_params.default
-rw-r--r-- 1 root root 3610 Jul 26 11:33 win-utf

2.修改nginx.conf

[root@node03 conf]# vim nginx.conf

    #1.說明找到第一個(gè)server
    #2.在server上面添加兩行代碼如下
    #3.在server里面添加kafka相關(guān)的代碼如下
    
    
#------------------添加的代碼---------------------------------------
 #開啟共享字典，設(shè)置內(nèi)存大小為10M，供每個(gè)nginx的線程消費(fèi)
 lua_shared_dict shared_data 10m;
 #配置本地域名解析
 resolver 127.0.0.1;
#------------------添加的代碼---------------------------------------

 server {
    listen    80;
    server_name localhost;

    #charset koi8-r;

    #access_log logs/host.access.log main;
    location / {
      root  html;
      index index.html index.htm;
    }

    #------------------添加的代碼---------------------------------------
    location /kafkalua { #這里的kafkalua就是工程名字，不加默認(rèn)為空
      #開啟nginx監(jiān)控
      stub_status on;
      #加載lua文件
      default_type text/html;
      #指定kafka的lua文件位置，就是我們剛才創(chuàng)建的kafkalua.lua（前面已經(jīng)強(qiáng)調(diào)要記住的?。。。。?
      content_by_lua_file /export/servers/openresty/testlua/kafkalua.lua;
    }
    #------------------添加的代碼---------------------------------------
}

說明：location /kafkalua{...}這里的kafkalua是工程名，可以隨意取也可以不取，但是必須要記?。。?！

看到我們上面配置了兩個(gè)location，第一個(gè)為location /{...}第二個(gè)為location /kafkalua{...}那么他們有什么區(qū)別呢？？？先向下看，迷霧將會(huì)慢慢揭開。

第四步：啟動(dòng)nginx

1.進(jìn)入nginx/sbin

[root@node03 sbin]# cd /export/servers/openresty/nginx/sbin/
[root@node03 sbin]# ll
total 16356
-rwxr-xr-x 1 root root 16745834 Jul 26 11:33 nginx

2.測試配置文件是否正確

[root@node03 sbin]# nginx -t
nginx: the configuration file /export/servers/openresty/nginx/conf/nginx.conf syntax is ok
nginx: configuration file /export/servers/openresty/nginx/conf/nginx.conf test is successful
#看到已經(jīng)成功啦

3.啟動(dòng)nginx

[root@node03 sbin]# nginx
#不顯示任何東西一般是成功啦

4.查看nginx是否啟動(dòng)成功

[root@node03 sbin]# ps -ef | grep nginx
root    3730   1 0 09:24 ?    00:00:00 nginx: master process nginx
nobody   3731  3730 0 09:24 ?    00:00:20 nginx: worker process is shutting down
nobody   5766  3730 0 12:17 ?    00:00:00 nginx: worker process
root    5824  3708 0 12:24 pts/1  00:00:00 grep nginx
#看到有兩個(gè)nginx進(jìn)程，表示成功le

5.瀏覽器訪問nginx

在瀏覽器輸入：node03/kafkalua

說明：如何么有配置hosts則輸入openresty所在設(shè)備的地址如：192.168.52.120/kafkalua

在瀏覽器輸入：node03/或者 192.168.52.120/

再在瀏覽器輸入：node03:80/kafkalua 和 node03:80/試試 搬來nginx.conf來看看：

node03:80/kafkalua 這里的nide03是服務(wù)器的別名或者之間寫文服務(wù)器地址，80是【listen 80;】配置的監(jiān)聽端口，80端口可以省略不寫，如果這寫成【listen 8088;】那么瀏覽器需輸入 node03:8088/kafkalua （這里不能省略8088），kafkalua是工程名。

 server {
    listen    80;
    server_name localhost;

    #charset koi8-r;

    #access_log logs/host.access.log main;
    location / {
      root  html;
      index index.html index.htm;
    }

    #------------------添加的代碼---------------------------------------
    location /kafkalua { #這里的kafkalua就是工程名字，不加默認(rèn)為空
      #開啟nginx監(jiān)控
      stub_status on;
      #加載lua文件
      default_type text/html;
      #指定kafka的lua文件位置，就是我們剛才創(chuàng)建的kafkalua.lua（前面已經(jīng)強(qiáng)調(diào)要記住的?。。。。?
      content_by_lua_file /export/servers/openresty/testlua/kafkalua.lua;
    }

第五步：創(chuàng)建測試爬蟲程序

1.創(chuàng)建maven工程導(dǎo)入依賴

 <dependencies>
    <dependency>
      <groupId>org.jsoup</groupId>
      <artifactId>jsoup</artifactId>
      <version>1.11.3</version>
    </dependency>
    <dependency>
      <groupId>org.apache.httpcomponents</groupId>
      <artifactId>httpclient</artifactId>
      <version>4.5.4</version>
    </dependency>
  </dependencies>

2.偽爬蟲程序

public class SpiderGoAirCN {
  private static String basePath = "http://node03/kafkalua";
  public static void main(String[] args) throws Exception {
    for (int i = 0; i < 50000; i++) {
      // 請求查詢信息
      spiderQueryao();
      // 請求html
      spiderHtml();
      // 請求js
      spiderJs();
      // 請求css
      spiderCss();
      // 請求png
      spiderPng();
      // 請求jpg
      spiderJpg();
      Thread.sleep(100);
    }
  }

  /**
   * 
   * @throws Exception
   */
  public static void spiderQueryao() throws Exception {
    // 1.指定目標(biāo)網(wǎng)站   ^.*/B2C40/query/jaxb/direct/query.ao.*$
    String url = basePath + "/B2C40/query/jaxb/direct/query.ao";
    // 2.發(fā)起請求
    HttpPost httpPost = new HttpPost(url);
    // 3. 設(shè)置請求參數(shù)
    httpPost.setHeader("Time-Local", getLocalDateTime());
    httpPost.setHeader("Requst",
          "POST /B2C40/query/jaxb/direct/query.ao HTTP/1.1");
    httpPost.setHeader("Request Method", "POST");
    httpPost.setHeader("Content-Type",
        "application/x-www-form-urlencoded; charset=UTF-8");
    httpPost.setHeader(
        "Referer",
        "http://b2c.csair.com/B2C40/modules/bookingnew/main/flightSelectDirect.html?t=S&c1=CAN&c2=WUH&d1="
            + getGoTime() + "&at=1&ct=0&it=0");
    httpPost.setHeader("Remote Address", "192.168.56.80");
    httpPost.setHeader(
        "User-Agent",
        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36");
    httpPost.setHeader("Time-Iso8601", getISO8601Timestamp());
    httpPost.setHeader("Server Address", "243.45.78.132");
    httpPost.setHeader(
        "Cookie",
        "JSESSIONID=782121159357B98CA6112554CF44321E; sid=b5cc11e02e154ac5b0f3609332f86803; aid=8ae8768760927e280160bb348bef3e12; identifyStatus=N; userType4logCookie=M; userId4logCookie=13818791413; useridCookie=13818791413; userCodeCookie=13818791413; temp_zh=cou%3D0%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-13%3B%E5%B9%BF%E5%B7%9E-%E5%8C%97%E4%BA%AC%3B1%2C0%2C0%3B%26cou%3D1%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D"
            + getGoTime()
            + "%3B%E5%B9%BF%E5%B7%9E-%E6%88%90%E9%83%BD%3B1%2C0%2C0%3B%26; JSESSIONID=782121159357B98CA6112554CF44321E; WT-FPC=id=211.103.142.26-608782688.30635197:lv=1516170718655:ss=1516170709449:fs=1513243317440:pn=2:vn=10; language=zh_CN; WT.al_flight=WT.al_hctype(S)%3AWT.al_adultnum(1)%3AWT.al_childnum(0)%3AWT.al_infantnum(0)%3AWT.al_orgcity1(CAN)%3AWT.al_dstcity1(CTU)%3AWT.al_orgdate1("
            + getGoTime() + ")");
    // 4.設(shè)置請求參數(shù)
    ArrayList<BasicNameValuePair> parameters = new ArrayList<BasicNameValuePair>();
    parameters
        .add(new BasicNameValuePair(
            "json",
            "{\"depcity\":\"CAN\", \"arrcity\":\"WUH\", \"flightdate\":\"20180220\", \"adultnum\":\"1\", \"childnum\":\"0\", \"infantnum\":\"0\", \"cabinorder\":\"0\", \"airline\":\"1\", \"flytype\":\"0\", \"international\":\"0\", \"action\":\"0\", \"segtype\":\"1\", \"cache\":\"0\", \"preUrl\":\"\", \"isMember\":\"\"}"));
    httpPost.setEntity(new UrlEncodedFormEntity(parameters));
    // 5. 發(fā)起請求
    CloseableHttpClient httpClient = HttpClients.createDefault();
    CloseableHttpResponse response = httpClient.execute(httpPost);
    // 6.獲取返回值
    System.out.println(response != null);
  }

  public static void spiderHtml() throws Exception {
    // 1.指定目標(biāo)網(wǎng)站     ^.*html.*$
    String url = basePath + "/B2C40/modules/bookingnew/main/flightSelectDirect.html?t=S&c1=CAN&c2=CTU&d1=2018-01-17&at=1&ct=0&it=0";
    // 2.發(fā)起請求
    HttpPost httpPost = new HttpPost(url);
    // 3. 設(shè)置請求參數(shù)
    httpPost.setHeader("Time-Local", getLocalDateTime());
    httpPost.setHeader("Requst",
        "POST /B2C40/query/jaxb/direct/query.ao HTTP/1.1");
    httpPost.setHeader("Request Method", "POST");
    httpPost.setHeader("Content-Type",
        "application/x-www-form-urlencoded; charset=UTF-8");
    httpPost.setHeader(
        "Referer",
        "http://b2c.csair.com/B2C40/modules/bookingnew/main/flightSelectDirect.html?t=S&c1=CAN&c2=WUH&d1=2018-02-20&at=1&ct=0&it=0");
    httpPost.setHeader("Remote Address", "192.168.56.1");
    httpPost.setHeader(
        "User-Agent",
        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36");
    httpPost.setHeader("Time-Iso8601", getISO8601Timestamp());
    httpPost.setHeader("Server Address", "192.168.56.80");
    httpPost.setHeader(
        "Cookie",
        "JSESSIONID=782121159357B98CA6112554CF44321E; sid=b5cc11e02e154ac5b0f3609332f86803; aid=8ae8768760927e280160bb348bef3e12; identifyStatus=N; userType4logCookie=M; userId4logCookie=13818791413; useridCookie=13818791413; userCodeCookie=13818791413; temp_zh=cou%3D0%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-13%3B%E5%B9%BF%E5%B7%9E-%E5%8C%97%E4%BA%AC%3B1%2C0%2C0%3B%26cou%3D1%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-17%3B%E5%B9%BF%E5%B7%9E-%E6%88%90%E9%83%BD%3B1%2C0%2C0%3B%26; JSESSIONID=782121159357B98CA6112554CF44321E; WT-FPC=id=211.103.142.26-608782688.30635197:lv=1516170718655:ss=1516170709449:fs=1513243317440:pn=2:vn=10; language=zh_CN; WT.al_flight=WT.al_hctype(S)%3AWT.al_adultnum(1)%3AWT.al_childnum(0)%3AWT.al_infantnum(0)%3AWT.al_orgcity1(CAN)%3AWT.al_dstcity1(CTU)%3AWT.al_orgdate1(2018-01-17)");
    // 4.設(shè)置請求參數(shù)
    // httpPost.setEntity(new StringEntity(
    // "depcity=CAN&arrcity=WUH&flightdate=20180220&adultnum=1&childnum=0&infantnum=0&cabinorder=0&airline=1&flytype=0&international=0&action=0&segtype=1&cache=0&preUrl=&isMember="));
    ArrayList<BasicNameValuePair> parameters = new ArrayList<BasicNameValuePair>();
    parameters
        .add(new BasicNameValuePair(
            "json",
            "{\"depcity\":\"CAN\", \"arrcity\":\"WUH\", \"flightdate\":\"20180220\", \"adultnum\":\"1\", \"childnum\":\"0\", \"infantnum\":\"0\", \"cabinorder\":\"0\", \"airline\":\"1\", \"flytype\":\"0\", \"international\":\"0\", \"action\":\"0\", \"segtype\":\"1\", \"cache\":\"0\", \"preUrl\":\"\", \"isMember\":\"\"}"));
    httpPost.setEntity(new UrlEncodedFormEntity(parameters));
    // 5. 發(fā)起請求
    CloseableHttpClient httpClient = HttpClients.createDefault();
    CloseableHttpResponse response = httpClient.execute(httpPost);
    // 6.獲取返回值
    System.out.println(response != null);
  }

  public static void spiderJs() throws Exception {

    // 1.指定目標(biāo)網(wǎng)站
    String url = basePath +"/B2C40/dist/main/modules/common/requireConfig.js";
    // 2.發(fā)起請求
    HttpPost httpPost = new HttpPost(url);
    // 3. 設(shè)置請求參數(shù)
    httpPost.setHeader("Time-Local", getLocalDateTime());
    httpPost.setHeader("Requst",
        "POST /B2C40/query/jaxb/direct/query.ao HTTP/1.1");
    httpPost.setHeader("Request Method", "POST");
    httpPost.setHeader("Content-Type",
        "application/x-www-form-urlencoded; charset=UTF-8");
    httpPost.setHeader(
        "Referer",
        "http://b2c.csair.com/B2C40/modules/bookingnew/main/flightSelectDirect.html?t=S&c1=CAN&c2=WUH&d1=2018-02-20&at=1&ct=0&it=0");
    httpPost.setHeader("Remote Address", "192.168.56.1");
    httpPost.setHeader(
        "User-Agent",
        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36");
    httpPost.setHeader("Time-Iso8601", getISO8601Timestamp());
    httpPost.setHeader("Server Address", "192.168.56.80");
    httpPost.setHeader(
        "Cookie",
        "JSESSIONID=782121159357B98CA6112554CF44321E; sid=b5cc11e02e154ac5b0f3609332f86803; aid=8ae8768760927e280160bb348bef3e12; identifyStatus=N; userType4logCookie=M; userId4logCookie=13818791413; useridCookie=13818791413; userCodeCookie=13818791413; temp_zh=cou%3D0%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-13%3B%E5%B9%BF%E5%B7%9E-%E5%8C%97%E4%BA%AC%3B1%2C0%2C0%3B%26cou%3D1%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-17%3B%E5%B9%BF%E5%B7%9E-%E6%88%90%E9%83%BD%3B1%2C0%2C0%3B%26; JSESSIONID=782121159357B98CA6112554CF44321E; WT-FPC=id=211.103.142.26-608782688.30635197:lv=1516170718655:ss=1516170709449:fs=1513243317440:pn=2:vn=10; language=zh_CN; WT.al_flight=WT.al_hctype(S)%3AWT.al_adultnum(1)%3AWT.al_childnum(0)%3AWT.al_infantnum(0)%3AWT.al_orgcity1(CAN)%3AWT.al_dstcity1(CTU)%3AWT.al_orgdate1(2018-01-17)");
    // 4.設(shè)置請求參數(shù)
    ArrayList<BasicNameValuePair> parameters = new ArrayList<BasicNameValuePair>();
    parameters
        .add(new BasicNameValuePair(
            "json",
            "{\"depcity\":\"CAN\", \"arrcity\":\"WUH\", \"flightdate\":\"20180220\", \"adultnum\":\"1\", \"childnum\":\"0\", \"infantnum\":\"0\", \"cabinorder\":\"0\", \"airline\":\"1\", \"flytype\":\"0\", \"international\":\"0\", \"action\":\"0\", \"segtype\":\"1\", \"cache\":\"0\", \"preUrl\":\"\", \"isMember\":\"\"}"));
    httpPost.setEntity(new UrlEncodedFormEntity(parameters));
    // 5. 發(fā)起請求
    CloseableHttpClient httpClient = HttpClients.createDefault();
    CloseableHttpResponse response = httpClient.execute(httpPost);
    // 6.獲取返回值
    System.out.println(response != null);
  }

  public static void spiderCss() throws Exception {

    // 1.指定目標(biāo)網(wǎng)站
    String url = basePath +"/B2C40/dist/main/css/flight.css";
    // 2.發(fā)起請求
    HttpPost httpPost = new HttpPost(url);
    // 3. 設(shè)置請求參數(shù)
    httpPost.setHeader("Time-Local", getLocalDateTime());
    httpPost.setHeader("Requst",
        "POST /B2C40/query/jaxb/direct/query.ao HTTP/1.1");
    httpPost.setHeader("Request Method", "POST");
    httpPost.setHeader("Content-Type",
        "application/x-www-form-urlencoded; charset=UTF-8");
    httpPost.setHeader("Referer",
        "http://b2c.csair.com/B2C40/modules/bookingnew/main/flightSelectDirect.html");
    httpPost.setHeader("Remote Address", "192.168.56.1");
    httpPost.setHeader(
        "User-Agent",
        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36");
    httpPost.setHeader("Time-Iso8601", getISO8601Timestamp());
    httpPost.setHeader("Server Address", "192.168.56.80");
    httpPost.setHeader(
        "Cookie",
        "JSESSIONID=782121159357B98CA6112554CF44321E; sid=b5cc11e02e154ac5b0f3609332f86803; aid=8ae8768760927e280160bb348bef3e12; identifyStatus=N; userType4logCookie=M; userId4logCookie=13818791413; useridCookie=13818791413; userCodeCookie=13818791413; temp_zh=cou%3D0%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-13%3B%E5%B9%BF%E5%B7%9E-%E5%8C%97%E4%BA%AC%3B1%2C0%2C0%3B%26cou%3D1%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-17%3B%E5%B9%BF%E5%B7%9E-%E6%88%90%E9%83%BD%3B1%2C0%2C0%3B%26; JSESSIONID=782121159357B98CA6112554CF44321E; WT-FPC=id=211.103.142.26-608782688.30635197:lv=1516170718655:ss=1516170709449:fs=1513243317440:pn=2:vn=10; language=zh_CN; WT.al_flight=WT.al_hctype(S)%3AWT.al_adultnum(1)%3AWT.al_childnum(0)%3AWT.al_infantnum(0)%3AWT.al_orgcity1(CAN)%3AWT.al_dstcity1(CTU)%3AWT.al_orgdate1(2018-01-17)");
    // 4.設(shè)置請求參數(shù)
    ArrayList<BasicNameValuePair> parameters = new ArrayList<BasicNameValuePair>();
    parameters
        .add(new BasicNameValuePair(
            "json",
            "{\"depcity\":\"CAN\", \"arrcity\":\"WUH\", \"flightdate\":\"20180220\", \"adultnum\":\"1\", \"childnum\":\"0\", \"infantnum\":\"0\", \"cabinorder\":\"0\", \"airline\":\"1\", \"flytype\":\"0\", \"international\":\"0\", \"action\":\"0\", \"segtype\":\"1\", \"cache\":\"0\", \"preUrl\":\"\", \"isMember\":\"\"}"));
    httpPost.setEntity(new UrlEncodedFormEntity(parameters));
    // 5. 發(fā)起請求
    CloseableHttpClient httpClient = HttpClients.createDefault();
    CloseableHttpResponse response = httpClient.execute(httpPost);
    // 6.獲取返回值
    System.out.println(response != null);
  }

  public static void spiderPng() throws Exception {

    // 1.指定目標(biāo)網(wǎng)站
    String url =basePath + "/B2C40/dist/main/images/common.png";
    // 2.發(fā)起請求
    HttpPost httpPost = new HttpPost(url);
    // 3. 設(shè)置請求參數(shù)
    httpPost.setHeader("Time-Local", getLocalDateTime());
    httpPost.setHeader("Requst",
        "POST /B2C40/query/jaxb/direct/query.ao HTTP/1.1");
    httpPost.setHeader("Request Method", "POST");
    httpPost.setHeader("Content-Type",
        "application/x-www-form-urlencoded; charset=UTF-8");
    httpPost.setHeader(
        "Referer",
        "http://b2c.csair.com/B2C40/modules/bookingnew/main/flightSelectDirect.html?t=S&c1=CAN&c2=WUH&d1=2018-02-20&at=1&ct=0&it=0");
    httpPost.setHeader("Remote Address", "192.168.56.1");
    httpPost.setHeader(
        "User-Agent",
        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36");
    httpPost.setHeader("Time-Iso8601", getISO8601Timestamp());
    httpPost.setHeader("Server Address", "192.168.56.80");
    httpPost.setHeader(
        "Cookie",
        "JSESSIONID=782121159357B98CA6112554CF44321E; sid=b5cc11e02e154ac5b0f3609332f86803; aid=8ae8768760927e280160bb348bef3e12; identifyStatus=N; userType4logCookie=M; userId4logCookie=13818791413; useridCookie=13818791413; userCodeCookie=13818791413; temp_zh=cou%3D0%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-13%3B%E5%B9%BF%E5%B7%9E-%E5%8C%97%E4%BA%AC%3B1%2C0%2C0%3B%26cou%3D1%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-17%3B%E5%B9%BF%E5%B7%9E-%E6%88%90%E9%83%BD%3B1%2C0%2C0%3B%26; JSESSIONID=782121159357B98CA6112554CF44321E; WT-FPC=id=211.103.142.26-608782688.30635197:lv=1516170718655:ss=1516170709449:fs=1513243317440:pn=2:vn=10; language=zh_CN; WT.al_flight=WT.al_hctype(S)%3AWT.al_adultnum(1)%3AWT.al_childnum(0)%3AWT.al_infantnum(0)%3AWT.al_orgcity1(CAN)%3AWT.al_dstcity1(CTU)%3AWT.al_orgdate1(2018-01-17)");
    // 4.設(shè)置請求參數(shù)
    ArrayList<BasicNameValuePair> parameters = new ArrayList<BasicNameValuePair>();
    parameters
        .add(new BasicNameValuePair(
            "json",
            "{\"depcity\":\"CAN\", \"arrcity\":\"WUH\", \"flightdate\":\"20180220\", \"adultnum\":\"1\", \"childnum\":\"0\", \"infantnum\":\"0\", \"cabinorder\":\"0\", \"airline\":\"1\", \"flytype\":\"0\", \"international\":\"0\", \"action\":\"0\", \"segtype\":\"1\", \"cache\":\"0\", \"preUrl\":\"\", \"isMember\":\"\"}"));
    httpPost.setEntity(new UrlEncodedFormEntity(parameters));
    // 5. 發(fā)起請求
    CloseableHttpClient httpClient = HttpClients.createDefault();
    CloseableHttpResponse response = httpClient.execute(httpPost);
    // 6.獲取返回值
    System.out.println(response != null);
  }

  public static void spiderJpg() throws Exception {

    // 1.指定目標(biāo)網(wǎng)站
    String url = basePath +"/B2C40/dist/main/images/loadingimg.jpg";
    // 2.發(fā)起請求
    HttpPost httpPost = new HttpPost(url);
    // 3. 設(shè)置請求參數(shù)
    httpPost.setHeader("Time-Local", getLocalDateTime());
    httpPost.setHeader("Requst",
        "POST /B2C40/query/jaxb/direct/query.ao HTTP/1.1");
    httpPost.setHeader("Request Method", "POST");
    httpPost.setHeader("Content-Type",
        "application/x-www-form-urlencoded; charset=UTF-8");
    httpPost.setHeader(
        "Referer",
        "http://b2c.csair.com/B2C40/modules/bookingnew/main/flightSelectDirect.html?t=S&c1=CAN&c2=WUH&d1=2018-02-20&at=1&ct=0&it=0");
    httpPost.setHeader("Remote Address", "192.168.56.1");
    httpPost.setHeader(
        "User-Agent",
        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36");
    httpPost.setHeader("Time-Iso8601", getISO8601Timestamp());
    httpPost.setHeader("Server Address", "192.168.56.80");
    httpPost.setHeader(
        "Cookie",
        "JSESSIONID=782121159357B98CA6112554CF44321E; sid=b5cc11e02e154ac5b0f3609332f86803; aid=8ae8768760927e280160bb348bef3e12; identifyStatus=N; userType4logCookie=M; userId4logCookie=13818791413; useridCookie=13818791413; userCodeCookie=13818791413; temp_zh=cou%3D0%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-13%3B%E5%B9%BF%E5%B7%9E-%E5%8C%97%E4%BA%AC%3B1%2C0%2C0%3B%26cou%3D1%3Bsegt%3D%E5%8D%95%E7%A8%8B%3Btime%3D2018-01-17%3B%E5%B9%BF%E5%B7%9E-%E6%88%90%E9%83%BD%3B1%2C0%2C0%3B%26; JSESSIONID=782121159357B98CA6112554CF44321E; WT-FPC=id=211.103.142.26-608782688.30635197:lv=1516170718655:ss=1516170709449:fs=1513243317440:pn=2:vn=10; language=zh_CN; WT.al_flight=WT.al_hctype(S)%3AWT.al_adultnum(1)%3AWT.al_childnum(0)%3AWT.al_infantnum(0)%3AWT.al_orgcity1(CAN)%3AWT.al_dstcity1(CTU)%3AWT.al_orgdate1(2018-01-17)");
    // 4.設(shè)置請求參數(shù)
    ArrayList<BasicNameValuePair> parameters = new ArrayList<BasicNameValuePair>();
    parameters
        .add(new BasicNameValuePair(
            "json",
            "{\"depcity\":\"CAN\", \"arrcity\":\"WUH\", \"flightdate\":\"20180220\", \"adultnum\":\"1\", \"childnum\":\"0\", \"infantnum\":\"0\", \"cabinorder\":\"0\", \"airline\":\"1\", \"flytype\":\"0\", \"international\":\"0\", \"action\":\"0\", \"segtype\":\"1\", \"cache\":\"0\", \"preUrl\":\"\", \"isMember\":\"\"}"));
    httpPost.setEntity(new UrlEncodedFormEntity(parameters));
    // 5. 發(fā)起請求
    CloseableHttpClient httpClient = HttpClients.createDefault();
    CloseableHttpResponse response = httpClient.execute(httpPost);
    // 6.獲取返回值
    System.out.println(response != null);
  }

  public static String getLocalDateTime() {
    DateFormat df = new SimpleDateFormat("dd/MMM/yyyy'T'HH:mm:ss +08:00",
        Locale.ENGLISH);
    String nowAsISO = df.format(new Date());
    return nowAsISO;

  }

  public static String getISO8601Timestamp() {
    DateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss+08:00");
    String nowAsISO = df.format(new Date());
    return nowAsISO;
  }

  public static String getGoTime() {
    DateFormat df = new SimpleDateFormat("yyyy-MM-dd");
    String nowAsISO = df.format(new Date());
    return nowAsISO;
  }

  public static String getBackTime() {
    Date date = new Date();// 取時(shí)間
    Calendar calendar = new GregorianCalendar();
    calendar.setTime(date);
    calendar.add(calendar.DATE, +1);// 把日期往前減少一天，若想把日期向后推一天則將負(fù)數(shù)改為正數(shù)
    date = calendar.getTime();
    SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
    String dateString = formatter.format(date);
    return dateString;
  }
}

第六步：啟動(dòng)kafka

1.創(chuàng)建主題topic

[root@node01 bin]# kafka-topics.sh --zookeeper node01:2181 --partitions 3 
--replication-factor 3 --create --topic B2CDATA_COLLECTION1

2.開啟kafka消費(fèi)者

[root@node01 bin]# kafka-console-consumer.sh --bootstrap-server node01:9092,node02:9092,node03:9092 
--topic B2CDATA_COLLECTION1

第七步：開啟爬蟲程序并觀察結(jié)果

1.啟動(dòng)爬蟲程序

2.觀察消費(fèi)者窗口如下

第八步：啟動(dòng)kafka-manager觀察

1.啟動(dòng)kafka-manager

[root@node01 conf]# cd /export/servers/kafka-manager-1.3.3.23/bin/
[root@node01 bin]# ll
total 36
-rwxr-xr-x 1 root root 13747 May 1 06:27 kafka-manager
-rw-r--r-- 1 root root 9975 May 1 06:27 kafka-manager.bat
-rwxr-xr-x 1 root root 1383 May 1 06:27 log-config
-rw-r--r-- 1 root root  105 May 1 06:27 log-config.bat
[root@node01 bin]# 

#啟動(dòng)
[root@node01 bin]# ./kafka-manager

啟動(dòng)后的窗口：

2.瀏覽器訪問

瀏覽器輸入：node01:9000

kafka manager使用不做講解，觀察B2CDATA_COLLECTION1主題消費(fèi)情況：

​ 有三個(gè)分區(qū)，每個(gè)分區(qū)消費(fèi)的消息差多說明成功啦，

​ 如果不一樣，則是kafkalua.lua 腳本中沒有配置分區(qū)策略，默認(rèn)分區(qū)會(huì)導(dǎo)致 數(shù)據(jù)傾斜 我們需配置自己的分區(qū)策略！

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

標(biāo)簽：安康 泰安 福州 德宏 淮安 鷹潭 上海 樂山

巨人網(wǎng)絡(luò)通訊聲明：本文標(biāo)題《nginx lua集成kafka的實(shí)現(xiàn)方法》，本文關(guān)鍵詞  nginx,lua,集成,kafka,的,實(shí)現(xiàn),；如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題，煩請?zhí)峁┫嚓P(guān)信息告之我們，我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò)，涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《nginx lua集成kafka的實(shí)現(xiàn)方法》相關(guān)的同類信息！
  • 本頁收集關(guān)于nginx lua集成kafka的實(shí)現(xiàn)方法的相關(guān)信息資訊供網(wǎng)民參考！
    • 推薦文章
    国产一区二区女| 欧美诱惑福利视频| 天天舔天天操天天干| 青青草这里只有精品| 99re99热| 国产亚洲欧美aaaa| 久久97精品| 亚洲精品国产一区二区三区| 91亚洲午夜精品久久久久久| 草草草在线视频| 欧美性猛交xxx高清大费中文| www.日日夜夜| 成人综合网网址| 黄网在线播放| www在线视频观看| 亚洲国产精品人人爽夜夜爽| 欧美激情精品久久久久久免费印度| 精品久久久久久中文字幕一区奶水| 国产成人免费在线观看视频| 天干天干啦夜天天天视频| 免费国产阿v视频在线观看| 免费在线看污片| 国产成人一区二区在线观看| 国产人成在线视频| wwwww在线观看免费视频| 婷婷在线精品视频| 色综合久久综合中文综合网| 亚洲国产日本| 麻豆精品视频在线原创| 欧美hentaied在线观看| 法国空姐在线观看免费| 国产高清在线视频| 欧美另类久久久品| chinese全程对白| 中文字幕久久久av一区| 国产主播福利在线| 成人毛片一区二区三区| 日本中文字幕一区二区有码在线| 999在线观看视频| 国产jzjzjz丝袜老师水多| jizzjizzjizz中国| fc2ppv国产精品久久| 色哟哟亚洲精品一区二区| 欧美性猛交xxxx乱大交蜜桃| 久热精品视频在线播放| 美女精品自拍一二三四| 91日韩在线| 日韩一区二区三免费高清在线观看| 久久精品成人一区二区三区蜜臀| av成人激情| 蜜桃av在线播放| 欧美午夜电影网| 91国偷自产中文字幕久久| 91精品国产综合久久久久久久久久| 亚洲欧美精品日韩欧美| 国产午夜精品一区| 日本欧美韩国一区三区| 99麻豆久久久国产精品免费| 久久久久久久久久久久网站| 国产人妻互换一区二区| 四虎精品视频| 亚洲欧洲日韩在线| 欧美三级自拍| 久久久久久久网| 精品国产一区二区三区成人影院| 我家有个日本女人| 欧美大片国产精品| 久久婷婷一区二区三区| 久久综合伊人77777麻豆| 欧美大片免费高清观看| 91老师国产黑色丝袜在线| 最近中文字幕在线观看| 国产精品老牛| 在线成人动漫| 亚洲精品国产精华液| 国产日韩精品中文字无码| 精选一区二区三区四区五区| 日韩视频专区| 久久久久999| 亚洲欧美另类动漫| 美女一区二区视频| av在线播放天堂| 亚洲一区二区不卡免费| 在线观看国产一级片| av中文字幕av| 国产夫妻在线| 伊人久久久久久久久久| 一区二区三区在线观看免费| 色香蕉久久蜜桃| 久久91亚洲人成电影网站| blackedav金发美女大战黑人| 久久久久久久免费视频| 国产主播性色av福利精品一区| 夜夜躁很很躁日日躁麻豆| 亚洲国产日韩综合一区| 国产亚洲一卡2卡3卡4卡新区| 亚洲一区视频在线观看视频| 亚洲三级av| 欧美美女一区二区在线观看| 欧美一区二区三区的| 污污视频在线观看网站| 国产精品久久久久久久久晋中| 国产精品视频观看| 韩国精品主播一区二区在线观看| 日韩高清国产一区在线观看| www.日韩精品| 麻豆91精品91久久久的内涵| 国产精品日韩在线| 日韩一区二区av| 欧美主播一区二区三区美女| 国产喷白浆一区二区三区| 无码人妻精品一区二区三区温州| 国产91色在线观看| 凸凹人妻人人澡人人添| 中文在线天堂网| 成全视频在线播放大地| 日韩人妻无码精品久久久不卡| 国产在线观看a视频| 青青草影院在线观看| 无码人妻aⅴ一区二区三区| 国产精品扒开腿爽爽爽视频| 国产精品伦一区二区三区视频| 国产精品视频色| 男人天堂2017| 毛片一区二区三区| 亚洲欧美另类小说| 99热成人精品热久久66| 国产喷水福利在线视频| 91欧美日韩一区| 国产在线播放av| 九九热视频精品| 国产精品剧情一区二区在线观看| 艳女tv在线观看国产一区| 亚洲成av人片一区二区梦乃| 久久精品2019中文字幕| 亚洲一级一区| 日韩精品在线一区二区| 青青草国产精品一区二区| 亚洲第一在线综合网站| 亚洲欧美国产一区二区三区| 欧美高清一区二区| 欧美一级做性受免费大片免费| 欧美精品一区二区三区三州| 欧美精品久久一区二区| 久久99国产精品麻豆| 中文字幕av久久爽av| 西野翔中文久久精品国产| 国产成年精品| 亚洲人成网7777777国产| 免费亚洲电影在线| 亚洲成人黄色在线| 91精品国产综合久久福利| avhd101老司机| 91av在线视频观看| 亚洲а∨天堂久久精品2021| 国产精品九九九九九| 日韩中文第一页| gogogogo高清视频在线| 中日韩精品一区二区三区| 国产亚洲精品拍拍拍拍拍| 欧美成人性福生活免费看| 欧美福利在线视频| 国产乱人伦偷精品视频免下载| 成人激情免费视频| 欧美精品情趣视频| 日韩在线一区二区视频| 黄黄视频在线观看| 国产精品777| 一级片手机在线观看| 成人av动漫在线| 国产精品毛片久久久久久久久久99999999| 久久久久久久久久毛片| 亚洲午夜av在线| 伊人精品久久久久7777| 91啦中文在线观看| 免费99精品国产自在在线| 丁香婷婷在线观看| 午夜视频在线观看一区二区| av中文字幕在线免费观看| 伊人久久大香线蕉午夜av| 欧美 国产 日本| 99re66热这里只有精品4| 亚洲成人五区| 欧美性69xxxx肥| 久久精品国产亚洲aⅴ| 欧美极品欧美精品欧美图片| 久久综合免费视频影院| 男人av在线播放| 精品国产高清自在线一区二区三区| 欧美精品18| 欧美影院一区二区三区| 另类春色校园亚洲| 人人妻人人添人人爽欧美一区| a级免费在线观看| 国产精品综合色区在线观看| 美国十次了思思久久精品导航| 色婷婷香蕉在线一区二区| 欧美日韩国产bt| 日韩一区二区福利| 国产三级视频在线看| 亚洲电影在线一区二区三区| 天天搞夜夜操| 性欧美亚洲xxxx乳在线观看| 综合电影一区二区三区| 97视频在线观看免费高清完整版在线观看| 精品国产一区二区三区久久久| av免费不卡国产观看| 无码av免费精品一区二区三区| 国产日韩av在线播放| 无码人妻丰满熟妇区毛片蜜桃精品| 亚洲狠狠爱一区二区三区| 最近中文字幕大全中文字幕免费| 日本丶国产丶欧美色综合| 欧美成人免费全部观看天天性色| 91超薄肉色丝袜交足高跟凉鞋| 亚洲国产成人私人影院tom| 久久久久久久美女| caoprom在线| 国产欧美日韩综合| 免费一级欧美在线大片| 国产又粗又猛又黄又爽| 成年人黄视频在线观看| 欧美激情一区二区三区久久久| 亚洲a∨精品一区二区三区导航| 久久人人看视频| 国产精品视频网站在线观看| av一区二区不卡| 亚洲精品在线免费观看视频| 在线观看av网| 首页综合国产亚洲丝袜| 久久香蕉国产线看观看网| 国内国产区免费视频| 黄a免费视频| 北条麻妃在线| 精品国产av无码一区二区三区| 午夜精品一区二区三区在线视频| 天天操夜夜操国产精品| 先锋影音欧美四级| 成人动漫h在线观看| 欧美男体视频| 日韩1区2区3区| 亚洲а∨天堂久久精品2021| 一级片视频免费| 国产精品9999| 又色又爽的视频| 人人干人人爱人人爱| 国产剧情一区二区三区| 1区不卡电影| 99久久精品一区二区| 国产欧美一区二区三区在线老狼| 在线播放日韩专区| 欧美视频在线第一页| 911久久香蕉国产线看观看| 日本电影在线观看网站| 男女爱爱福利视频| 欧美激情一区二区久久久| 亚洲h视频在线观看| 国产伦精品一区二区三区视频黑人| 日本精品在线中文字幕| 在线播放日韩欧美| 久久国产精品72免费观看| 国模 一区 二区 三区| 国产视频1区| 日韩一级精品| 成人一级片免费看| 国产成人精品视频| 一级特黄aaa大片在线观看| 亚洲天堂中文字幕在线观看| 四色成人av永久网址| 日韩中文在线电影| 污视频在线免费观看一区二区三区| 欧美性xxxx18| 超薄肉色丝袜脚交一区二区| 亚洲欧美日韩在线| 欧美日韩国产免费| 99热免费精品| 欧美jjzz| 亚洲色图15p| 国产一级做a爱片久久毛片a| 在线国产一级| 97精品在线播放| 密臀av在线播放| 亚洲国产精品嫩草影院久久| 青青草成人网| 姝姝窝人体www聚色窝| 中文字幕一区二区不卡| 亚洲bt欧美bt精品777| 国产成人福利在线| 欧美国产1区2区| 日本边添边摸边做边爱的第三级| 亚洲国产精品人人爽夜夜爽| 国产亚洲观看| 在线视频免费在线观看一区二区| 国产成人av一区二区三区| 国产三级视频在线播放| 91蜜桃在线观看| 捆绑调教一区二区三区| 精品人妻一区二区三区换脸明星| 极品少妇xxxx精品少妇偷拍| 新版的欧美在线视频| 亚洲理论在线观看| 国产成人免费视频一区| 国产精品欧美久久久久一区二区| 视频一区在线免费观看| fc2在线中文字幕| 免费午夜一级| 男人的天堂视频网站| 亚洲人一二三区| 亚洲人成网站77777在线观看| 麻豆蜜桃在线观看| 日本一极黄色片| 欧美高清不卡| 七七久久电影网| 久久久精品中文字幕麻豆发布| 99久久亚洲| 成人精品在线视频| 91在线视频导航| 亚洲宅男一区| 免费黄色av网址| 国产精品久久久久久妇女| 相泽南亚洲一区二区在线播放| 国产精品字幕| 老司机深夜福利网站| av网站有哪些| 亚洲精品一区国产精品| 激情视频一区| 视频在线观看一区二区三区| 在线免费观看中文字幕|