代码拉取完成，页面将自动刷新
河南创志威科技有限公司
支持.net core 2.x-7.x，正常使用
支持linux系统，centos，radhat,麒麟，统信，鲲鹏，X86_64,等系统，经过测试互认证。查看证书
业务开发业务逻辑API类时， 搜索nuget包，wRPCService。执行业务逻辑，搜索WeaveRemoteService包
WINX64 运行包 weave_win_1.0.0-1.X64.zip
RPM包下载
登录认证中心RPM包下载
主要目的，尽量简化和减少开发复杂度和难度，微服务由4部分组成。
注册分发中心，集成网关，认证中心，熔断机制，选举机制，架构实现了RPC相关功能。通信协议基于weaving-socket
安装 windows 直接运行发布后，从发布目录中拷贝。 linux 系统： 根据不通CPU选择不同的rpm包下载,
使用 yum install WeaveMicro--.*.rpm(WeaveMicro-1-1.arm64.rpm 或 WeaveMicro-1.0.0-1.aarch64.rpm 或 WeaveMicro-1.0.0-1.x86_64.rpm)进行安装。
设置服务随linux后台启动运行教程 linux服务设置教程
chmod 777 /microcenter/WeaveMicrocenter 然后在执行 /microcenter/WeaveMicrocenter
可以修改目录下config.json文件更改端口和API查询地址 {
"port": 9001,
"url": "http://*:5022"
}
API文档使用
找到config.json文件 修改配置
{
"port": 9001,
"url": "http://*:5022",
"SwaggerPath": "swagger"
}
可使用SwaggerPath配置文档查看地址，默认为根目录（无此配置或设置为空字符串同等效果），如不启用API文档，修改配置如下
{
"port": 9001,
"url": "http://*:5022",
"SwaggerPath": null
}
chmod 777 /gateway/gateway 然后在执行 /gateway/gateway
可以修改目录下config.json文件更改端口和服务中心地址，认证中心注册地址，本地网关找到config.json文件 修改配置{
"Authentication": true,//开启登录认证
"IdentityServer": "http://10.1.65.226",//登录认证地址
"Audience": "ac-cloud",
"defaultScheme": "Bearer",
"applicationUrl": "http://*:5221",//网关请求地址
//网关请求地址支持IP写为*，但必须增加配置bindIP告知服务中心网关实际请求地址，用于在复杂环境下的部署
"bindIP": "127.0.0.1",
"Microcenter": "127.0.0.1:9002",//注册中心
"filetype": ".jpg,.png,.doc,.txt",//指定可上传文件的后缀
"httpspassword": "linezero",//https证书密码
"Cookies": [ "Role", "UserId", "Name", "Phone" ],//开启认证后，token中所包含的指定信息，可明文带入远程服务中
"Headers": [ "token" ],//http指定头部内容可以带入，远程服务中
//设置不允许的HTTP谓词，如TRACE
"HttpDisableMethods": [ "Trace", "Debug" ],
//添加额外的头部
"AddHeaders": {
"Referrer-Policy": "no-referrer",
"X-Content-Type-Options": "nosniff",
"X-Download-Options": "noopen",
"X-Permitted-Cross-Domain-Policies": "master-only",
"X-Frame-Options": "sameorigin",
"X-XSS-Protection": "1; mode=block"
},
}
下载对应的打包发布程序您的服务器上 登录认证中心RPM包发行与使用说明
之前版本认证中心需要重新编译内容，自己提供实现，目前可通过接口继承进行实现。简化编写方法 新建2.0类库 ，nuget 搜索 WeaveVerify，继承 IdentityBase，实现内部方法
public class Verifyabc : IdentityBase
{
public override string PrjName { get; set; } = "abc";//项目名称
public override Verifymode attestation(string Loginname, string Password)
{
Verifymode vm = new Verifymode();
if (true)
{ //认证成功赋值内容
vm.Verify = true;
vm.Claims = new Claim[] {
new Claim("UserId", "123"),
new Claim("Name", "admin"),
new Claim("GivenName", "sdfq") } ;
}
else
{
//认证失败提示错误内容
vm.Verify = false;
vm.ERRMessage = "XXX错误~！";
}
return vm;
}
}
测试提交参数
{
RemoteService remoteService = new RemoteService("TEST");//TEST 为你注册的API名称
remoteService.Start();
}
修改配置文件
{
"ServerIP": "127.0.0.1",//本机需要绑定的IP
"Port": 10098,//需要绑定的端口用于网关调用
"Microcenter": "127.0.0.1:8001"//服务中心的IP和端口
}
- 新建CLASS继承 : FunctionBase 基类
- 基类介绍，FunctionBase 包含 Cookies，和 Headers 两个属性，Headers为http请求头可以被带入的内容，Cookies 为开启认证后，登录的token中所包含的指定信息，可明文带入远程服务中。
- 标识属性 Route ， [Route("abcd")]放在类上面，标识次类的API路由地址，
- 标识属性 InstallFun ， [InstallFun(FunAttribute.NONE, "此方法用于测试")] ，参数1：FunAttribute.NONE，标识此方法接收POST 传入的 json类型对象。参数2：用于API测试中的注释说明。FunAttribute { NONE,Get,POST ，file} 包含四种请求类型
- 统一响应返回格式 IApiResult接口，（可选）如果需要统一API响应格式，可通过继承IApiResult接口，定义返回格式。系统会自动获取T的类型并展示到Swagger文档中。
业务方法可以写成这样 `public async Task<IApiResult> Update(T_DisasterCase o)`
- async，支持方法类型为异步响应async。
[Route("abcd")]//路由地址
public class Class2: FunctionBase//FunctionBase可以继承，也可以不继承，方便以后扩展功能
{
[InstallFun(FunAttribute.NONE, "此方法用于测试")]//指定方法为远程方法，
//FunAttribute { NONE,Get,POST ，file} 包含四种请求类型，为方法写注释
public String ff(mode md)
{
// Console.WriteLine(md.name);
return "Class2.ff的返回值";
}
[Authorize]//此处表明此方法需要权限验证
[InstallFun(FunAttribute.NONE, "此方法用于测试")]
public String ff2([Param("用户名")] string name)//[Param("用户名")] 为每个参数写注释
{
/// Console.WriteLine(name);
return "Class2.f2f22的返回值";
}
}
[InstallFun(FunAttribute.file, "此方法用于测试")]
public String ff()//接收文件并保存
{
object obj= this.Cookies; object obj2 = this.Headers;
System.IO.FileStream streamWriter = new System.IO.FileStream(this.Filedata.filename,System.IO.FileMode.Create);
streamWriter.Write(this.Filedata.data,0, this.Filedata.data.Length);
streamWriter.Close();
return this.Filedata.filename;
}
（可选）如果需要统一API响应格式，可通过继承IApiResult接口，定义返回格式。系统会自动获取T的类型并展示到Swagger文档中
/// <summary>
/// Api返回结果
/// </summary>
public class ApiResult<T> : IApiResult
{
/// <summary>
/// 状态码：200成功500异常0操作失败
/// </summary>
public int code { get; set; }
/// <summary>
/// 状态描述
/// </summary>
public string message { get; set; }
/// <summary>
/// 返回数据
/// </summary>
public T data { get; set; }
/// <summary>
/// 异常数据
/// </summary>
public dynamic errData { get; set; }
}
//API签名可以这样写（wRPCService v1.0.8 以上版本）
public async Task<IApiResult> Update(T_DisasterCase o)...
[InstallFun(FunAttribute.Get, "此方法用于测试")]//指定方法为远程方法，
//FunAttribute { NONE,Get,POST ，file} 包含四种请求类型，为方法写注释
public String ff(String md)
{
// Console.WriteLine(md);
return "Class2.ff的返回值";
}
[InstallFun(FunAttribute.POST, "此方法用于测试")]//指定方法为远程方法，
//FunAttribute { NONE,Get,POST ，file} 包含四种请求类型，为方法写注释
public String ff(String md,int a)
{
// Console.WriteLine(md);
return "Class2.ff的返回值";
}
[InstallFun(FunAttribute.NONE, "此方法用于测试")]//指定方法为远程方法，
//FunAttribute { NONE,Get,POST ，file} 包含四种请求类型，为方法写注释
public String ff(mode md)//只能传入一个对象
{
// Console.WriteLine(md.name);
return "Class2.ff的返回值";
}
[InstallFun(FunAttribute.file, "此方法用于测试")]
public String ff(string name)//接收文件并保存
{
object obj= this.Cookies; object obj2 = this.Headers;
System.IO.FileStream streamWriter = new System.IO.FileStream(this.Filedata.filename,System.IO.FileMode.Create);
streamWriter.Write(this.Filedata.data,0, this.Filedata.data.Length);
streamWriter.Close();
return this.Filedata.filename;
}
public async Task<String> ff()
{
object obj= this.Cookies; object obj2 = this.Headers;
await Task.Delay(1000);
return await Task.Run(() => { ; return "aaaaaa"; } ) ;
}
流式返回可以在数据量较大的时候，数据快速响应到页面
[InstallFun(FunAttribute.Get, "测试流传输")]
public void ff22()
{
int i = 0;
DateTime dt = DateTime.Now;
while (true)
{ i++;
this.PushStream("Weave微服务架构,是.net core下开发的由分发网关，服务中心，认证中心，服务API 组成，具有多负载分布式特点");
if (i > 20000)
break;
}
DateTime dt2 = DateTime.Now;
Console.WriteLine("ff22:"+(dt2-dt).TotalMilliseconds);
}
[Route("api/test")]
public class testclass : ApiBase<object>//继承ApiBase<object>基类
{
public async Task<ApiResult<String>> test()
{
return await TRY(async () =>
{
// 写自己的方法内容
return "";
});
}
public async Task<IApiResult> testapi()
{
return await TRY(async () =>
{
// 写自己的方法内容
return "";
});
}
}
[InstallFun(FunAttribute.Get, "测试流传输", "application/octet-stream")]
public void ffs22()
{
DateTime dt = DateTime.Now;
int i = 0;
while (true)
{
i++;
this.PushStream(System.Text.UTF8Encoding.UTF8.GetBytes("Weave微服务架构,是.net core下开发的由分发网关，服务中心，认证中心，服务API 组成，具有多负载分布式特点"));
if (i > 100000)
break;
}
DateTime dt2 = DateTime.Now;
Console.WriteLine("ffs22:" + (dt2 - dt).TotalMilliseconds);
/// Console.WriteLine(name);
}
首先需要在gateway网关中修改配置文件，
"Headers": [ "token" ]//添加需要获取到的HTTP header
[InstallFun(FunAttribute.Get, "测试")]
public string ff22()
{
var value = this.Headers["对应KEY"];
return "";
}
认证中心需要返回对应的资料内容如下：
context.Result = new GrantValidationResult(
subject: context.UserName,
authenticationMethod: "custom",
claims: new Claim[] {
new Claim("UserId", "ceshi123"),
new Claim("Name","ceshi"),
new Claim("Phone", "135135"),
new Claim("Role","admin"),
new Claim("Area","41")
});
然后需要在gateway网关中修改配置文件，
"Cookies": [ "Areacode", "Role", "UserId", "Name", "Phone" ]
[InstallFun(FunAttribute.Get, "测试")]
public string ff22()
{
var value = this.Cookies["对应KEY"];
return "";
}
无验证的调用
有验证的调用
wRPCclient.ClientChannel clientChannel = new wRPCclient.ClientChannel("127.0.0.1", 10098); //连接API服务的地址
String retun = clientChannel.Call<String>("api/abcd", "ff2","asdasd");//"api/abcd" 路由地址，ff2，调用的方法名称，"asdasd" 传入的参数，有几个就写几个，多个参数，可以写多个如，Call<String>("路由名", "方法名","参数1"，"参数2");
//Call<String> 为返回的值类型
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型