基于netty http协议栈的轻量级 MVC 组件
https://github.com/cyfonly/nettice
- 接收装配请求数据、流程控制和渲染数据
URI到方法直接映射，以及命名空间
- 对
HttpRequest的流程控制 - 像普通方法一样处理
http请求 - 对请求的数据自动装配，支持
基本类型、List、Array和Map - 提供
Render方法渲染并写回响应，支持多种Content-Type - 支持可配置的命名空间
<dependency>
<groupId>org.nutz</groupId>
<artifactId>nutz-integration-nettice</artifactId>
<version>1.r.63-SNAPSHOT</</version>
</dependency>
.addLast("dispatcher",new ActionDispatcher())
例如 com.server.action.DemoAction 提供了 returnTextUseNamespace() 方法，com.server.action.sub.SubDemoAction 也提供了 returnTextUseNamespace() 方法，但两个方法实现不同功能。nettice 组件默认使用方法名进行 URI 映射，那么上述两个 returnTextUseNamespace() 方法会产生冲突，开发者可以使用 @At 注解修改 URI 映射：
package com.server.action;
public class DemoAction extends BaseAction{
@At("/nettp/demo/")
public Render returnTextUseNamespace(@Param("id") Integer id, @Param("proj") String proj){
//do something
return new Render(RenderType.TEXT, "returnTextUseNamespace in [DemoAction]");
}
}
package com.server.action.sub;
public class SubDemoAction extends BaseAction{
@At("/nettp/subdemo/")
public Render returnTextUseNamespace(@Param("ids") Integer[] ids, @Param("names") List<String> names){
//do something
return new Render(RenderType.TEXT, "returnTextUseNamespace in [SubDemoAction]");
}
}
使用Read注解可以自动装配请求数组，支持不同的类型（基本类型、List、Array 和 Map），可以设置默认值（目前仅支持基本类型设置 defaultValue）。
这个例子演示了从 HttpRequest 中获取基本类型的方法，如果没有值会自动设置默认值：
public Render primTypeTest(@Param(value="id", df="1" ) Integer id, @Param("proj") String proj, @Param("author") String author){
System.out.println("Receive parameters: id=" + id + ",proj=" + proj + ",author=" + author);
return new Render(RenderType.TEXT, "Received your primTypeTest request.[from primTypeTest]");
}
这个例子演示了从 HttpRequest 中获取 List/Array 类型的方法：
public Render arrayListTypeTest(@Param("ids") Integer[] ids, @Param("names") List<String> names){
System.out.println("server output ids:");
for(int i=0; i<ids.length; i++){
System.out.println(ids[i]);
}
System.out.println("server output names：");
for(String item : names){
System.out.println(item);
}
NutMap obj = new NutMap();
obj.put("code", 0);
obj.put("msg", "Received your Array/List request.[from arrayListTypeTest()]");
return new Render(RenderType.JSON, Json.toJson(obj));
}
这个例子演示了从 HttpRequest 中获取 Map 类型的方法（注意，使用 Map 时限定了只能存在一个 Map<String,String> 参数）：
public Render mapTypeTest(@Read(key="srcmap") Map<String,String> srcmap){
System.out.println("server output srcmap:");
for(String key : srcmap.keySet()){
System.out.println(key + "=" + srcmap.get(key));
}
NutMap obj = new NutMap();
obj.put("code", 0);
obj.put("msg", "Received your Map request.[from mapTypeTest]");
return new Render(RenderType.JSON, Json.toJson(obj));
}
处理方法可以通过返回 Render 对象向客户端返回特定格式的数据，一个 Render 对象由枚举类型 RenderType 和 data 两部分组成。
nettice 组件会通过 RenderType 来为 Response 设置合适的 Content-Type，开发者也可以扩展 Render 以及相关类来实现更多的类型支持。
例如这是一个返回 JSON 对象的例子，客户端将收到一个 Json 对象：
public Render postPriMap(){
NutMap obj = new NutMap();
obj.put("code", 0);
obj.put("msg", "had received your request.");
return new Render(RenderType.JSON, Json.toJson(obj));
}
- java bean支持
public class HttpServer {
private static final Log logger = Logs.get();
private final int port;
public HttpServer(int port) {
this.port = port;
}
public void run() throws Exception {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast("codec", new HttpServerCodec()).addLast("aggregator", new HttpObjectAggregator(1024 * 1024)).addLast("dispatcher", new ActionDispatcher());
}
}).option(ChannelOption.SO_BACKLOG, 1024).childOption(ChannelOption.SO_KEEPALIVE, true).childOption(ChannelOption.TCP_NODELAY, true);
ChannelFuture future = bootstrap.bind(port).sync();
logger.info("Nettp server listening on port " + port);
future.channel().closeFuture().sync();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
public static void main(String[] args) throws Exception {
ActionDispatcher dispatcher = new ActionDispatcher();
dispatcher.init("nettice.xml", "action");
new HttpServer(8080).run();
}
}
<?xml version="1.0" encoding="UTF-8"?>
<router>
<action-package>
<package>com.anawin.http.action</package>
</action-package>
</router>
@At("/api/rule/")
public class RuleAction extends BaseAction {
@At
public Render add(@Param(value = "ip") String addrs) {
if (StringUtils.isNotBlank(addrs)) {
String[] addrArry = StringUtils.split(addrs, ",");
IocProvider.me().ioc().get(IpRule.class).add(Lang.array2list(addrArry));
}
return new Render(RenderType.JSON, "{\"code\":200,\"msg\":\" Ok\"}");
}
}
http://127.0.0.1/api/rule/add.action?ip=192.168.3.1
基于 Apache License 2.0 发布。有关详细信息，请参阅 LICENSE。