网络框架:java_chainMarket

public class App {
    public static void main(String[] args) {
        init();
        //初始化chainMarket服务
        HttpServer httpServer = new HttpServer();
        //参数分别是 端口号
        //control类所在的包路径（接口入口类所在的包路径），
        // 允许接收的最大字节数（超过这个数量，将直接返回400错误码）
        //websocket url,
        //websocket 回调类
        //启动chainMarket服务
        httpServer.start(8080, "com.shareData.chainMarket.test", 1024,
                null, null);
        //若要启动WEBSOCKET服务，请将后两个参数传入
       //httpServer.start(8080, "com.shareData.chainMarket.test", 1024,
       //"ws://127.0.0.1:8080/websocket", new MyWebSocket());
    }

    public static void init() {
        //是否启动SSL服务，若启动则服务器无法接收HTTP请求，只能接收HTTPS请求
        //反之也一样
        HttpsSetting.sslEnabled = false;//不启动SSL服务，不设置就是默认不启动
        HttpsSetting.keystorePath = "SSL证书在磁盘上的地址";
        HttpsSetting.certificatePassword = "SSL证书密码";
        HttpsSetting.keystorePassword = "SSL证书密码";//上下两者等同
        Config.setFileMaxLength(6553666);//上传文件的最大大小,单位BIT
    }

}
//在设置的control包路径下，创建control类
//注解 Central代表虚拟路径名称，在内部的URL中填写虚拟路径
//这样这两个接口地址分别是 /login/wxLogin,/login/getCommunity
//不区分post,get,message是 POST体的参数，map 是url？后面的健值对（get参数）
//return 是返回内容
@Central(url = "/login")
public class Login {
@Central(url = "/wxLogin")
public String wxLogin(String message, Map<Object, Object> map) {//微信小程序登录
    return wxLogin(message);
}

@Central(url = "/getCommunity")
public String land(String message, Map<Object, Object> map) {//获取全部社区
    return getSmallCity();
}
//若是FORM表单提交信息，请使用List<FileAndName> forms 来接收
@Central(url = "/list")
    public String list(List<FileAndName> forms) {
        return "a";
        }
}
//List<FileAndName>
//FileAndName 是一个健值对，LIST就是接收的一个健值对集合
//FileAndName 中有三个参数
//name,键名
//text,文本类型的值
//inputStream，二进制文件类型的值
//注意文本类型和二进制类型互斥，有其中一种，另一种就是null。
//从inputStream中读取字节码后，无需关闭字节流，return之后底层会自动关闭
    public class FileAndName {
        private InputStream inputStream;
        private String name;
        private String text;
    }

        public class MyWebSocket extends WebSocketBack {
        //若启用WEBSOCKET,创建回调类
        //且必须继承WebSocketBack，并重写active方法和 getText方法
        @Override
        public void active(ChannelHandlerContext ctx) {
        //当用户进行WEBSOCKET握手时激活，一个用户构成一个连接有且只执行一次
            System.out.println("激活了======");
        }
    
        @Override
        public String getText(String message, ChannelHandlerContext ctx) {
          //收到一个WEBSOCKET通讯
          //将一个通讯的信道注册起来，与主键绑定
          WebSocketManager.register(1,ctx);
          //通过绑定的主键，服务端主动给用户PUSH信息
          WebSocketManager.putMessage(1,"发送信息");
    
            return "ok";
        }}