[incubator-dubbo] branch dev-metadata updated: Add demo change for tagrouter

[liujun]

This is an automated email from the ASF dual-hosted git repository.

liujun pushed a commit to branch dev-metadata
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/dev-metadata by this push:
     new c0be5e5  Add demo change for tagrouter
c0be5e5 is described below

commit c0be5e536e13e686f0251f2d88d4d6bcfe9406bc
Author: ken.lj <ken.lj...@gmail.com>
AuthorDate: Fri Sep 7 16:17:16 2018 +0800

    Add demo change for tagrouter
---
 .../main/java/org/apache/dubbo/config/AbstractReferenceConfig.java    | 3 +++
 .../src/main/java/org/apache/dubbo/demo/consumer/Consumer.java        | 4 ++++
 .../src/main/java/org/apache/dubbo/demo/provider/DemoServiceImpl.java | 2 ++
 .../src/main/resources/META-INF/spring/dubbo-demo-provider.xml        | 3 ++-
 4 files changed, 11 insertions(+), 1 deletion(-)

diff --git 
a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java
 
b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java
index 552ccf1..e451d1e 100644
--- 
a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java
+++ 
b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java
@@ -61,6 +61,9 @@ public abstract class AbstractReferenceConfig extends 
AbstractInterfaceConfig {
     // group
     protected String group;
 
+    // enable dynamic tag
+    protected String enabledynamictag;
+
     public Boolean isCheck() {
         return check;
     }
diff --git 
a/dubbo-demo/dubbo-demo-consumer/src/main/java/org/apache/dubbo/demo/consumer/Consumer.java
 
b/dubbo-demo/dubbo-demo-consumer/src/main/java/org/apache/dubbo/demo/consumer/Consumer.java
index 420ab2d..58466b1 100644
--- 
a/dubbo-demo/dubbo-demo-consumer/src/main/java/org/apache/dubbo/demo/consumer/Consumer.java
+++ 
b/dubbo-demo/dubbo-demo-consumer/src/main/java/org/apache/dubbo/demo/consumer/Consumer.java
@@ -17,6 +17,7 @@
 package org.apache.dubbo.demo.consumer;
 
 import org.apache.dubbo.demo.DemoService;
+import org.apache.dubbo.rpc.RpcContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 
 public class Consumer {
@@ -33,8 +34,11 @@ public class Consumer {
         while (true) {
             try {
                 Thread.sleep(1000);
+                RpcContext.getContext().setAttachment("tag", "tag1");
                 String hello = demoService.sayHello("world"); // call remote 
method
                 System.out.println(hello); // get result
+                RpcContext.getContext().setAttachment("tag", "tag3");
+                RpcContext.getContext().setAttachment("force.tag", "true");
                 String routeMethod1 = demoService.routeMethod1(); // call 
remote method
                 System.out.println(routeMethod1); // get result
             } catch (Throwable throwable) {
diff --git 
a/dubbo-demo/dubbo-demo-provider/src/main/java/org/apache/dubbo/demo/provider/DemoServiceImpl.java
 
b/dubbo-demo/dubbo-demo-provider/src/main/java/org/apache/dubbo/demo/provider/DemoServiceImpl.java
index cdfcd5b..c0cbcf2 100644
--- 
a/dubbo-demo/dubbo-demo-provider/src/main/java/org/apache/dubbo/demo/provider/DemoServiceImpl.java
+++ 
b/dubbo-demo/dubbo-demo-provider/src/main/java/org/apache/dubbo/demo/provider/DemoServiceImpl.java
@@ -32,11 +32,13 @@ public class DemoServiceImpl implements DemoService {
 
     @Override
     public String routeMethod1() {
+        System.out.println("routeMethod1 was called: " + 
RpcContext.getContext().getLocalAddress());
         return "routeMethod1";
     }
 
     @Override
     public String routeMethod2() {
+        System.out.println("routeMethod2 was called: " + 
RpcContext.getContext().getLocalAddress());
         return "routeMethod2";
     }
 
diff --git 
a/dubbo-demo/dubbo-demo-provider/src/main/resources/META-INF/spring/dubbo-demo-provider.xml
 
b/dubbo-demo/dubbo-demo-provider/src/main/resources/META-INF/spring/dubbo-demo-provider.xml
index ed08464..30275e4 100644
--- 
a/dubbo-demo/dubbo-demo-provider/src/main/resources/META-INF/spring/dubbo-demo-provider.xml
+++ 
b/dubbo-demo/dubbo-demo-provider/src/main/resources/META-INF/spring/dubbo-demo-provider.xml
@@ -23,12 +23,13 @@
 
     <!-- provider's application name, used for tracing dependency relationship 
-->
     <dubbo:application name="demo-provider"/>
+    <dubbo:provider tag="tag3"/>
 
     <!-- use multicast registry center to export service -->
     <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
 
     <!-- use dubbo protocol to export service on port 20880 -->
-    <dubbo:protocol name="dubbo" port="20880"/>
+    <dubbo:protocol name="dubbo" port="-1"/>
 
     <!-- service implementation, as same as regular local bean -->
     <bean id="demoService" 
class="org.apache.dubbo.demo.provider.DemoServiceImpl"/>