极简的Resty服务端和客户端RESTful框架

< repositories >

     < repository >

       < id >oss-snapshots</ id >

       < url >https://oss.sonatype.org/content/repositories/snapshots</ url >

       < releases >

         < enabled >false</ enabled >

       </ releases >

       < snapshots >

         < enabled >true</ enabled >

       </ snapshots >

     </ repository >

   </ repositories >

< dependency >

     < groupId >cn.dreampie</ groupId >

     < artifactId >resty-route</ artifactId >

     < version >1.0-SNAPSHOT</ version >

</ dependency >

//创建record的执行器  针对sec_user表 并开启缓存

Record recordDAO = new Record( "sec_user" , true );

//使用当前数据源和表数据 new一个对象来保存数据

recordDAO.reNew().set( "属性" , "值" ).save();

Record r1 = recordDAO.reNew().set( "属性" , "值" );

Record r2 = recordDAO.reNew().set( "属性" , "值" );

//批量保存

recordDAO.save(r1, r2);

//更新

r2.set( "属性" , "值" ).update()

//查询全部

List<Record> records = recordDAO.findAll();

//条件查询

recordDAO.findBy(where,paras)

//分页查询

Page<Record> records = recordDAO.paginateAll();

//根据id删除

recordDAO.deleteById( "1" );

//本次查询放弃使用cache

recordDAO.unCache().findBy(where,paras);

//把record的数据源切换到dsName数据源上

recordDAO.useDS(dsName).findBy(where,paras);

User dao= new User();

//本次查询放弃使用cache

dao.unCache().findBy(where,paras);

//把model的数据源切换到dsName数据源上

dao.useDS(dsName).findBy(where,paras);

//not must auto load

app.encoding=UTF- 8

app.devMode= true

app.showRoute= true

app.cacheEnabled= true

//druid plugin auto load

//dsName is "default"  you can use everything

db. default .url=jdbc:mysql: //127.0.0.1/example?useUnicode=true&characterEncoding=UTF-8

db. default .user=dev

db. default .password=dev1010

db. default .dialect=mysql

druid. default .initialSize= 10

druid. default .maxPoolPreparedStatementPerConnectionSize= 20

druid. default .timeBetweenConnectErrorMillis= 1000

druid. default .filters=slf4j,stat,wall

//flyway database migration auto load

flyway. default .valid.clean= true

flyway. default .migration.auto= true

flyway. default .migration.initOnMigrate= true

//数据库的配置精简  自动从文件读取参数  只需配置model扫描目录 和dsName

public void configPlugin(PluginLoader pluginLoader) {

   //第一个数据库

   ActiveRecordPlugin activeRecordPlugin = new ActiveRecordPlugin( new DruidDataSourceProvider( "default" ), true );

   activeRecordPlugin.addIncludePaths( "cn.dreampie.resource" );

   pluginLoader.add(activeRecordPlugin);

}

@GET ( "/users/:name" ) 

//在路径中自定义解析的参数 如果有其他符合 也可以用 /users/{name}

// 参数名就是方法变量名  除路径参数之外的参数也可以放在方法参数里  传递方式 user={json字符串}

public Map find(String name,User user) {

   // return Lister.of(name);

   return Maper.of( "k1" , "v1,name:" + name, "k2" , "v2" );

   //返回什么数据直接return，完全融入普通方法的方式

}

//批量保存

User u1 = new User().set( "username" , "test" ).set( "providername" , "test" ).set( "password" , "123456" );

User u2 = new User().set( "username" , "test" ).set( "providername" , "test" ).set( "password" , "123456" );

User.dao.save(u1,u2);

//普通保存

User u = new User().set( "username" , "test" ).set( "providername" , "test" ).set( "password" , "123456" );

u.save();

//更新

u.update();

//条件更新

User.dao.updateBy(columns,where,paras);

User.dao.updateAll(columns,paras);

//删除

u.deleted();

//条件删除

User.dao.deleteBy(where,paras);

User.dao.deleteAll();

//查询

User.dao.findById(id);

User.dao.findBy(where,paras);

User.dao.findAll();

//分页

User.dao.paginateBy(pageNumber,pageSize,where,paras);

User.dao.paginateAll(pageNumber,pageSize);

Client client= null ; //创建客户端对象

//启动resty-example项目，即可测试客户端

String apiUrl = "http://localhost:8081/api/v1.0" ;

//如果不需要 使用账号登陆

//client = new Client(apiUrl);

//如果有账号权限限制  需要登陆

client = new Client(apiUrl, "/tests/login" , "u" , "123" );

//该请求必须  登陆之后才能访问  未登录时返回 401  未认证

ClientRequest authRequest = new ClientRequest( "/users" , HttpMethod.GET);

ResponseData authResult = client.build(authRequest).ask();

System.out.println(authResult.getData());

//get

ClientRequest getRequest = new ClientRequest( "/tests" , HttpMethod.GET);

ResponseData getResult = client.build(getRequest).ask();

System.out.println(getResult.getData());

//post

ClientRequest postRequest = new ClientRequest( "/tests" , HttpMethod.POST);

postRequest.addParameter( "test" , Jsoner.toJSONString(Maper.of( "a" , "谔谔" )));

ResponseData postResult = client.build(postRequest).ask();

System.out.println(postResult.getData());

//put

ClientRequest putRequest = new ClientRequest( "/tests/x" , HttpMethod.PUT);

ResponseData putResult = client.build(putRequest).ask();

System.out.println(putResult.getData());

//delete

ClientRequest deleteRequest = new ClientRequest( "/tests/a" , HttpMethod.DELETE);

ResponseData deleteResult = client.build(deleteRequest).ask();

System.out.println(deleteResult.getData());

//upload

ClientRequest uploadRequest = new ClientRequest( "/tests/resty" , HttpMethod.POST);

uploadRequest.addUploadFiles( "resty" , ClientTest. class .getResource( "/resty.jar" ).getFile());

uploadRequest.addParameter( "des" , "test file  paras  测试笔" );

ResponseData uploadResult = client.build(uploadRequest).ask();

System.out.println(uploadResult.getData());

//download  支持断点续传

ClientRequest downloadRequest = new ClientRequest( "/tests/file" , HttpMethod.GET);

downloadRequest.setDownloadFile(ClientTest. class .getResource( "/resty.jar" ).getFile().replace( ".jar" , "x.jar" ));

ResponseData downloadResult = client.build(downloadRequest).ask();

System.out.println(downloadResult.getData());

// 在resource里使用事务,也就是controller里，rest的世界认为所以的请求都表示资源，所以这儿叫resource

@GET ( "/users" )

@Transaction (name = {DS.DEFAULT_DS_NAME, "demo" }) //多数据源的事务，如果你只有一个数据库  直接@Transaction 不需要参数

public User transaction() {

//TODO 用model执行数据库的操作  只要有操作抛出异常  两个数据源 都会回滚  虽然不是分布式事务  也能保证代码块的数据执行安全

}

// 如果你需要在service里实现事务，通过java动态代理（必须使用接口，jdk设计就是这样）

public interface UserService {

   @Transaction (name = {DS.DEFAULT_DS_NAME, "demo" }) //service里添加多数据源的事务，如果你只有一个数据库  直接@Transaction 不需要参数

   public User save(User u);

}

// 在resource里使用service层的 事务

// @Transaction(name = {DS.DEFAULT_DS_NAME, "demo"})的注解需要写在service的接口上

// 注意java的自动代理必须存在接口

// TransactionAspect 是事务切面 ，你也可以实现自己的切面比如日志的Aspect，实现Aspect接口

// 再private UserService userService = AspectFactory.newInstance(new UserServiceImpl(), new TransactionAspect(),new LogAspect());

private UserService userService = AspectFactory.newInstance( new UserServiceImpl(), new TransactionAspect());

public void configInterceptor(InterceptorLoader interceptorLoader) {  //权限拦截器 放在第一位 第一时间判断 避免执行不必要的代码

   interceptorLoader.add( new SecurityInterceptor( new MyAuthenticateService()));

}

//实现接口

public class MyAuthenticateService implements AuthenticateService { 

//登陆时 通过name获取用户的密码和权限信息

   public Principal findByName(String name) {

     DefaultPasswordService defaultPasswordService = new DefaultPasswordService();

     Principal principal = new Principal(name, defaultPasswordService.hash( "123" ), new HashSet<String>() {{

       add( "api" );

     }});   

     return principal;

   } 

   //基础的权限总表  所以的url权限都放在这儿  你可以通过 文件或者数据库或者直接代码 来设置所有权限

   public Set<Credential> loadAllCredentials() {

       Set<Credential> credentials = new HashSet<Credential>();

       credentials.add( new Credential( "GET" , "/api/v1.0/users**" , "users" ));

       return credentials;

   }

}

public void configConstant(ConstantLoader constantLoader) {

   //启用缓存并在要自动使用缓存的model上  开启缓存@Table(name = "sec_user", cached = true)

   constantLoader.setCacheEnable( true );

}

@Table (name = "sec_user" , cached = true )

public class User extends Model<User> {

public static User dao = new User();

}

@GET ( "/files" )

public File file() {

   return new File(path);

}

@POST("/files")

@FILE(dir = "/upload/") //配置上传文件的相关信息

public UploadedFile file(UploadedFile file) {   

   return file;

}

public void configConstant(ConstantLoader constantLoader) {

   // 通过后缀来返回不同的数据类型  你可以自定义自己的  render  如：FreemarkerRender

   // constantLoader.addRender("json", new JsonRender());

   //默认已添加json和text的支持，只需要把自定义的Render add即可

}