Lagom是一个集成ES/CQRS的Reactive微服务框架(微服务)

作者:xinwang_m@163.com
发布时间: 2020-07-21 05:02:18 (4年前)
关键词: Lagom；ES CQRS；Reactive微服务框架
摘要:

                              
                                     Lagom是一个集成了微服务、RESTful、CQRS、EventSoucring、Reactive编程等最潮概念的开发框架。

Lagom是一个集成了微服务、RESTful、CQRS、EventSoucring、Reactive编程等最潮概念的开发框架。2014年预测：为什么REST 微服务和异步 编程是一种趋势？，如今变成了现实。Lagom缺省都是是异步的，所有的异步都是基于 Akka Stream(scala)和JDK8 CompletionStage API 实现的。提供以下主要功能：1.服务API服务API 提供一种申明和实现服务接口的方法，这个服务可以被客户端直接消费调用，客户端通过服务定位器发现它所要访问的服务。这个服务API提供服务之间调用异步的Stream方式 ，同时也支持传统的同步请求-响应方式调用。2.持久API提供事件溯源event-sourced实体持久化，支持CQRS. Lagom跨集群节点管理持久实体的分布，激活分区sharding和水平扩展. Cassandra以out-of-the-box作为数据库.3.开发环境开发环境能够运行你的服务，支持Lagom底层基础设施，使用一个命令，能在代码改变时热加载你的服务，没有琐碎的脚本来设置和管理你的开发环境，代之以Lagom, 一个开发者能够很快和其他开发者合作，开发新的服务或加入现有的开发团队。4.产品环境Lightbend ConductR是以out-of-the-box支持生产环境，支持简单部署 监视和扩展规模。以hellowworld为案例：HelloService的接口代码如下：public interface HelloService extends Service { @Override default Descriptor descriptor() { return named(“helloservice”).with( restCall(Method.GET, “/api/hello/:id”, hello()) ).withAutoAcl(true); }ServiceCall<String, NotUsed, String> hello(); } 你的服务接口代码必须继承框架的Service，并提供Service#descriptor方法实现. Service#descriptor必须返回Descriptor对象，这个对象定义了 服务名称和服务对外的REST端点。 这里是定义了REST API的调用URL，这样你就可以 <a href="http://localhost:9000/api/hello/World访问这个HelloService微服务了。">http://localhost:9000/api/hello/World访问这个HelloService微服务了。</a>然后编写你的HellpService接口的具体实现子类：public class HelloServiceImpl implements HelloService {private final PersistentEntityRegistry persistentEntityRegistry;@Inject public HelloServiceImpl(PersistentEntityRegistry persistentEntityRegistry) { this.persistentEntityRegistry = persistentEntityRegistry; persistentEntityRegistry.register(HelloWorld.class); }@Override public ServiceCall<String, NotUsed, String> hello() { return (id, request) -> { // Look up the hello world entity for the given ID. PersistentEntityRef ref = persistentEntityRegistry.refFor(HelloWorld.class, id); // Ask the entity the Hello command. return ref.ask(new Hello(id, Optional.empty())); }; } } 这段代码内容主要是访问持久层，实现实体的查询操作，首先在HelloServiceImpl注册了PersistentEntityRegistry ，然后向PersistentEntityRegistry 注册了HelloWorld.class这个实体对象，在查询方法ServiceCall中，根据ID向PersistentEntityRegistry发出查询命令。这里的 PersistentEntityRegistry是框架自身提供以Event Sourcing 和 CQRS方式访问数据库中的数据实体。最后一步运行该代码：$ cd my-first-system $ activator … (booting up)
<blockquote>runAll [info] Starting embedded Cassandra server ………. [info] Cassandra server running at 127.0.0.1:4000 [info] Service locator is running at <a href="http://localhost:8000">http://localhost:8000</a> [info] Service gateway is running at <a href="http://localhost:9000">http://localhost:9000</a> [info] Service helloworld-impl listening for HTTP on 0:0:0:0:0:0:0:0:24266 [info] Service hellostream-impl listening for HTTP on 0:0:0:0:0:0:0:0:26230 (Services started, use Ctrl+D to stop and go back to the console…) ,Lagom是一个集成了微服务、RESTful、CQRS、EventSoucring、Reactive编程等最潮概念的开发框架。
</blockquote>2014年预测：为什么REST 微服务和异步 编程是一种趋势？，如今变成了现实。Lagom缺省都是是异步的，所有的异步都是基于 Akka Stream(scala)和JDK8 CompletionStage API 实现的。提供以下主要功能：1.服务API服务API 提供一种申明和实现服务接口的方法，这个服务可以被客户端直接消费调用，客户端通过服务定位器发现它所要访问的服务。这个服务API提供服务之间调用异步的Stream方式 ，同时也支持传统的同步请求-响应方式调用。2.持久API提供事件溯源event-sourced实体持久化，支持CQRS. Lagom跨集群节点管理持久实体的分布，激活分区sharding和水平扩展. Cassandra以out-of-the-box作为数据库.3.开发环境开发环境能够运行你的服务，支持Lagom底层基础设施，使用一个命令，能在代码改变时热加载你的服务，没有琐碎的脚本来设置和管理你的开发环境，代之以Lagom, 一个开发者能够很快和其他开发者合作，开发新的服务或加入现有的开发团队。4.产品环境Lightbend ConductR是以out-of-the-box支持生产环境，支持简单部署 监视和扩展规模。以hellowworld为案例：HelloService的接口代码如下：public interface HelloService extends Service { @Override default Descriptor descriptor() { return named(“helloservice”).with( restCall(Method.GET, “/api/hello/:id”, hello()) ).withAutoAcl(true); }ServiceCall<String, NotUsed, String> hello(); } 你的服务接口代码必须继承框架的Service，并提供Service#descriptor方法实现. Service#descriptor必须返回Descriptor对象，这个对象定义了 服务名称和服务对外的REST端点。 这里是定义了REST API的调用URL，这样你就可以 <a href="http://localhost:9000/api/hello/World访问这个HelloService微服务了。">http://localhost:9000/api/hello/World访问这个HelloService微服务了。</a>然后编写你的HellpService接口的具体实现子类：public class HelloServiceImpl implements HelloService {private final PersistentEntityRegistry persistentEntityRegistry;@Inject public HelloServiceImpl(PersistentEntityRegistry persistentEntityRegistry) { this.persistentEntityRegistry = persistentEntityRegistry; persistentEntityRegistry.register(HelloWorld.class); }@Override public ServiceCall<String, NotUsed, String> hello() { return (id, request) -> { // Look up the hello world entity for the given ID. PersistentEntityRef ref = persistentEntityRegistry.refFor(HelloWorld.class, id); // Ask the entity the Hello command. return ref.ask(new Hello(id, Optional.empty())); }; } } 这段代码内容主要是访问持久层，实现实体的查询操作，首先在HelloServiceImpl注册了PersistentEntityRegistry ，然后向PersistentEntityRegistry 注册了HelloWorld.class这个实体对象，在查询方法ServiceCall中，根据ID向PersistentEntityRegistry发出查询命令。这里的 PersistentEntityRegistry是框架自身提供以Event Sourcing 和 CQRS方式访问数据库中的数据实体。最后一步运行该代码：$ cd my-first-system $ activator … (booting up)
<blockquote>runAll [info] Starting embedded Cassandra server ………. [info] Cassandra server running at 127.0.0.1:4000 [info] Service locator is running at <a href="http://localhost:8000">http://localhost:8000</a> [info] Service gateway is running at <a href="http://localhost:9000">http://localhost:9000</a> [info] Service helloworld-impl listening for HTTP on 0:0:0:0:0:0:0:0:24266 [info] Service hellostream-impl listening for HTTP on 0:0:0:0:0:0:0:0:26230 (Services started, use Ctrl+D to stop and go back to the console…) 
</blockquote>

0 条回复

动动手指，沙发就是你的了！

登录后才能参与评论