org.noear:solon.boot.nettyhttp

Java project for solon

License

License

Categories

Categories

Net Netty Networking
GroupId

GroupId

org.noear
ArtifactId

ArtifactId

solon.boot.nettyhttp
Last Version

Last Version

1.0.42
Release Date

Release Date

Type

Type

jar
Description

Description

Java project for solon

Download solon.boot.nettyhttp

How to add to project

<!-- https://jarcasting.com/artifacts/org.noear/solon.boot.nettyhttp/ -->
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>solon.boot.nettyhttp</artifactId>
    <version>1.0.42</version>
</dependency>
// https://jarcasting.com/artifacts/org.noear/solon.boot.nettyhttp/
implementation 'org.noear:solon.boot.nettyhttp:1.0.42'
// https://jarcasting.com/artifacts/org.noear/solon.boot.nettyhttp/
implementation ("org.noear:solon.boot.nettyhttp:1.0.42")
'org.noear:solon.boot.nettyhttp:jar:1.0.42'
<dependency org="org.noear" name="solon.boot.nettyhttp" rev="1.0.42">
  <artifact name="solon.boot.nettyhttp" type="jar" />
</dependency>
@Grapes(
@Grab(group='org.noear', module='solon.boot.nettyhttp', version='1.0.42')
)
libraryDependencies += "org.noear" % "solon.boot.nettyhttp" % "1.0.42"
[org.noear/solon.boot.nettyhttp "1.0.42"]

Dependencies

compile (2)

Group / Artifact Type Version
org.noear : solon jar 1.0.42
io.netty : netty-codec-http jar 4.1.43.Final

Project Modules

There are no modules declared in this project.

Maven Central

QQ交流群:22200020

Solon rpc for java

一个微型的Java RPC开发框架。

支持jdk8+;主框架0.1mb;组合不同的插件应对不同需求;方便定制;快速开发。

  • 更快、更小、更自由
  • 支持注解与手动两种控制模式,自由切换
  • 自带IOC & AOP容器,支持PRC、REST API、MVC开发
  • 采用Handler + Context 架构;强调插件式扩展
  • 统一Http、WebSocket、Socket三种信号的开发体验
  • 插件可扩展可切换:启动插件,扩展插件,序列化插件,数据插件,会话状态插件,视图插件(可共存) 等...
  • 使用感觉与Springboot近似,迁移成本低

Hello world:

//Handler 模式:
public class App{
    public static void main(String[] args){
        SolonApp app = Solon.start(App.class,args);
        
        app.get("/",(c)->c.output("Hello world!"));
    }
}

//Controller 模式:
@Controller
public class App{
    public static void main(String[] args){
        Solon.start(App.class,args);
    }
  
    @Mapping("/")
    public Object home(Context c){
        return "Hello world!";  
    }
}

主框架及快速集成开发包:

主框架
组件 说明
org.noear:solon-parent 框架版本管理
org.noear:solon 主框架
org.noear:nami 伴生框架(做为solon rpc 的客户端);由 Fairy 更名而来
快速集成开发包
组件 说明
org.noear:solon-lib 快速开发基础集成包
org.noear:solon-api solon-lib + http boot;快速开发接口应用
org.noear:solon-web solon-api + freemarker + sessionstate;快速开发WEB应用
org.noear:solon-rpc solon-api + nami;快速开发RPC应用
org.noear:solon-cloud solon-rpc + nacos;快速开发微服务应用

附1:与其它框架的异同性

《Solon 特性简集,相较于 Springboot 有什么区别?》

附2:示例与文章

附3:快速入门示例

  • Web 示例(mvc)
<parent>
    <groupId>org.noear</groupId>
    <artifactId>solon-parent</artifactId>
    <version>1.2.27</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.noear</groupId>
        <artifactId>solon-web</artifactId>
    </dependency>
</dependencies>
//资源路径说明(不用配置)
resources/application.properties(或 application.yml) 为应用配置文件
resources/static/ 为静态文件根目标
resources/WEB-INF/view/ 为视图文件根目标(支持多视图共存)

//调试模式:
启动参数添加:-debug=1
public class App{
    public static void main(String[] args){
        Solon.start(App.class, args);
    }
}

/*
 * mvc控制器
 */
@Controller
public class DemoController{
    //for http
    @Mapping("/hallo/{u_u}")
    public ModelAndView hallo(String u_u){
        return new ModelAndView("hallo");
    }
    
    /*
    //for web socket (需添加:solon.boot.websocket 插件)
    @Mapping(value="/hallo/{u_u}", method = MethodType.WEBSOCKET)
    public ModelAndView hallo_ws(String u_u){
        return new ModelAndView("hallo");
    }
    */
}
  • Rpc 示例
// - interface : 定义协议
public interface DemoService{
    void setName(Integer user_id, String name);
}

// - server : 实现协议
@Mapping("/demo/*")
@Component(remoting = true)
public class DemoServiceImp implements DemoService{
    public void setName(int user_id, String name){
        
    }
}

// - client - 简单示例
//注入模式
//@NamiClient("http://127.0.0.1:8080/demo/") 
//DemoService client;

//构建模式
DemoService client = Nami.builder().upstream(n->"http://127.0.0.1:8080/demo/").create(DemoService.class); 
client.setName(1,'');

  • 获取应用配置
//非注入模式
Solon.cfg().get("app_key"); //=>String
Solon.cfg().getInt("app_id",0); //=>int
Solon.cfg().getProp("xxx.datasource"); //=>Properties

//注入模式
@Configuration //or @Controller, or @Component
public class Config{
    @Inject("${app_key}")
    String app_key;
}
  • 事务与缓存控制(+验证)
@Valid
@Controller
public class DemoController{
    @Db
    BaseMapper<UserModel> userService;
    
    @NotZero("user_id")
    @CacheRemove(tags = "user_${user_id}")
    @Tran
    @Mapping("/user/update")
    public void udpUser(int user_id, UserModel user){
        userService.updateById(user);
    }

    @NotZero("user_id")
    @Cache(tags = "user_${user_id}")
    public UserModel getUser(int user_id){
        return userService.selectById(user_id);
    }
}
  • 文件上传与输出
@Controller
public class DemoController{
    @Mapping("/file/upload")
    public void upload(UploadedFile file){
        IoUtil.save(file.content, "/data/file_" + file.name);
    }

    @Mapping("/file/down")
    public void down(Context ctx, String path){
        URL uri = Utils.getResource(path);

        ctx.contentType("json/text");
        ctx.output(uri.openStream());
    }
}
  • Servlet 注解支持
@WebFilter("/hello/*")
public class HelloFilter implements Filter {
    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        servletResponse.getWriter().write("Hello,我把你过滤了");
    }
}
  • Quartz 定时任务
@Quartz(cron7x = "0 0/1 * * * ? *")
public class HelloTask implements Runnable {
    public static void main(String[] args){
        Solon.start(QuartzRun2.class,args);
    }
    
    @Override
    public void run() {
        System.out.println("Hello world");
    }
}
  • 体外扩展加载 jar
demoApp.jar             #主程序
ext/                    #扩展目录
ext/ext.markdown.jar    #MD格式支持扩展包
  • 单链接双向RPC(客户端链上服务端之后,形成双向RPC)
//server
@Mapping(value = "/demoh/rpc", method = MethodType.SOCKET)
@Component(remoting = true)
public class HelloRpcServiceImpl implements HelloRpcService {
    public String hello(String name) {
        //此处,可以根据 client session 创建一个连接 client 的 rpc service
        NameRpcService rpc = SocketD.create(Context.current(), NameRpcService.class);

        String name2 = rpc.name(name);

        return "name=" + name;
    }
}

//client
HelloRpcService rpc = SocketD.create("tcp://localhost:"+_port, HelloRpcService.class);

String rst = rpc.hello("noear");

附4:插件开发说明

  • 新建一个 maven 项目
  • 新建一个 java/{包名}/XPluginImp.java (implements XPlugin)
  • 新建一个 resources/META-INF/solon/{包名.properties}
  • 添加配置:solon.plugin={包名}.XPluginImp

附5:启动顺序参考

  • 1.实例化 Solon.global() 并加载配置
  • 2.加载扩展文件夹
  • 3.扫描插件
  • 4.运行builder函数
  • 5.运行插件
  • 6.扫描并加载java bean
  • 7.加载渲染关系
  • 8.完成

附6:Helloworld 的单机并发数 《helloworld_wrk_test》

  • 机器:2017 macbook pro 13, i7, 16g, MacOS 10.15, jdk11
  • 测试:wrk -t10 -c200 -d30s --latency "http://127.0.0.1:8080/"
solon 1.1.2 大小 QPS
solon.boot.jlhttp(bio) 0.1m 4.7万左右
solon.boot.jetty(nio, 支持servlet api) 1.8m 10.7万左右
solon.boot.undertow(nio, 支持servlet api) 4.2m 11.3万左右
solon.boot.smarthttp(aio) 0.3m 12.4万左右
spring boot 2.3.3 大小 QPS
spring-boot-starter-tomcat 16.1m 3.2万左右
spring-boot-starter-jetty 16m 3.7万左右
spring-boot-starter-undertow 16.8m 4.4万左右

Versions

Version
1.0.42
1.0.41
1.0.40
1.0.39
1.0.38
1.0.37
1.0.36
1.0.35
1.0.34
1.0.33
1.0.32
1.0.31
1.0.30
1.0.29
1.0.28
1.0.27
1.0.26
1.0.25
1.0.24
1.0.23
1.0.22
1.0.21
1.0.20
1.0.19
1.0.18
1.0.17
1.0.16
1.0.15
1.0.14.1
1.0.14
1.0.13
1.0.12
1.0.11
1.0.10
1.0.9.2
1.0.9.1
1.0.9
1.0.8
1.0.7.1
1.0.7
1.0.6.5
1.0.6.4
1.0.6.3
1.0.6.2
1.0.6.1
1.0.6
1.0.5.12
1.0.5.11
1.0.5.10
1.0.5.9
1.0.5.8
1.0.5.7
1.0.5.6
1.0.5.5
1.0.5.4
1.0.5.2
1.0.5.1
1.0.5
1.0.4.4
1.0.4.3
1.0.4.2
1.0.4.1
1.0.4
1.0.3.44
1.0.3.43
1.0.3.42
1.0.3.41
1.0.3.40
1.0.3.39
1.0.3.38
1.0.3.37
1.0.3.36
1.0.3.34
1.0.3.33
1.0.3.32
1.0.3.31
1.0.3.30
1.0.3.29
1.0.3.28
1.0.3.27
1.0.3.26
1.0.3.25
1.0.3.24
1.0.3.23
1.0.3.22
1.0.3.7
1.0.3.6
1.0.3.5
1.0.3.4
1.0.3.3
1.0.3.2