这边文章将偏实战, 至于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的应用
分享到:
相关推荐
rpcx是一个类似阿里巴巴 Dubbo 和微博 Motan 的分布式的RPC服务框架,基于Golang net/rpc实现。 谈起分布式的RPC框架,比较出名的是阿里巴巴的dubbo,包括由当当网维护的dubbox。 不知道dubbo在阿里的内部竞争中败给...
- **请求分发**:消费者发起请求时,Motan 负载均衡器会根据预设策略选择一个服务提供者进行调用。 - **通信协议**:Motan 使用自定义的二进制协议,通过 HTTP/2 进行传输,提高了通信效率。 - **容错机制**:当...
Motan 是一个由微博开发并广泛应用的高性能、易用的分布式远程服务调用框架。它旨在简化分布式系统中的服务间通信问题,提高系统的可伸缩性和灵活性。在深入理解 Motan 源码之前,我们先来了解一下其核心概念和组件...
本笔记将深入探讨JBoot的远程调用功能,以及如何结合Consul和Motan实现这一机制。 首先,让我们理解JBoot RPC的核心概念。RPC是一种协议,使得一个程序可以在不理解底层网络协议的情况下,调用另一个远程系统上的...
本项目为Java编写的motan跨语言RPC框架设计源码,总计包含722个文件,涵盖455个Java源文件、53个XML配置文件、51个JavaScript文件、28个CSS文件、22个PNG图像文件、15个HTML文件、14个Markdown文件、9个属性文件、8...
该项目是一款基于Java的高性能分布式服务远程调用框架——motan的设计源码,涵盖744个文件,包括475个Java源文件、54个XML配置文件、51个JavaScript文件、28个CSS文件、22个PNG图像文件、15个HTML文件、14个Markdown...
Motan,作为阿里巴巴开源的一款高性能、轻量级的RPC(远程过程调用)框架,提供了简单易用的API,使得开发者能够方便地实现跨进程的服务调用。ZooKeeper,由Apache基金会开发,是一款分布式协调服务,常用于管理...
Motan是用于快速开发高性能分布式服务的跨语言远程过程调用(RPC)框架。 Motan生态系统中的相关项目: 是golang的实现。 是PHP客户端,可以直接或通过Motan-go代理与Motan服务器进行交互。 是基于的Lua(Luajit...
Motan是微博开源的分布式服务框架,设计目标也是简化分布式服务的开发和维护。Motan提供了简单易用的API,支持多种通信协议,如HTTP、TCP等,并且支持水平扩展,具有良好的性能和稳定性。其特色在于其易于集成的...
Go-rpcx 是一个高度可扩展的、功能丰富的分布式RPC(远程过程调用)服务框架,它的设计灵感来源于阿里巴巴的Dubbo和微博的Motan。这个框架是用Golang语言构建的,利用了Golang的net/rpc库,为开发者提供了高效、稳定...
与阿里巴巴的Dubbo和微博的Motan等知名RPC框架类似,Doge致力于为Python开发者提供高效、稳定且易于使用的解决方案。 **一、RPC基础与Doge的核心特性** 1. **RPC原理**:远程过程调用允许一个程序调用另一个不在...
目前存在多种RPC框架,它们大致可以分为两类:一类是偏重于服务治理的框架,如阿里巴巴开源的Dubbo和Motan等,这些框架支持高性能远程调用、服务发现与治理,非常适合大型服务的微服务化拆分及管理,但是它们与特定...
该项目是一款基于Kilim、Promise JDeferred、Zookeeper和Spring Boot技术的协程驱动分布式...该框架支持Nepxion Thunder、Dubbo和Motan等RPC调用的集成,并通过规则配置实现调用聚合,适用于构建高性能的分布式系统。
RPC调用方式多样,包括: 1. **基于URL的调用**:通过指定URL直接调用远程服务。 2. **动态代理**:通过Java动态代理实现调用,如JDK的Proxy类。 3. **异步访问**:使用 CompletableFutures、Promise或RxJava等工具...
通过Motan,微博能够在Java服务之间以及Golang、PHP服务之间进行有效的服务调用和管理。 微服务容器化和DevOps的趋势让微博开始探索Service Mesh技术。Service Mesh通过sidecar的形式将网络代理注入到每一个微服务...
描述中的博客链接可能详细介绍了某个特定的RPC实现,例如可能是作者自己开发的轻量级框架,或者是对现有框架如Dubbo、gRPC或Motan的分析。遗憾的是,由于没有实际内容,我们无法深入了解该框架的具体实现和特性。 ...
Motan是微博开源的远程调用框架,它设计简洁,易于使用,并且具有良好的性能。Motan支持负载均衡、故障切换、服务路由等特性。在示例中,你可以学习如何设置服务接口、服务提供者和服务消费者,以及如何配置Motan...
Motan-OpenResty则是在OpenResty之上构建的RPC框架,它继承了OpenResty的高性能特性,同时解决了不同语言服务之间的通信问题。Motan-OpenResty支持多种编程语言,如Java、Python、Go等,使得服务间的交互变得更加...
1. **Motan框架简介**:Motan是基于Java实现的轻量级RPC框架,它提供了高性能、高可用的服务调用解决方案,支持多种协议如HTTP、TCP等,并具备良好的服务治理能力,如负载均衡、熔断、降级等。 2. **红豆Live项目...
> **注意** :我们这里说的 RPC 框架指的是:可以让客户端直接调用服务端方法就像调用本地方法一样简单的框架,比如我前面介绍的 Dubbo、Motan、gRPC 这些。 如果需要和 HTTP 协议打交道,解析和封装 HTTP 请求和...