diff --git a/4-governance/dubbo-samples-tagrouter-static/README.md b/4-governance/dubbo-samples-tagrouter-static/README.md new file mode 100644 index 0000000000..604af65086 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/README.md @@ -0,0 +1,22 @@ +# governance dubbo using tag router static +the same effect with project [dubbo-samples-tagrouter](..%2Fdubbo-samples-tagrouter),but use static tag in xml file +```xml + + + + + +``` +1. step1 run `BasicProvider.java` + +> it will start an zookeeper and register two service with dubbo port 20880 with `tag2` +2. step2 run `BasicProviderOtherPort.java` +> it will register another two service with dubbo port 20881 with `tag1` +3. step3 run `BasicConsumer.java` or [DemoServiceIT.java](src%2Ftest%2Fjava%2Forg%2Fapache%2Fdubbo%2Fsamples%2Fgovernance%2FDemoServiceIT.java) +> it will consume as blow role +> * All consumer taged by `tag1` come from provider taged by `tag1` in port 20881 +> * All consumer taged by `tag2` come from provider taged by `tag2` in port 20880 + +This strategy can be used to reduce `time to return` by route service in some IDC through tag the same tags \ No newline at end of file diff --git a/4-governance/dubbo-samples-tagrouter-static/case-configuration.yml b/4-governance/dubbo-samples-tagrouter-static/case-configuration.yml new file mode 100644 index 0000000000..00f10ec711 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/case-configuration.yml @@ -0,0 +1,68 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +services: + zookeeper: + image: zookeeper:latest + + dubbo-samples-tagrouter1: + type: app + basedir: . + mainClass: org.apache.dubbo.samples.governance.BasicProvider + systemProps: + - zookeeper.address=zookeeper + - zookeeper.port=2181 + - dubbo.port=20880 + waitPortsBeforeRun: + - zookeeper:2181 + checkPorts: + - 20880 + checkLog: "dubbo service started" + depends_on: + - zookeeper + + dubbo-samples-tagrouter2: + type: app + basedir: . + mainClass: org.apache.dubbo.samples.governance.BasicProvider + systemProps: + - zookeeper.address=zookeeper + - zookeeper.port=2181 + - dubbo.port=20881 + waitPortsBeforeRun: + - zookeeper:2181 + checkPorts: + - 20881 + checkLog: "dubbo service started" + depends_on: + - zookeeper + + dubbo-samples-tagrouter-test: + type: test + basedir: . + tests: + - "**/*IT.class" + systemProps: + - zookeeper.address=zookeeper + - zookeeper.port=2181 + waitPortsBeforeRun: + - zookeeper:2181 + - dubbo-samples-tagrouter1:20880 + - dubbo-samples-tagrouter2:20881 + depends_on: + - zookeeper + - dubbo-samples-tagrouter1 + - dubbo-samples-tagrouter2 diff --git a/4-governance/dubbo-samples-tagrouter-static/case-versions.conf b/4-governance/dubbo-samples-tagrouter-static/case-versions.conf new file mode 100644 index 0000000000..20c45c863f --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/case-versions.conf @@ -0,0 +1,25 @@ +# +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + + +# Supported component versions of the test case + +# Spring app +dubbo.version=2.7*, 3.* +spring.version=4.*, 5.* +java.version= [<= 11] diff --git a/4-governance/dubbo-samples-tagrouter-static/pom.xml b/4-governance/dubbo-samples-tagrouter-static/pom.xml new file mode 100644 index 0000000000..48b52d4097 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/pom.xml @@ -0,0 +1,145 @@ + + + + + org.apache.dubbo + 1.0-SNAPSHOT + + 4.0.0 + + dubbo-samples-tagrouter-static + Dubbo Samples Tag Router static + Dubbo Samples Tag Router static + + 1.8 + 1.8 + 3.0.7 + 4.3.29.RELEASE + 4.13.1 + 3.7.0 + + + + + + org.springframework + spring-framework-bom + ${spring.version} + pom + import + + + + org.apache.dubbo + dubbo-bom + ${dubbo.version} + pom + import + + + + org.apache.dubbo + dubbo-dependencies-zookeeper + ${dubbo.version} + pom + + + + junit + junit + ${junit.version} + + + + + + + org.apache.dubbo + dubbo + + + + org.apache.dubbo + dubbo-dependencies-zookeeper + pom + + + + junit + junit + test + + + + org.springframework + spring-test + test + + + + + + + javax.annotation + + [1.11,) + + + + javax.annotation + javax.annotation-api + 1.3.2 + + + + + + + + + org.apache.maven.plugins + maven-compiler-plugin + ${maven-compiler-plugin.version} + + ${source.level} + ${target.level} + + + + + + + + apache.snapshots.https + Apache Development Snapshot Repository + https://repository.apache.org/content/repositories/snapshots + default + + false + + + true + daily + + + + diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicConsumer.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicConsumer.java new file mode 100644 index 0000000000..aa3f63fa8a --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicConsumer.java @@ -0,0 +1,48 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance; + +import org.apache.dubbo.rpc.RpcContext; +import org.apache.dubbo.samples.governance.api.DemoService; +import org.apache.dubbo.samples.governance.api.DemoService2; + +import org.springframework.context.support.ClassPathXmlApplicationContext; + +import static org.apache.dubbo.common.constants.CommonConstants.TAG_KEY; +import static org.apache.dubbo.rpc.Constants.FORCE_USE_TAG; + +public class BasicConsumer { + + public static void main(String[] args) { + ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-demo-consumer.xml"); + context.start(); + DemoService demoService = context.getBean("demoService", DemoService.class); + DemoService2 demoService2 = context.getBean("demoService2", DemoService2.class); + + RpcContext.getContext().setAttachment(TAG_KEY, "tag1"); + String hello = demoService.sayHello("world"); + System.out.println(hello); + + RpcContext.getContext().setAttachment(FORCE_USE_TAG, "true"); + RpcContext.getContext().setAttachment(TAG_KEY, "tag2"); + String hello2 = demoService2.sayHello("world again"); + System.out.println(hello2); + } +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicProvider.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicProvider.java new file mode 100644 index 0000000000..bf3a4a3263 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicProvider.java @@ -0,0 +1,38 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance; + +import org.springframework.context.support.ClassPathXmlApplicationContext; + +import java.util.concurrent.CountDownLatch; + +public class BasicProvider { + + public static void main(String[] args) throws Exception { + new EmbeddedZooKeeper(2181, false).start(); + + ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-demo-provider-20880.xml"); + context.start(); + + System.out.println("dubbo service started"); + new CountDownLatch(1).await(); + } + +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicProviderOtherPort.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicProviderOtherPort.java new file mode 100644 index 0000000000..b80e003ec3 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/BasicProviderOtherPort.java @@ -0,0 +1,36 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance; + +import org.springframework.context.support.ClassPathXmlApplicationContext; + +import java.util.concurrent.CountDownLatch; + +public class BasicProviderOtherPort { + + public static void main(String[] args) throws Exception { + ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-demo-provider-20881.xml"); + context.start(); + + System.out.println("dubbo service started"); + new CountDownLatch(1).await(); + } + +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/EmbeddedZooKeeper.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/EmbeddedZooKeeper.java new file mode 100644 index 0000000000..c4ed039972 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/EmbeddedZooKeeper.java @@ -0,0 +1,250 @@ +/* + * Copyright 2014 the original author or authors. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.dubbo.samples.governance; + +import org.apache.zookeeper.server.ServerConfig; +import org.apache.zookeeper.server.ZooKeeperServerMain; +import org.apache.zookeeper.server.quorum.QuorumPeerConfig; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.SmartLifecycle; +import org.springframework.util.ErrorHandler; +import org.springframework.util.SocketUtils; + +import java.io.File; +import java.lang.reflect.Method; +import java.util.Properties; +import java.util.UUID; + +/** + * from: https://github.com/spring-projects/spring-xd/blob/v1.3.1.RELEASE/spring-xd-dirt/src/main/java/org/springframework/xd/dirt/zookeeper/ZooKeeperUtils.java + *

+ * Helper class to start an embedded instance of standalone (non clustered) ZooKeeper. + *

+ * NOTE: at least an external standalone server (if not an ensemble) are recommended, even for + * {@link org.springframework.xd.dirt.server.singlenode.SingleNodeApplication} + * + * @author Patrick Peralta + * @author Mark Fisher + * @author David Turanski + */ +public class EmbeddedZooKeeper implements SmartLifecycle { + + /** + * Logger. + */ + private static final Logger logger = LoggerFactory.getLogger(EmbeddedZooKeeper.class); + + /** + * ZooKeeper client port. This will be determined dynamically upon startup. + */ + private final int clientPort; + + /** + * Whether to auto-start. Default is true. + */ + private boolean autoStartup = true; + + /** + * Lifecycle phase. Default is 0. + */ + private int phase = 0; + + /** + * Thread for running the ZooKeeper server. + */ + private volatile Thread zkServerThread; + + /** + * ZooKeeper server. + */ + private volatile ZooKeeperServerMain zkServer; + + /** + * {@link ErrorHandler} to be invoked if an Exception is thrown from the ZooKeeper server thread. + */ + private ErrorHandler errorHandler; + + private boolean daemon = true; + + /** + * Construct an EmbeddedZooKeeper with a random port. + */ + public EmbeddedZooKeeper() { + clientPort = SocketUtils.findAvailableTcpPort(); + } + + /** + * Construct an EmbeddedZooKeeper with the provided port. + * + * @param clientPort port for ZooKeeper server to bind to + */ + public EmbeddedZooKeeper(int clientPort, boolean daemon) { + this.clientPort = clientPort; + this.daemon = daemon; + } + + /** + * Returns the port that clients should use to connect to this embedded server. + * + * @return dynamically determined client port + */ + public int getClientPort() { + return this.clientPort; + } + + /** + * Specify whether to start automatically. Default is true. + * + * @param autoStartup whether to start automatically + */ + public void setAutoStartup(boolean autoStartup) { + this.autoStartup = autoStartup; + } + + /** + * {@inheritDoc} + */ + @Override + public boolean isAutoStartup() { + return this.autoStartup; + } + + /** + * Specify the lifecycle phase for the embedded server. + * + * @param phase the lifecycle phase + */ + public void setPhase(int phase) { + this.phase = phase; + } + + /** + * {@inheritDoc} + */ + @Override + public int getPhase() { + return this.phase; + } + + /** + * {@inheritDoc} + */ + @Override + public boolean isRunning() { + return (zkServerThread != null); + } + + /** + * Start the ZooKeeper server in a background thread. + *

+ * Register an error handler via {@link #setErrorHandler} in order to handle + * any exceptions thrown during startup or execution. + */ + @Override + public synchronized void start() { + if (zkServerThread == null) { + zkServerThread = new Thread(new ServerRunnable(), "ZooKeeper Server Starter"); + zkServerThread.setDaemon(daemon); + zkServerThread.start(); + } + } + + /** + * Shutdown the ZooKeeper server. + */ + @Override + public synchronized void stop() { + if (zkServerThread != null) { + // The shutdown method is protected...thus this hack to invoke it. + // This will log an exception on shutdown; see + // https://issues.apache.org/jira/browse/ZOOKEEPER-1873 for details. + try { + Method shutdown = ZooKeeperServerMain.class.getDeclaredMethod("shutdown"); + shutdown.setAccessible(true); + shutdown.invoke(zkServer); + } catch (Exception e) { + throw new RuntimeException(e); + } + + // It is expected that the thread will exit after + // the server is shutdown; this will block until + // the shutdown is complete. + try { + zkServerThread.join(5000); + zkServerThread = null; + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + logger.warn("Interrupted while waiting for embedded ZooKeeper to exit"); + // abandoning zk thread + zkServerThread = null; + } + } + } + + /** + * Stop the server if running and invoke the callback when complete. + */ + @Override + public void stop(Runnable callback) { + stop(); + callback.run(); + } + + /** + * Provide an {@link ErrorHandler} to be invoked if an Exception is thrown from the ZooKeeper server thread. If none + * is provided, only error-level logging will occur. + * + * @param errorHandler the {@link ErrorHandler} to be invoked + */ + public void setErrorHandler(ErrorHandler errorHandler) { + this.errorHandler = errorHandler; + } + + /** + * Runnable implementation that starts the ZooKeeper server. + */ + private class ServerRunnable implements Runnable { + + @Override + public void run() { + try { + Properties properties = new Properties(); + File file = new File(System.getProperty("java.io.tmpdir") + + File.separator + UUID.randomUUID()); + file.deleteOnExit(); + properties.setProperty("dataDir", file.getAbsolutePath()); + properties.setProperty("clientPort", String.valueOf(clientPort)); + + QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig(); + quorumPeerConfig.parseProperties(properties); + + zkServer = new ZooKeeperServerMain(); + ServerConfig configuration = new ServerConfig(); + configuration.readFrom(quorumPeerConfig); + + zkServer.runFromConfig(configuration); + } catch (Exception e) { + if (errorHandler != null) { + errorHandler.handleError(e); + } else { + logger.error("Exception running embedded ZooKeeper", e); + } + } + } + } + +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/api/DemoService.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/api/DemoService.java new file mode 100644 index 0000000000..bde5f6eb6a --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/api/DemoService.java @@ -0,0 +1,26 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance.api; + +public interface DemoService { + + String sayHello(String name); + +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/api/DemoService2.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/api/DemoService2.java new file mode 100644 index 0000000000..828d87c919 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/api/DemoService2.java @@ -0,0 +1,26 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance.api; + +public interface DemoService2 { + + String sayHello(String name); + +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/impl/DemoServiceImpl.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/impl/DemoServiceImpl.java new file mode 100644 index 0000000000..87ed7417b0 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/impl/DemoServiceImpl.java @@ -0,0 +1,36 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance.impl; + +import org.apache.dubbo.rpc.RpcContext; +import org.apache.dubbo.samples.governance.api.DemoService; + +import java.text.SimpleDateFormat; +import java.util.Date; + +public class DemoServiceImpl implements DemoService { + + @Override + public String sayHello(String name) { + System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] Hello " + + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress()); + return "Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress(); + } +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/impl/DemoServiceImpl2.java b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/impl/DemoServiceImpl2.java new file mode 100644 index 0000000000..31fa42bff1 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/java/org/apache/dubbo/samples/governance/impl/DemoServiceImpl2.java @@ -0,0 +1,36 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance.impl; + +import org.apache.dubbo.rpc.RpcContext; +import org.apache.dubbo.samples.governance.api.DemoService2; + +import java.text.SimpleDateFormat; +import java.util.Date; + +public class DemoServiceImpl2 implements DemoService2 { + + @Override + public String sayHello(String name) { + System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] Hello " + name + + ", request from consumer: " + RpcContext.getContext().getRemoteAddress()); + return "Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress(); + } +} diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/resources/log4j.properties b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/log4j.properties new file mode 100644 index 0000000000..f30fda0d71 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/log4j.properties @@ -0,0 +1,25 @@ +# +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# +# +###set log levels### +log4j.rootLogger=info, stdout +###output to the console### +log4j.appender.stdout=org.apache.log4j.ConsoleAppender +log4j.appender.stdout.Target=System.out +log4j.appender.stdout.layout=org.apache.log4j.PatternLayout +log4j.appender.stdout.layout.ConversionPattern=[%d{dd/MM/yy hh:mm:ss:sss z}] %t %5p %c{2}: %m%n \ No newline at end of file diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-consumer.xml b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-consumer.xml new file mode 100644 index 0000000000..dae469f14a --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-consumer.xml @@ -0,0 +1,37 @@ + + + + + + + + + + + + + + + + diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-provider-20880.xml b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-provider-20880.xml new file mode 100644 index 0000000000..1be914d44b --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-provider-20880.xml @@ -0,0 +1,43 @@ + + + + + + + + + + + + + + + + + + + + + + diff --git a/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-provider-20881.xml b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-provider-20881.xml new file mode 100644 index 0000000000..09a94d58de --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/main/resources/spring/dubbo-demo-provider-20881.xml @@ -0,0 +1,43 @@ + + + + + + + + + + + + + + + + + + + + + + diff --git a/4-governance/dubbo-samples-tagrouter-static/src/test/java/org/apache/dubbo/samples/governance/DemoServiceIT.java b/4-governance/dubbo-samples-tagrouter-static/src/test/java/org/apache/dubbo/samples/governance/DemoServiceIT.java new file mode 100644 index 0000000000..3be8887f05 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter-static/src/test/java/org/apache/dubbo/samples/governance/DemoServiceIT.java @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.dubbo.samples.governance; + +import org.apache.dubbo.rpc.RpcContext; +import org.apache.dubbo.rpc.RpcException; +import org.apache.dubbo.samples.governance.api.DemoService; + +import org.junit.Assert; +import org.junit.BeforeClass; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; +import org.springframework.test.context.ContextConfiguration; +import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; + +import static org.apache.dubbo.common.constants.CommonConstants.TAG_KEY; +import static org.apache.dubbo.rpc.Constants.FORCE_USE_TAG; + +@RunWith(SpringJUnit4ClassRunner.class) +@ContextConfiguration(locations = {"classpath:/spring/dubbo-demo-consumer.xml"}) +public class DemoServiceIT { + @Autowired + @Qualifier("demoService") + private DemoService demoService; + + @Test + public void testDemoService1() throws Exception { + for (int i = 0; i < 10; i++) { + RpcContext.getContext().setAttachment(FORCE_USE_TAG, "true"); + RpcContext.getContext().setAttachment(TAG_KEY, "tag1"); + Assert.assertTrue(demoService.sayHello("world").contains("20881")); + } + } + + @Test + public void testDemoService2() throws Exception { + for (int i = 0; i < 10; i++) { + RpcContext.getContext().setAttachment(FORCE_USE_TAG, "true"); + RpcContext.getContext().setAttachment(TAG_KEY, "tag2"); + Assert.assertTrue(demoService.sayHello("world").contains("20880")); + } + } + + @Test(expected = RpcException.class) + public void testDemoService3() throws Exception { + RpcContext.getContext().setAttachment(TAG_KEY, "tag3"); + demoService.sayHello("world"); + } +} diff --git a/4-governance/dubbo-samples-tagrouter/README.md b/4-governance/dubbo-samples-tagrouter/README.md new file mode 100644 index 0000000000..171122114b --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter/README.md @@ -0,0 +1,27 @@ +# governance dubbo using tag router +1. step1 run `BasicProvider.java` + +> it will start an zookeeper and register two service with dubbo port 20880 +2. step2 run `BasicProviderOtherPort.java` +> it will register another two service with dubbo port 20881 +3. step3 run `RuleUtil.java`, +> it will read the route rule defined by [dubbo-routers-tag.yml](src%2Fmain%2Fresources%2Fdubbo-routers-tag.yml) +```yaml +--- +force: false +runtime: true +enabled: true +priority: 1 +key: governance-tagrouter-provider +tags: +- name: tag1 + addresses: ["*.*.*.*:20881"] +- name: tag2 + addresses: ["*.*.*.*:20880"] +... +``` + +6. step4 run `BasicConsumer.java` +> it will consume service by rule defined by yml file +> * All consumer taged by `tag1` come from provider in port 20881 +> * All consumer taged by `tag2` come from provider in port 20880 \ No newline at end of file diff --git a/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/BasicProvider.java b/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/BasicProvider.java index 033bf625a4..bf3a4a3263 100644 --- a/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/BasicProvider.java +++ b/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/BasicProvider.java @@ -26,7 +26,9 @@ public class BasicProvider { public static void main(String[] args) throws Exception { - ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-demo-provider.xml"); + new EmbeddedZooKeeper(2181, false).start(); + + ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-demo-provider-20880.xml"); context.start(); System.out.println("dubbo service started"); diff --git a/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/BasicProviderOtherPort.java b/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/BasicProviderOtherPort.java new file mode 100644 index 0000000000..b80e003ec3 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/BasicProviderOtherPort.java @@ -0,0 +1,36 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +package org.apache.dubbo.samples.governance; + +import org.springframework.context.support.ClassPathXmlApplicationContext; + +import java.util.concurrent.CountDownLatch; + +public class BasicProviderOtherPort { + + public static void main(String[] args) throws Exception { + ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-demo-provider-20881.xml"); + context.start(); + + System.out.println("dubbo service started"); + new CountDownLatch(1).await(); + } + +} diff --git a/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/EmbeddedZooKeeper.java b/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/EmbeddedZooKeeper.java new file mode 100644 index 0000000000..c4ed039972 --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter/src/main/java/org/apache/dubbo/samples/governance/EmbeddedZooKeeper.java @@ -0,0 +1,250 @@ +/* + * Copyright 2014 the original author or authors. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.dubbo.samples.governance; + +import org.apache.zookeeper.server.ServerConfig; +import org.apache.zookeeper.server.ZooKeeperServerMain; +import org.apache.zookeeper.server.quorum.QuorumPeerConfig; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.SmartLifecycle; +import org.springframework.util.ErrorHandler; +import org.springframework.util.SocketUtils; + +import java.io.File; +import java.lang.reflect.Method; +import java.util.Properties; +import java.util.UUID; + +/** + * from: https://github.com/spring-projects/spring-xd/blob/v1.3.1.RELEASE/spring-xd-dirt/src/main/java/org/springframework/xd/dirt/zookeeper/ZooKeeperUtils.java + *

+ * Helper class to start an embedded instance of standalone (non clustered) ZooKeeper. + *

+ * NOTE: at least an external standalone server (if not an ensemble) are recommended, even for + * {@link org.springframework.xd.dirt.server.singlenode.SingleNodeApplication} + * + * @author Patrick Peralta + * @author Mark Fisher + * @author David Turanski + */ +public class EmbeddedZooKeeper implements SmartLifecycle { + + /** + * Logger. + */ + private static final Logger logger = LoggerFactory.getLogger(EmbeddedZooKeeper.class); + + /** + * ZooKeeper client port. This will be determined dynamically upon startup. + */ + private final int clientPort; + + /** + * Whether to auto-start. Default is true. + */ + private boolean autoStartup = true; + + /** + * Lifecycle phase. Default is 0. + */ + private int phase = 0; + + /** + * Thread for running the ZooKeeper server. + */ + private volatile Thread zkServerThread; + + /** + * ZooKeeper server. + */ + private volatile ZooKeeperServerMain zkServer; + + /** + * {@link ErrorHandler} to be invoked if an Exception is thrown from the ZooKeeper server thread. + */ + private ErrorHandler errorHandler; + + private boolean daemon = true; + + /** + * Construct an EmbeddedZooKeeper with a random port. + */ + public EmbeddedZooKeeper() { + clientPort = SocketUtils.findAvailableTcpPort(); + } + + /** + * Construct an EmbeddedZooKeeper with the provided port. + * + * @param clientPort port for ZooKeeper server to bind to + */ + public EmbeddedZooKeeper(int clientPort, boolean daemon) { + this.clientPort = clientPort; + this.daemon = daemon; + } + + /** + * Returns the port that clients should use to connect to this embedded server. + * + * @return dynamically determined client port + */ + public int getClientPort() { + return this.clientPort; + } + + /** + * Specify whether to start automatically. Default is true. + * + * @param autoStartup whether to start automatically + */ + public void setAutoStartup(boolean autoStartup) { + this.autoStartup = autoStartup; + } + + /** + * {@inheritDoc} + */ + @Override + public boolean isAutoStartup() { + return this.autoStartup; + } + + /** + * Specify the lifecycle phase for the embedded server. + * + * @param phase the lifecycle phase + */ + public void setPhase(int phase) { + this.phase = phase; + } + + /** + * {@inheritDoc} + */ + @Override + public int getPhase() { + return this.phase; + } + + /** + * {@inheritDoc} + */ + @Override + public boolean isRunning() { + return (zkServerThread != null); + } + + /** + * Start the ZooKeeper server in a background thread. + *

+ * Register an error handler via {@link #setErrorHandler} in order to handle + * any exceptions thrown during startup or execution. + */ + @Override + public synchronized void start() { + if (zkServerThread == null) { + zkServerThread = new Thread(new ServerRunnable(), "ZooKeeper Server Starter"); + zkServerThread.setDaemon(daemon); + zkServerThread.start(); + } + } + + /** + * Shutdown the ZooKeeper server. + */ + @Override + public synchronized void stop() { + if (zkServerThread != null) { + // The shutdown method is protected...thus this hack to invoke it. + // This will log an exception on shutdown; see + // https://issues.apache.org/jira/browse/ZOOKEEPER-1873 for details. + try { + Method shutdown = ZooKeeperServerMain.class.getDeclaredMethod("shutdown"); + shutdown.setAccessible(true); + shutdown.invoke(zkServer); + } catch (Exception e) { + throw new RuntimeException(e); + } + + // It is expected that the thread will exit after + // the server is shutdown; this will block until + // the shutdown is complete. + try { + zkServerThread.join(5000); + zkServerThread = null; + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + logger.warn("Interrupted while waiting for embedded ZooKeeper to exit"); + // abandoning zk thread + zkServerThread = null; + } + } + } + + /** + * Stop the server if running and invoke the callback when complete. + */ + @Override + public void stop(Runnable callback) { + stop(); + callback.run(); + } + + /** + * Provide an {@link ErrorHandler} to be invoked if an Exception is thrown from the ZooKeeper server thread. If none + * is provided, only error-level logging will occur. + * + * @param errorHandler the {@link ErrorHandler} to be invoked + */ + public void setErrorHandler(ErrorHandler errorHandler) { + this.errorHandler = errorHandler; + } + + /** + * Runnable implementation that starts the ZooKeeper server. + */ + private class ServerRunnable implements Runnable { + + @Override + public void run() { + try { + Properties properties = new Properties(); + File file = new File(System.getProperty("java.io.tmpdir") + + File.separator + UUID.randomUUID()); + file.deleteOnExit(); + properties.setProperty("dataDir", file.getAbsolutePath()); + properties.setProperty("clientPort", String.valueOf(clientPort)); + + QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig(); + quorumPeerConfig.parseProperties(properties); + + zkServer = new ZooKeeperServerMain(); + ServerConfig configuration = new ServerConfig(); + configuration.readFrom(quorumPeerConfig); + + zkServer.runFromConfig(configuration); + } catch (Exception e) { + if (errorHandler != null) { + errorHandler.handleError(e); + } else { + logger.error("Exception running embedded ZooKeeper", e); + } + } + } + } + +} diff --git a/4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider.xml b/4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider-20880.xml similarity index 96% rename from 4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider.xml rename to 4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider-20880.xml index 1a7725465a..8f01b7fb43 100644 --- a/4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider.xml +++ b/4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider-20880.xml @@ -31,7 +31,7 @@ - + diff --git a/4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider-20881.xml b/4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider-20881.xml new file mode 100644 index 0000000000..fbe332c66a --- /dev/null +++ b/4-governance/dubbo-samples-tagrouter/src/main/resources/spring/dubbo-demo-provider-20881.xml @@ -0,0 +1,43 @@ + + + + + + + + + + + + + + + + + + + + + + diff --git a/4-governance/pom.xml b/4-governance/pom.xml index 9efe164529..3edff91028 100644 --- a/4-governance/pom.xml +++ b/4-governance/pom.xml @@ -38,6 +38,7 @@ dubbo-samples-spring-hystrix dubbo-samples-ssl dubbo-samples-tagrouter + dubbo-samples-tagrouter-static dubbo-samples-zipkin \ No newline at end of file