Englishdoc
EasyRest与Netty,Akka和Spring的整合.这是一个为快速开发而设计的高性能RESTful框架，极易搭建集群和使用分布式。你可以完全专注在你的业务逻辑上。
不需要Tomcat，不需要web.xml配置，只需一个有main函数的jar包，你就能拥有一个完美的分布式系统。
你可以不知道Netty，也可以不知道akka，甚至不熟悉Spring，但仍然可以使用该框架。
快速开始:REST接口定义
@BindURL("/rest/{TENANT}/stock")public interface StockInfoRest { @Post("/personal/{USER_ID}/favorite/{CODE}") void addFavorite(String TENANT, String USER_ID, String CODE, long time); @Post ResponseEntity addStocks(int userNumber, String userName, List<Stock> stockList); @Get("/personal/{USER_ID}/favorite/list") List<Stock> getStockList(String USER_ID);}使用@Service注解，将该类交给Spring生成bean并管理，该框架可以和spring无缝对接使用。
@Servicepublic class StockInfoRestController implements StockInfoRest { @Override public void addFavorite(String TENANT, String USER_ID, String CODE, long time) { System.out.println(TENANT + " " + USER_ID + " " + CODE + " " + time); } @Override@AllDefined public ResponseEntity addStocks(int userNumber, String userName, List<Stock> stockList) { return ResponseEntity.buildOkResponse(Lists.asList(userNumber, userName, new List[]{stockList})); } @Override public List<Stock> getStockList(String USER_ID) { return Lists.newArrayList(new Stock(100000, "stock1"), new Stock(100001, "stock2"), new Stock(100002, "stock3")); }}主函数类，用于启动以及配置。
public class Example { public static void main(String[] args) { EasyRest easyRest = new EasyRest("classpath:MyExampleApplicationContext.xml"); easyRest.startup("EasyRestServer"); }}一个基础的spring配置文件
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="https://www.springframework.org/schema/beans" xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance" xmlns:context="https://www.springframework.org/schema/context" xsi:schemaLocation="https://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd https://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd"> <context:annotation-config/> <context:component-scan base-package="com.example"> </context:component-scan> <context:annotation-config/></beans>@BindURL("/rest/{TENANT}/stock") 会绑定该类监听"/rest/{TENANT}/stock"路径的请求。
@AllDefined 会要求该方法所有的参数在请求中都被赋予非空值，如果检测到有null，框架将会直接拒绝这个请求。可以减少用户的空值判断。
@Service 这个是spring的annotation，将交给spring生成bean并管理。
ResponseEntity 是一个通用的返回格式，你能将所有格式的数据放进去。（你也可以不使用这个，直接返回任何你想返回的格式）
如果你有很多其他的spring配置文件，你可以这样启动EasyRest：
EasyRest easyRest = new EasyRest("classpath:MyApplicationContext-01.xml", "classpath:MyApplicationContext-02.xml"...);所有你想暴露的数据接口，EasyRest都会自动检测到，你只需要启动server。
easyRest.startup("EasyRestServer");接口调用示例函数1
@Post("/personal/{USER_ID}/favorite/{CODE}")void addFavorite(String TENANT, String USER_ID, String CODE, long time);调用地址:
https://127.0.0.1:8080/rest/100000001/stock/personal/001/favorite/100001
Content-Typeis'application/json'
请求内容:
{"time":1524827542}控制台输出:
100000001 001 100001 1524827542收到的响应内容:
{ "code": "1", "message": "ok"}函数2
@Post@AllDefinedResponseEntity addStocks(int userNumber, String userName, List<Stock> stockList);调用地址:
https://127.0.0.1:8080/rest/100000001/stock/addStocks
Content-Typeis'application/json'
请求内容:
{"userNumber":1, "userName":"Louie", "stockList":[{"code":100001, "name":"stock1"}, {"code":100002, "name":"stock2"}]}响应内容:
{ "code": "1", "data": [ 1, "Louie", [ { "code": 100001, "name": "stock1" }, { "code": 100002, "name": "stock2" } ] ]}这个函数有一个 @AllDefined 的注解，所以如果任何参数的值为null，比如：“UserName”，那么响应结果将会如下：
{ "code": "-1", "message": "Failed", "data": { "errorType": "ParameterNotFoundException", "errorMessage": "userName is not defined." }}函数3
@Get("/personal/{USER_ID}/favorite/list")List<Stock> getStockList(String USER_ID);调用地址:
https://127.0.0.1:8080/rest/100000001/stock/personal/001/favorite/list
响应内容:
[ { "code": 100000, "name": "stock1" }, { "code": 100001, "name": "stock2" }, { "code": 100002, "name": "stock3" }]对于contenttype,'multipart/form-data'也是支持的.
框架支持分布式服务，并且十分容易搭建.
分布式服务示例所有的代码都在Example的模块中代码结构- Example-Distributed-Service-1- example-service-1-api- example-service-1-main- Example-Distributed-Service-2- example-service-2-api- example-service-2-main- Example-Distributed-Service-ModelExample-Distributed-Service-1会收到请求，然后会调用Example-Distributed-Service-2的服务去创建一个People，然后将这个People做为响应数据返回出去。
Example-Distributed-Service-ModelPeople类
public class People { private String name; private int age; private long birthday; private List<String> skills; private People boss; public People(String name, int age, long birthday, List<String> skills, People boss) { this.name = name; this.age = age; this.birthday = birthday; this.skills = skills; this.boss = boss; }}Example-Distributed-Service-1example-service-1-api
接口定义
@BindURL("/service1")public interface Service1 { @Post @AllDefined ResponseEntity createPeople(String name, int age, long birthday, List<String> skills, People boss);}example-service-1-main
接口实现
@Servicepublic class Service1Impl implements Service1 { @Override public ResponseEntity createPeople(String name, int age, long birthday, List<String> skills, People boss) { Service2 service2 = EasyRestServiceLookup.lookup(Service2.class); return ResponseEntity.buildOkResponse(service2.getPeople(name, age, birthday, skills, boss)); }}EasyRestServiceLookup 有一个静态方法 lookup.你能使用这个函数获得任何交给EasyRest，或者spring的bean实例，包括在其他服务器上的实例，你都能直接调用。
主函数
public class Startup {private static String systemName = "example-service-1"; public static void main(String[] args) throws IOException { EasyRestDistributedServiceBind.loadConfiguration(Startup.class.getClassLoader().getResourceAsStream("services-mapping-01.json")); EasyRest easyRest = new EasyRest("classpath:MyExampleApplicationContext-01.xml"); easyRest.startup(systemName, new NettyInit(8001)); }}EasyRestDistributedServiceBind.loadConfiguration(Startup.class.getClassLoader().getResourceAsStream("services-mapping-01.json"));将会为框架载入服务映射的关系配置文件。
akka配置文件: application.conf
akka { actor { provider = "akka.remote.RemoteActorRefProvider" } remote { transport = "akka.remote.netty.NettyRemoteTransport" netty { tcp { hostname = "127.0.0.1" port = 2551 } } }}Akka系统会检测到这个配置文件，然后在指定的端口监听远程请求。
分布式服务映射关系表:(services-mapping-01.json)
{ "self": { "akkaSystemName": "example-service-1", "host": "127.0.0.1", "port": "2551" }, "services" : [ { "akkaSystemName": "example-service-1", "host": "127.0.0.1", "port": "2551" }, { "akkaSystemName": "example-service-2", "host": "127.0.0.1", "port": "2552" } ]}服务映射关系表只需要2个字段: Self 记录本地的服务器信息. Services 是一个数组，记录所有的服务器信息，包括自己本身.
字段akkaSystemName的值必须和主函数中systemName的值一致！！！
*一个基本的spring配置文件:
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="https://www.springframework.org/schema/beans" xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance" xmlns:context="https://www.springframework.org/schema/context" xsi:schemaLocation="https://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd https://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd"> <context:annotation-config/> <context:component-scan base-package="com.example"> </context:component-scan> <context:annotation-config/></beans>Example-Distributed-Service-2example-service-2-api
接口定义
@BindURL("/service2")public interface Service2 { @Get People getPeople(String name, int age, long birthday, List<String> skills, People boss);}example-service-2-main
接口实现
@Servicepublic class Service2Impl implements Service2 { @Override public People getPeople(String name, int age, long birthday, List<String> skills, People boss) { return new People(name, age, birthday, skills, boss); }}主函数
public class Startup {private static String systemName = "example-service-2"; public static void main(String[] args) throws IOException { EasyRestDistributedServiceBind.loadConfiguration(Startup.class.getClassLoader().getResourceAsStream("services-mapping-02.json")); EasyRest easyRest = new EasyRest("classpath:MyExampleApplicationContext-02.xml"); easyRest.startup(systemName, new NettyInit(8002)); }}akka配置文件: application.conf
akka { actor { provider = "akka.remote.RemoteActorRefProvider" } remote { transport = "akka.remote.netty.NettyRemoteTransport" netty { tcp { hostname = "127.0.0.1" port = 2552 } } }}分布式服务映射表:(services-mapping-02.json，该service并未依赖其他service，所以其实可以不用加载该配置文件)
{ "self": { "akkaSystemName": "example-service-2", "host": "127.0.0.1", "port": "2552" }, "services" : [ { "akkaSystemName": "example-service-1", "host": "127.0.0.1", "port": "2551" }, { "akkaSystemName": "example-service-2", "host": "127.0.0.1", "port": "2552" } ]}一个基本的spring配置文件:
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="https://www.springframework.org/schema/beans" xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance" xmlns:context="https://www.springframework.org/schema/context" xsi:schemaLocation="https://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd https://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd"> <context:annotation-config/> <context:component-scan base-package="com.example"> </context:component-scan> <context:annotation-config/></beans>启动Service1和Service2.当你在两边的控制台分别看到如下的日志:
[example-service-1-akka.actor.default-dispatcher-5] INFO com.easyrest.utils.LogUtils - From com.easyrest.actors.remote.RemoteServiceExchangeActor: Service mapping init success.[example-service-1-akka.actor.default-dispatcher-5] INFO com.easyrest.utils.LogUtils - example-service-2 is running on the port 8001.[example-service-2-akka.actor.default-dispatcher-3] INFO com.easyrest.utils.LogUtils - From com.easyrest.actors.remote.RemoteServiceExchangeActor: Service mapping init success.[example-service-2-akka.actor.default-dispatcher-3] INFO com.easyrest.utils.LogUtils - example-service-2 is running on the port 8002.这表示两个service现在已经就绪了!现在我们将通过restcall调用service1.
https://127.0.0.1:8001/service1/createPeople Content-Type:application/jsonBody:{"name":"Louie","age":18,"birthday":763401600,"skills":["java","netty","akka","spring"],"boss":{"name":"Louie_B","age":18,"birthday":763401600}}
收到的响应内容:
{ "code": "1", "data": { "name": "Louie", "age": 18, "birthday": 763401600, "skills": [ "java", "netty", "akka", "spring" ], "boss": { "name": "Louie_B", "age": 18, "birthday": 763401600 } }}That'swork!持续更新...
评论