| package com.alibaba.csp.sentinel.adapter.dubbo; |
| |
| import com.alibaba.csp.sentinel.node.ClusterNode; |
| import com.alibaba.csp.sentinel.slots.clusterbuilder.ClusterBuilderSlot; |
| |
| import org.junit.Assert; |
| import org.junit.Test; |
| import org.springframework.context.support.ClassPathXmlApplicationContext; |
| |
| /** |
| * 运行该用例的时候需要加入JVM参数:-Djava.net.preferIPv4Stack=true, |
| * 否则可能会抛出{@code java.lang.IllegalStateException: Can't assign requested address} |
| * |
| * @author leyou |
| */ |
| public class DubboProviderTest { |
| |
| private final String resource = "com.alibaba.csp.sentinel.adapter.dubbo.DemoService:sayHello(java.lang.String,int)"; |
| |
| @Test |
| public void testProviderFilter() throws Exception { |
| ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( |
| new String[] {"spring-dubbo-provider-filter.xml"}); |
| context.start(); |
| DemoService demoService = (DemoService)context.getBean("demoService"); |
| String result = demoService.sayHello("Test dubbo provider filter", 1); |
| System.out.println("result=" + result); |
| ClusterNode node = ClusterBuilderSlot.getClusterNode(resource); |
| Thread.sleep(1000 * 60 * 100); |
| Assert.assertNotNull(node); |
| } |
| } |