解决bug

Author: 王井方

.idea/libraries/Maven__com_google_guava_guava_15_0.xml

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>cxf3.1</artifactId>
+        <groupId>com.cxf.my</groupId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>com.jd.vd</groupId>
+    <artifactId>common</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+
+</project>

.idea/libraries/Maven__io_dropwizard_metrics_metrics_core_3_1_0.xml

@@ -0,0 +1,52 @@
+package com.jd.vd.common.util;
+
+public class ResultUtil {
+    private int code;
+    private String msg;
+    private Object data;
+    public static ResultUtil SUCCESS = new ResultUtil(0, "success", null);
+
+    public static ResultUtil success(Object data) {
+        return new ResultUtil(0, "success", data);
+    }
+
+    public ResultUtil(int code, String msg, Object data) {
+        this.code = code;
+        this.msg = msg;
+        this.data = data;
+    }
+
+    public static ResultUtil getInstance(int code, String msg, Object data) {
+        return new ResultUtil(code, msg, data);
+    }
+
+    public int getCode() {
+        return this.code;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return this.msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public Object getData() {
+        return this.data;
+    }
+
+    public void setData(Object data) {
+        this.data = data;
+    }
+
+    @Override
+    public String toString() {
+        return "ResultUtil [code=" + code + ", msg=" + msg + ", data=" + data + "]";
+    }
+}
+

.idea/libraries/Maven__io_dropwizard_metrics_metrics_healthchecks_3_1_0.xml

@@ -6,6 +6,7 @@
         <artifactId>cxf3.1</artifactId>
         <groupId>com.cxf.my</groupId>
         <version>0.0.1-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

common/pom.xml

@@ -0,0 +1,9 @@
+基本需求：
+1. 到网上爬取信息
+2. 将信息存放到es里面
+3. 能够根据关键字爬取信息
+4. 能够关联推荐
+5. 能够限制接口访问流量
+7. 接口可以时rpc类型的接口
+8. 接口可以被网关代理
+9. 能够识别机器流量

common/src/main/java/com/jd/vd/common/util/ResultUtil.java

@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>cxf3.1</artifactId>
+        <groupId>com.cxf.my</groupId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <dependencies>
+        <dependency>
+            <groupId>com.jd.vd</groupId>
+            <artifactId>common</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+    <artifactId>gateway-module</artifactId>
+
+
+</project>

elastic-search/pom.xml

@@ -1,9 +1,8 @@
 package io.study.gateway.client;
 
-import com.sun.deploy.config.ClientConfig;
+
 import io.netty.channel.EventLoop;
 import io.netty.util.concurrent.Promise;
-import io.study.gateway.balance.ILoadBalance;
 import io.study.gateway.config.ProxyConfig;
 
 public interface ClientOrigin {

elastic-search/readme.md

@@ -75,7 +75,7 @@ public void operationComplete(Future<? super PooledConnection> future) throws Ex
                         operateConnectSuccess(endpoint,context,connectionPromise.get());
                     }else{
 
-                        throw new BizException("proxy.err_get_connection",future.cause());
+                        throw new BizException("proxy.err_get_connection");
                     }
                 }
             });
@@ -86,7 +86,7 @@ private void onConnectionFail(){
 
     }
     private void operateConnectSuccess(ProxyEndpoint endpoint,StreamContext context,PooledConnection connection) {
-        //context.setTargetNode(connection.getChannel().localAddress());
+        //context.setTargetNode(connection.getChannel().localAddress());RequestStatFilter
         context.setToChannel(connection);
         connection.getChannel().attr(GatewayConstant.KEY_PROXY_ENDPOINT).set(endpoint);
         endpoint.proxy();