`
xiaoliang330
  • 浏览: 116000 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

RPC调用之微博 motan

 
阅读更多
这边文章将偏实战, 至于motan,可以去了解如何实现、比普通的http请求的优越之处等


这里贴出应用motan的代码




Client端

ClassPathXmlApplicationContext ctx= new ClassPathXmlApplicationContext("classpath:motan_client.xml");


NaturalRankingService naturalRankingService = ctx.getBean(NaturalRankingService.class);
		NaturalResponse naturalResponse = naturalRankingService.recommend(recommendRequest);



client端配置motan_client.xml
<?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: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">
	
	<!-- 配置注册中心,客户端与服务端使用相同的配置中心 
	
	-->
	<motan:registry regProtocol="zookeeper" name="client_zookeeper" address="172.0.0.1:2181,172.0.0.2:2181,172.0.0.3:2181"/>
	

	
	<!--codec,serialization一定要跟服务端配置的保持一致,否则无法正常调用 -->
	<motan:protocol id="client_protocol" default="false" name="motan"  codec="motan2" serialization="fastjson"
                    requestTimeout="1000"  maxContentLength="2048576"
                    maxClientConnection="300" minClientConnection="100" loadbalance="roundrobin"/>
    
    <!-- mock测试: filter="statistic,mock"  check="true" directUrl="127.0.0.1:8002"   mock="true" -->
    <motan:basicReferer registry="client_zookeeper"  
    					group="ads-ranking-natural"  accessLog="false" shareChannel="false" 
                        id="clientBasicConfig" 
                        filter="statistic"
                        />
    
    <!-- reference to the remote service     directUrl="localhost:8002" -->
    <motan:referer id="NaturalRankingService" interface="com.zz.common.interfaces.NaturalRankingService"  
    basicReferer="clientBasicConfig" 
     />
</beans>




jar包中的接口service

public interface NaturalRankingService {
	public NaturalResponse recommend(RecommendRequest request) ;
}



jar包依赖

<dependencies>
		 <!-- dependencies blow were only needed for motan-based features -->
	  <dependency>
	        <groupId>com.weibo</groupId>
	        <artifactId>motan-core</artifactId>
	        <version>${motanVersion}</version>
	    </dependency>
	    <dependency>
	        <groupId>com.weibo</groupId>
	        <artifactId>motan-transport-netty</artifactId>
	        <version>${motanVersion}</version>
	    </dependency>
	    <dependency>
	        <groupId>com.weibo</groupId>
	        <artifactId>motan-springsupport</artifactId>
	        <version>${motanVersion}</version>
	    </dependency>
	    <dependency>
		    <groupId>com.weibo</groupId>
		    <artifactId>motan-registry-zookeeper</artifactId>
		    <version>RELEASE</version>
		</dependency>
		
		<!-- dependencies blow were only needed for spring-based features -->
	    <dependency>
	        <groupId>org.springframework</groupId>
	        <artifactId>spring-context</artifactId>
	        <version>${spring.version}</version>
	    </dependency>
	    <dependency>
	        <groupId>org.slf4j</groupId>
	        <artifactId>slf4j-log4j12</artifactId>
	        <version>${slf4jVersion}</version>
    	</dependency>
		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-api</artifactId>
			<version>${slf4jVersion}</version>
		</dependency>
	</dependencies>






server端实现  server端也加入上面的jar

public class NaturalRankinServicegImpl implements NaturalRankingService { 
   @Override
	public NaturalResponse recommend(RecommendRequest request) {
           //实现代码
          return null;
         }
}



server端的配置motan_server.xml

<?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: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">

	<!-- 配置注册中心,客户端与服务端使用相同的配置中心 
	
	-->
	
	
	<motan:registry regProtocol="zookeeper" name="server_zookeeper" address="172.0.0.1:2181,172.0.0.2:2181,172.0.0.3:2181"/>	

	
	<!-- 协议配置。为防止多个业务配置冲突,推荐使用id表示具体协议。serialization="kryo" codec="compressMotan"-->
    <motan:protocol id="server_protocol" default="false" name="motan"  codec="motan2" serialization="fastjson"
                    requestTimeout="1000" maxServerConnection="8000" maxContentLength="2048576"
                    maxWorkerThread="300" minWorkerThread="100" />
                    
    <!-- service implemention bean -->
    <bean id="NaturalRankinServicegImpl" class="io.batcloud.service.impl.NaturalRankinServicegImpl" />
    
    
    <!-- exporting service by motan -->
    <motan:basicService requestTimeout="1000" export="server_protocol:8102" registry="server_zookeeper"
                        group="ads-ranking-natural" accessLog="false" shareChannel="false" 
                        id="serviceBasicConfig" filter="statistic"/>
    <motan:service interface="com.zz.common.interfaces.NaturalRankingService" ref= "NaturalRankinServicegImpl" basicService="serviceBasicConfig" />
</beans>




这样便完成了motan RPC的调用应用, 当然中间还有 服务注册中心zookeeper的应用
分享到:
评论

相关推荐

    介绍 Golang 简单服务框架,提供如下功能 高性能TCP网络通信服务端&客户端.rar

    rpcx是一个类似阿里巴巴 Dubbo 和微博 Motan 的分布式的RPC服务框架,基于Golang net/rpc实现。 谈起分布式的RPC框架,比较出名的是阿里巴巴的dubbo,包括由当当网维护的dubbox。 不知道dubbo在阿里的内部竞争中败给...

    motan,用于快速开发高性能分布式服务的远程过程调用(rpc)框架。.zip

    - **请求分发**:消费者发起请求时,Motan 负载均衡器会根据预设策略选择一个服务提供者进行调用。 - **通信协议**:Motan 使用自定义的二进制协议,通过 HTTP/2 进行传输,提高了通信效率。 - **容错机制**:当...

    motan 源码

    Motan 是一个由微博开发并广泛应用的高性能、易用的分布式远程服务调用框架。它旨在简化分布式系统中的服务间通信问题,提高系统的可伸缩性和灵活性。在深入理解 Motan 源码之前,我们先来了解一下其核心概念和组件...

    jboot远程调用笔记和demo,能用!

    本笔记将深入探讨JBoot的远程调用功能,以及如何结合Consul和Motan实现这一机制。 首先,让我们理解JBoot RPC的核心概念。RPC是一种协议,使得一个程序可以在不理解底层网络协议的情况下,调用另一个远程系统上的...

    基于Java的motan跨语言远程过程调用RPC框架设计源码

    本项目为Java编写的motan跨语言RPC框架设计源码,总计包含722个文件,涵盖455个Java源文件、53个XML配置文件、51个JavaScript文件、28个CSS文件、22个PNG图像文件、15个HTML文件、14个Markdown文件、9个属性文件、8...

    基于Java的motan高性能分布式服务远程调用框架设计源码

    该项目是一款基于Java的高性能分布式服务远程调用框架——motan的设计源码,涵盖744个文件,包括475个Java源文件、54个XML配置文件、51个JavaScript文件、28个CSS文件、22个PNG图像文件、15个HTML文件、14个Markdown...

    Java+motan.zip

    Motan,作为阿里巴巴开源的一款高性能、轻量级的RPC(远程过程调用)框架,提供了简单易用的API,使得开发者能够方便地实现跨进程的服务调用。ZooKeeper,由Apache基金会开发,是一款分布式协调服务,常用于管理...

    motan:跨语言远程过程调用(RPC)框架,用于快速开发高性能分布式服务

    Motan是用于快速开发高性能分布式服务的跨语言远程过程调用(RPC)框架。 Motan生态系统中的相关项目: 是golang的实现。 是PHP客户端,可以直接或通过Motan-go代理与Motan服务器进行交互。 是基于的Lua(Luajit...

    Java分布式RPC服务框架教程,包括DubboDubbox,Motan,gRPC..zip

    Motan是微博开源的分布式服务框架,设计目标也是简化分布式服务的开发和维护。Motan提供了简单易用的API,支持多种通信协议,如HTTP、TCP等,并且支持水平扩展,具有良好的性能和稳定性。其特色在于其易于集成的...

    Go-rpcx是一个类似Dubbo和Motan的分布式的RPC服务框架

    Go-rpcx 是一个高度可扩展的、功能丰富的分布式RPC(远程过程调用)服务框架,它的设计灵感来源于阿里巴巴的Dubbo和微博的Motan。这个框架是用Golang语言构建的,利用了Golang的net/rpc库,为开发者提供了高效、稳定...

    Python-Doge是一个基于Python的高性能开源RPC框架

    与阿里巴巴的Dubbo和微博的Motan等知名RPC框架类似,Doge致力于为Python开发者提供高效、稳定且易于使用的解决方案。 **一、RPC基础与Doge的核心特性** 1. **RPC原理**:远程过程调用允许一个程序调用另一个不在...

    go-rpc-programming-guide.pdf

    目前存在多种RPC框架,它们大致可以分为两类:一类是偏重于服务治理的框架,如阿里巴巴开源的Dubbo和Motan等,这些框架支持高性能远程调用、服务发现与治理,非常适合大型服务的微服务化拆分及管理,但是它们与特定...

    基于Kilim、Promise JDeferred、Zookeeper和Spring Boot的协程分布式调用聚合框架设计源码

    该项目是一款基于Kilim、Promise JDeferred、Zookeeper和Spring Boot技术的协程驱动分布式...该框架支持Nepxion Thunder、Dubbo和Motan等RPC调用的集成,并通过规则配置实现调用聚合,适用于构建高性能的分布式系统。

    RPC那些事儿

    RPC调用方式多样,包括: 1. **基于URL的调用**:通过指定URL直接调用远程服务。 2. **动态代理**:通过Java动态代理实现调用,如JDK的Proxy类。 3. **异步访问**:使用 CompletableFutures、Promise或RxJava等工具...

    新浪微博 - 微博Service Mesh实践

    通过Motan,微博能够在Java服务之间以及Golang、PHP服务之间进行有效的服务调用和管理。 微服务容器化和DevOps的趋势让微博开始探索Service Mesh技术。Service Mesh通过sidecar的形式将网络代理注入到每一个微服务...

    RPC 轻量级框架高并发处理

    描述中的博客链接可能详细介绍了某个特定的RPC实现,例如可能是作者自己开发的轻量级框架,或者是对现有框架如Dubbo、gRPC或Motan的分析。遗憾的是,由于没有实际内容,我们无法深入了解该框架的具体实现和特性。 ...

    p_rpc:Java分布式RPC服务框架示例,包括 DubboDubbox, Motan, gRPC

    Motan是微博开源的远程调用框架,它设计简洁,易于使用,并且具有良好的性能。Motan支持负载均衡、故障切换、服务路由等特性。在示例中,你可以学习如何设置服务接口、服务提供者和服务消费者,以及如何配置Motan...

    motan-openresty:基于OpenResty的跨语言RPC框架,用于快速开发高性能分布式服务

    Motan-OpenResty则是在OpenResty之上构建的RPC框架,它继承了OpenResty的高性能特性,同时解决了不同语言服务之间的通信问题。Motan-OpenResty支持多种编程语言,如Java、Python、Go等,使得服务间的交互变得更加...

    基于motan红豆live后台开发经验分析

    1. **Motan框架简介**:Motan是基于Java实现的轻量级RPC框架,它提供了高性能、高可用的服务调用解决方案,支持多种协议如HTTP、TCP等,并具备良好的服务治理能力,如负载均衡、熔断、降级等。 2. **红豆Live项目...

    基于Netty+Kyro+Zookeeper的RPC框架.zip

    &gt; **注意** :我们这里说的 RPC 框架指的是:可以让客户端直接调用服务端方法就像调用本地方法一样简单的框架,比如我前面介绍的 Dubbo、Motan、gRPC 这些。 如果需要和 HTTP 协议打交道,解析和封装 HTTP 请求和...

Global site tag (gtag.js) - Google Analytics