webcat——基于netty的http和websocket框架

立即下载用AI写一个

发布时间：2018-03-24

35人 | 浏览：8051次 | 收藏 |

技术：Netty + Spring + Websocket + Http

概述

Webcat是一个基于netty的简单、高性能服务端框架，目前提供http和websocket两种协议的快速开发模式。可以帮助开发者迅速搭建高可用分部署系统。有任何技术难题也欢迎咨询。

详细

Webcat是一个基于netty的简单、高性能服务端框架，目前提供http和websocket两种协议的快速开发模式。webcat采用spring进行对象管理，因此工程需要依赖spring框架，[Github地址](https://github.com/licheng-xd/webcat)。

下载源代码后，可以直接运行WebcatServerTest启动http和websocket服务，然后通过pytest文件夹中的两个python脚本对服务进行测试。

### HTTP Server 使用

在spring的配置中,加上对webcat的package扫描:
```xml
<context:component-scan base-package="com.lchml.webcat"/>
```

设置端口并启动:
```java
public static void main(String[] args) throws WebcatStartException {
    HttpServer httpServer = context.getBean(WebcatHttpServer.class);
    httpServer.setPort(8080);
    httpServer.start();
}
```

添加自己的controller:
```xml
<context:component-scan base-package="com.lchml.test"/>
```

```java
@HttpController(path = "/test")
public class TestController {

@HttpRequestMapping(path = "/hello", consumes = {"text/plain"})
    public String testHello() {
        return "hello webcat";
    }

@HttpRequestMapping(path = "/bodytest", method = {ReqMethod.POST})
    public String testBody(@ReqBody String body) {
        return "hello webcat " + body;
    }

@HttpRequestMapping(path = "/redirect", method = {ReqMethod.GET})
    public void testRedirect(FullHttpResponse response) {
        ResponseUtil.redirect(response, "http://lchml.com");
    }
}
```

* logEnable，默认会打开所有websocket请求的日志。
* logResponse，默认日志中不会输入response内容。
* defaultProduce，默认返回content-type为application/json;charset=utf-8。

```xml
<bean class="com.lchml.webcat.config.WebcatHttpConf" id="webcatConf">
    <property name="logEnable" value="true"/>
    <property name="logResponse" value="true"/>
    <property name="defaultProduce" value="application/json;charset=utf-8"/>
</bean>
```

### Websocket Server 使用

在spring的配置中,加上对webcat的package扫描:
```xml
<context:component-scan base-package="com.lchml.webcat"/>
```

设置端口，设置连接初始化和断开的监听回调并启动:

```java
public static void main(String[] args) throws WebcatStartException {
    WebcatWsServer wsServer = context.getBean(WebcatWsServer.class);
    wsServer.setPort(8081);
    wsServer.setChannelConnectListener(new ChannelConnectListener() {
        @Override public void connect(ChannelInfo channelInfo) {
            channelInfo.addAttr("connectTime", System.currentTimeMillis());
            System.out.println(channelInfo.getClientIp() + " connect");
        }
    });
    wsServer.setChannelDisconnectListener(new ChannelDisconnectListener() {
        @Override public void disconnect(ChannelInfo channelInfo) {
            System.out.println(channelInfo.getClientIp() + " disconnect");
        }
    });

wsServer.start();
}
```

添加自己的controller:
```xml
<context:component-scan base-package="com.lchml.test"/>
```

```java
@WsController(path = "/test")
public class TestWsController {

@WsRequestMapping(path = "/hello")
    public Object testHello(String name, WsContext ctx) {
        return "hello webcat " + name + " from " + ctx.getCi().getClientIp();
    }
}
```

* heartbeat，默认心跳为15s，超过15s没有收到客户端心跳则视为连接断开。
* useProxy，默认没有使用代理，则直接使用RemoteAddress作为客户端ip，如果设置为true，会从路由信息中获取真实客户端ip地址。
* wsPath，默认path为/webcat，可以自行修改。
* logEnable，默认会打开所有websocket请求的日志。
* logResponse，默认日志中不会输入response内容。

```xml
<bean class="com.lchml.webcat.config.WebcatWsConf" id="webcatConf">
    <property name="heartbeat" value="15"/>
    <property name="useProxy" value="false"/>
    <property name="logResponse" value="true"/>
    <property name="logEnable" value="true"/>
</bean>
```

websocket模式，采用json格式做协议交互，格式如下：
```js
{
    "path": "/test/hello", // 请求的path，对应controller中的path
    "mid": 1, // 请求的序号，用于对应请求和回包
    "version": 0, // 版本号，可不用
    "params": {"name": "holyshit"} // 业务的参数
}
```

所有的请求最后都会被组装为WsContext对象：
```java
public class WsContext {
    private String path;

private ChannelInfo ci;

private int mid;

private int version;

private Channel channel;

private Map<String, Object> params;
}
```

其中，ChannelInfo中会包含请求方的客户端ip，并且可以在ChannelConnectListener中自定义其他属性，params默认会根据Controller中方法定义映射到对应的参数上。
### 其他补充
> 项目结构截图如下

![](/contentImages/image/20180324/xhGRSANmDq9cEJ9r9lX.png)

本实例支付的费用只是购买源码的费用，如有疑问欢迎在文末留言交流，如需作者在线代码指导、定制等，在作者开启付费服务后，可以点击“购买服务”进行实时联系，请知悉，谢谢

感谢

手机上随时阅读、收藏该文章？请扫下方二维码

webcat——基于netty的http和websocket框架

概述

详细

相似例子推荐

评论

作者

评分详细

作者例子