netty restful框架,restful 框架

2022-07-31 10:18:33 分类：java 阅读()

　　netty restful框架,restful 框架

　　如果你对restful不是很了解，或者认为restful只是一个规范，没有实际意义，推荐osc两年前的一篇文章：restful API Design REST Practices和Infoq的一篇理论性极强的文章。虽然原来RESTful的建筑风格有点老，但是介绍很简单，大家应该都有所了解。关于RESTful的更多好处，请询问google。

　　拥有jfinal/activejdbc这样的activerecord的简单设计，使用更简单的restful框架。

　　部分设计也来自jfinal activejdbc restx，希望大家能支持开源。开源不比较框架的优劣，只描述自己的想法。

　　Restful的api设计是restful的服务器的最佳选择(使用场景：客户端和服务器解耦，用于为静态html客户端(mvvm等)提供服务器的api接口。)，ios，andriod等。)

　　下载jar包：Resty jar

　　00-1010 1.添加maven快照仓库

　　存储库存储库idoss-snapshot s/id urlhttps://oss.sonatype.org/content/repositories/snapshots/url发布已启用假/已启用/发布快照已启用真/已启用/快照/存储库/存储库2。添加依赖包

　　依赖groupIdcn.dreampie/groupId工件Resty-route/Artifact ID版本1.0-snapshot/Version/dependency

maven使用方式：

record的时代已经到来，你根本不需要使用任何模型来执行你的数据。

 

　　//创建记录的执行器以sec_user表为目标，打开缓存recorddao=newrecord (sec _ user ，true)；//使用当前数据源和表数据新建对象保存数据recordDAO.reNew()。集合(属性，值)。save()；R1=recorddao.renew()。set(属性，值)；Record=recorddao.renew()。set(属性，值)；//批量保存recordDAO.save(r1，R2)；//更新r2.set (attribute ， value )。update()//查询所有list recordrecords=record Dao . find all()；//条件查询recorddao.findby (where，para)//page record Records=record Dao . paginateall()；//根据Id删除record Dao . Delete byid( 1 )；//此查询放弃使用cacherecorddao.uncache()。findby (where，para)；//将记录的数据源切换到recorddao.uses (dsName)。dsname数据源上的findby (where，para)；以此类推，彻底摆脱模型，实现快速数据操作。

　　模型支持动态数据源切换，并且该查询放弃了缓存。

　　User Dao=new User()；//此查询放弃使用cachedao.uncache()。findby (where，para)；//将模型的数据源切换到dao.uses (dsName)。在dsname数据源上查找by (where，para)；并将数据库和全局参数配置迁移到application.properties。

　　//not must auto load app . encoding=UTF-8 app . devmode=true app . show route=true app . cache enabled=true//德鲁伊插件自动加载//dsName是‘默认’你

　　 can use everythingdb.default.url=jdbc:mysql://127.0.0.1/example?useUnicode=true&characterEncoding=UTF-8db.default.user=devdb.default.password=dev1010db.default.dialect=mysqldruid.default.initialSize=10druid.default.maxPoolPreparedStatementPerConnectionSize=20druid.default.timeBetweenConnectErrorMillis=1000druid.default.filters=slf4j,stat,wall//flyway database migration auto loadflyway.default.valid.clean=trueflyway.default.migration.auto=trueflyway.default.migration.initOnMigrate=true//数据库的配置精简 自动从文件读取参数 只需配置model扫描目录 和dsNamepublic void configPlugin(PluginLoader pluginLoader) { //第一个数据库 ActiveRecordPlugin activeRecordPlugin = new ActiveRecordPlugin(new DruidDataSourceProvider("default"), true); activeRecordPlugin.addIncludePaths("cn.dreampie.resource"); pluginLoader.add(activeRecordPlugin);}

独有优点

1.极简的route设计:

 

　　

@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，完全融入普通方法的方式}

2.极简的activerecord设计，数据操作只需短短的一行 ，支持批量保存对象

 

　　

//批量保存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);

3.极简的客户端设计，支持各种请求，文件上传和文件下载（支持断点续传）

 

　　

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());//getClientRequest getRequest = new ClientRequest("/tests", HttpMethod.GET);ResponseData getResult = client.build(getRequest).ask();System.out.println(getResult.getData());//postClientRequest 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());//putClientRequest putRequest = new ClientRequest("/tests/x", HttpMethod.PUT);ResponseData putResult = client.build(putRequest).ask();System.out.println(putResult.getData());//deleteClientRequest deleteRequest = new ClientRequest("/tests/a", HttpMethod.DELETE);ResponseData deleteResult = client.build(deleteRequest).ask();System.out.println(deleteResult.getData());//uploadClientRequest 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());

4.支持多数据源和嵌套事务（使用场景：需要访问多个数据库的应用，或者作为公司内部的数据中间件向客户端提供数据访问api等）

 

　　

// 在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());

5.极简的权限设计，你只需要实现一个简单接口和添加一个拦截器，即可实现基于url的权限设计

 

　　

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; }}

6.极简的缓存设计，可扩展，非常简单即可启用model的自动缓存功能

 

　　

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();}

7.下载文件，只需要直接return file

 

　　

@GET("/files")public File file() { return new File(path);}

8.上传文件，通过@FILE注解件写到服务器

 

　　

@POST("/files")@FILE(dir = "/upload/") //配置上传文件的相关信息public UploadedFile file(UploadedFile file) { return file;}

9.当然也是支持传统的web开发，你可以自己实现数据解析，在config里添加自定义的解析模板

 

　　

public void configConstant(ConstantLoader constantLoader) { // 通过后缀来返回不同的数据类型 你可以自定义自己的 render 如：FreemarkerRender // constantLoader.addRender("json", new JsonRender()); //默认已添加json和text的支持，只需要把自定义的Render add即可}

二、运行example示例：

1.运行根目录下的pom.xml->install （把相关的插件安装到本地，功能完善之后发布到maven就不需要这样了）

 

　　2.在本地mysql数据库里创建demo,example数据库，对应application.properties的数据库配置

　　3.运行resty-example下的pom.xml->flyway-maven-plugin:migration，自动根具resources下db目录下的数据库文件生成数据库表结构

　　4.运行resty-example下的pom.xml->tomcat7-maven-plugin:run,启动example程序

　　提醒:推荐idea作为开发ide，使用分模块的多module开发

　　以上就是极简的Resty服务端和客户端RESTful框架的详细内容，更多关于Resty服务端客户端RESTful框架的资料请关注盛行IT其它相关文章！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

标签：

相关文章阅读

  • ribbon netty,netty 源码分析
  • netty 对比,netty与mina
  • netty 协议解析,netty编解码器
  • java netty连接硬件,
  • JAVA netty,netty工作原理
  • netty 编解码器,netty 编解码_1
  • netty nioeventloop,
  • netty 性能,netty高级应用
  • netty 源码分析,netty 源码深入分析
  • netty pipeline 原理,netty pipeline如何工作
  • netty socketchannel,netty作为客户端与普通socket服务端
  • netty 源码解析,netty 解码器
  • netty bytebuf内存释放,netty bytebuffer
  • netty io线程和业务线程,netty默认线程数
  • netty eventloop源码分析,
    • 留言与评论（共有 条评论）
       
    验证码：