whatsmars-motan

whatsmars-spring-boot/src/main/java/com/itlong/whatsmars/spring/boot/controller/DemoRpcClient.java

+/*
+ *  Copyright 2009-2016 Weibo, Inc.
+ *
+ *    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 com.itlong.whatsmars.spring.boot.controller;
+
+import com.weibo.motan.demo.service.MotanDemoService;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class DemoRpcClient {
+
+    public static void main(String[] args) throws InterruptedException {
+
+        ApplicationContext ctx = new ClassPathXmlApplicationContext(new String[]{"classpath:spring/motan_demo_client.xml"});
+
+        MotanDemoService service = (MotanDemoService) ctx.getBean("motanDemoReferer");
+        for (int i = 0; i < Integer.MAX_VALUE; i++) {
+            System.out.println(service.hello("motan" + i));
+            Thread.sleep(500);
+        }
+        System.out.println("motan demo is finish.");
+        System.exit(0);
+    }
+
+}

whatsmars-spring-boot/src/main/resources/spring/motan_demo_client_direct.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~  Copyright 2009-2016 Weibo, Inc.
+  ~
+  ~    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.
+  -->
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:motan="http://api.weibo.com/schema/motan"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
+       http://api.weibo.com/schema/motan http://api.weibo.com/schema/motan.xsd">
+	<import resource="classpath*:spring/configloader.xml"/>
+	<!-- 注册中心配置 -->
+	<motan:registry regProtocol="local" name="motanDemo" />
+
+	<!-- motan协议配置 -->
+	<motan:protocol default="true" name="motan" haStrategy="failover"
+		loadbalance="activeWeight" maxClientConnection="10" minClientConnection="2"/>
+
+	<!-- 通用referer基础配置 -->
+	<motan:basicReferer requestTimeout="200" accessLog="false"
+		retries="2" group="motan-demo-rpc" module="motan-demo-rpc"
+		application="myMotanDemo" protocol="motan" registry="motanDemo"
+		id="motantestClientBasicConfig" throwException="false" check="true" />
+
+	<!-- 具体referer配置。使用方通过beanid使用服务接口类 -->
+	<motan:referer id="motanDemoReferer"
+		directUrl="localhost:8002"
+		interface="com.weibo.motan.demo.service.MotanDemoService"
+		connectTimeout="300" requestTimeout="300" basicReferer="motantestClientBasicConfig" />
+
+</beans>
\ No newline at end of file