Dubbo新增服務ip白名單,防止不法呼叫。
阿新 • • 發佈:2018-12-30
1.新增類ValidationFilter繼承阿里巴巴的Filter
package com.filter;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import com.alibaba.dubbo.rpc.*;
/**
* Description:
* author: LinQin
* date: 2018/06/08
*/
public class ValidationFilter implements Filter {
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
Properties prop = new Properties();
InputStream in = ValidationFilter.class.getResourceAsStream("/ipwhitelist.properties");
String clientIp = RpcContext.getContext().getRemoteHost();//客戶端ip
try {
prop.load(in);
String ipwhitelist = prop.getProperty("ipwhitelist");//ip白名單
if (ipwhitelist.contains(clientIp)) {
return invoker.invoke(invocation);
} else {
return new RpcResult(new Exception("ip地址:"
+ clientIp + "沒有訪問許可權" ));
}
} catch (IOException e) {
e.printStackTrace();
} catch (RpcException e) {
throw e;
} catch (Throwable t) {
throw new RpcException(t.getMessage(), t);
}
return invoker.invoke(invocation);
}
}
2.安裝阿里巴巴的約定新建配置檔案,指定上面的類
注意:路徑和配置檔名稱必須一致
com.alibaba.dubbo.rpc.Filter
validation=com.filter.ValidationFilter
3.配置ip白名單
resource 目錄
ipwhitelist.properties
ipwhitelist=192.168.1.19,192.168.1.158
4.配置服務端dubbo配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd
"
>
<!-- 提供方應用資訊,用於計算依賴關係 -->
<dubbo:application name="common-service" />
<!-- 使用zookeeper註冊中心暴露服務地址 -->
<dubbo:registry protocol="zookeeper" address="193.112.76.194:2181" />
<!-- 用dubbo協議在20880埠暴露服務 -->
<dubbo:protocol name="dubbo" port="20880" />
<dubbo:provider filter="validation" delay="-1" timeout="6000" retries="0"/>
<!-- 使用者服務介面 -->
<dubbo:service interface="com.service.UserService" ref="userService" />
<bean id="userService" class="com.service.UserServiceImpl"></bean>
</beans>
filter="validation"
表示開啟攔截。
啟動流程:
啟動會先讀取dubbo的配置filter的值,對應METE-INF裡面的配置的值,找到class進行過濾。
測試:
啟動服務,由其他ip的消費者呼叫,報錯
這個錯誤剛好是我們Fileter類丟擲的資訊。
不過一般會使用自定義異常進行出來,然後丟擲自定義異常。spring框架統一對這類的許可權進行特有的頁面提示。或者是json返回。