淘寶SOA框架dubbo學習（4）--參數驗證

開始，先說一句，仍是用maven的好

一、因爲沒用maven，和對dubbo不是很瞭解的緣由，此次，總由於jar包不對，而致使：dubbo客戶端程序，啓動不起來

因此決定：將原來用過的全部jar包所有去，將dubbo-demo-provider-2.5.4-SNAPSHOT/lib下的全部jar包所有導入項目中

一切就OK了

二、服務消費者代碼

import java.util.Set;

import javax.validation.ConstraintViolation;
import javax.validation.ConstraintViolationException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.alibaba.dubbo.demo.ValidationParameter;
import com.alibaba.dubbo.demo.ValidationService;
import com.alibaba.dubbo.rpc.RpcException;

public class Consumer {

    /**
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] { "classpath:consumer.xml" });
        context.start();

        // DemoService demoService = (DemoService)
        // context.getBean("demoService");
        // while (true) {
        // String hello = demoService.sayHello("world");
        // System.out.println(hello);
        //
        // Thread.sleep(100);
        // }


        ValidationService validationService = (ValidationService) context.getBean("validationService");

        while (true) {
            ValidationParameter parameter = new ValidationParameter();
            parameter.setAge(2);
            parameter.setEmail("han@qq.com");

            try {
                String result = validationService.intsert(parameter);

                System.out.println(result);
            } catch (RpcException e) { // 拋出的是RpcException
                ConstraintViolationException ve = (ConstraintViolationException) e.getCause(); // 裏面嵌了一個ConstraintViolationException
                Set<ConstraintViolation<?>> violations = ve.getConstraintViolations(); // 能夠拿到一個驗證錯誤詳細信息的集合
                System.out.println(violations);
            }
        }
    }
}

三、服務消費者配置文件

<?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="consumer-of-helloworld-app"  />
 
    <!-- 使用zookeeper註冊中心暴露發現服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
 
    <!-- 生成遠程服務代理，能夠和本地bean同樣使用demoService -->
    <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService"
    	 retries="2"
    	  />
 
    <!-- 生成遠程服務代理，能夠和本地bean同樣使用demoService -->
    <dubbo:reference id="validationService" interface="com.alibaba.dubbo.demo.ValidationService"
    	 retries="2" validation="true"
    	  />
 
</beans>

注：重點關注一下，帶有下面信息的那一行，就OK了，此處代表，是在客戶端側進行參數驗證

validation="true"

四、服務提供者配置文件

<?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="hello-world"  />
 
    <!-- 使用zookeeper註冊中心暴露發現服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
 
    <!-- 用dubbo協議在20880端口暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />
 
    <!-- 聲明須要暴露的服務接口 -->
    <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />
 
    <!-- 和本地bean同樣實現服務 -->
    <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl" />
 
    <!-- 聲明須要暴露的服務接口 -->
    <dubbo:service interface="com.alibaba.dubbo.demo.ValidationService" ref="validationService" />
 
    <!-- 和本地bean同樣實現服務 -->
    <bean id="validationService" class="com.alibaba.dubbo.demo.provider.ValidationServiceImpl" />
 
</beans>

五、服務消費者和提供者共用的類和接口

package com.alibaba.dubbo.demo;

public interface ValidationService {
    @interface Intsert {
    }

    String intsert(ValidationParameter parameter);
}

package com.alibaba.dubbo.demo;

import java.io.Serializable;

import javax.validation.constraints.Max;
import javax.validation.constraints.Min;
import javax.validation.constraints.Pattern;

public class ValidationParameter implements Serializable {
    private static final long serialVersionUID = 3469571402386167794L;

    @Pattern(regexp = "^\\s*\\w+(?:\\.{0,1}[\\w-]+)*@[a-zA-Z0-9]+(?:[-.][a-zA-Z0-9]+)*\\.[a-zA-Z]+\\s*$")
    private String email;

    @Min(18)
    // 最小值
    @Max(100)
    // 最大值
    private int age;

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

}

六、服務提供者接口實現類

package com.alibaba.dubbo.demo.provider;

import com.alibaba.dubbo.demo.ValidationParameter;
import com.alibaba.dubbo.demo.ValidationService;

public class ValidationServiceImpl implements ValidationService {
    @Override
    public String intsert(ValidationParameter parameter) {
        return parameter.getEmail() + "==" + parameter.getAge();
    }
}

七、運行客戶端程序時，控制檯會輸出如下信息：

[ConstraintViolationImpl{interpolatedMessage='最小不能小於18', propertyPath=age, rootBeanClass=class com.alibaba.dubbo.demo.ValidationParameter, messageTemplate='{javax.validation.constraints.Min.message}'}]

八、OK，此時已經能夠驗證，參數驗證已經開始起做用了。