当前位置：移动技术网 > IT编程>开发语言>.net > 浅谈surging服务引擎中的rabbitmq组件和容器化部署

浅谈surging服务引擎中的rabbitmq组件和容器化部署

2018年08月29日 | 移动技术网IT编程 | 我要评论

旧军孟,雅安志愿者,圣诞节黑板报

1、前言

上个星期完成了surging 的0.9.0.1 更新工作，此版本通过nuget下载引擎组件，下载后，无需通过代码build集成，引擎会通过sidecar模式自动扫描装配异构组件来构建服务引擎，而这篇将介绍浅谈surging服务引擎中的rabbitmq组件和容器化部署

2、sidecar模式

　　比如现在比较火的service mesh，谈到service mesh，就不得不了解下sidecar模式，sidecar设计模式被越来越多的关注和采用，此模式之所以称作sidecar，是因为它类似于三轮摩托车上的挎斗。在此模式中，挎斗附加到应用程序中，为应用程序提供支持性功能。挎斗与应用程序具有相同的生命周期：与应用程序一起创建，一起停用。挎斗模式有时也称为搭档模式，这是一种分解模式。而surging 采用了sidecar模式用来附加组件，而使用sidecar模式有以下功能

共享存储空间

　引擎组件部署到共享的文件目录里，服务引擎从共享的文件目录扫描引擎组件文件。

共享组件和业务的配置文件

针对于组件的配置文件部署到共享的文件目录里，服务引擎从共享的文件目录加载文件。

独立的业务服务

针对于业务可以把依赖的组件打包部署到共享的文件目录里，服务引擎从共享的文件目录扫描加载，从而部署成独立的业务服务

内置多种协议

针对于独立部署的业务服务，内置了多种协议，提供给服务和外部程序进行调用

模式特点

隔离：让组件都能够关注核心问题。比如eventbus、logger、 netty 在实现功能的同时无需关注其它组件的实现而发生的冲突；
单一责任原则：每个组件都应该职责分开，而根据这一原则，职责应该是对应一个类、模块或者接口，从而能够独立进行处理。
内聚性/可重用性：针对组件的特性，方法可以进行重用，从而满足组件可持续扩展。

3、基于event bus 的rabbitmq组件

surging服务引擎扩展了基于eventbus 的rabbitmq ，组件可以选择绑定 normal，retry(dead letter)，fail ，如下图所示。

而针对于该组件有哪些应用场景呢？

商品秒杀和抢购

抢购/秒杀是如今很常见的一个应用场景，在高并发的流量访问下可以将用户放入到抢购队列中，购买成功则销毁消息。

最终数据的一致性

在大型业务中，系统一般由多个独立的服务组成，在分布式调用时候把消息放入到rabbitmq 队列中，再通过消息的幂等性来解决数据的最终一致性

订单失效处理

在购买商品/服务生成订单业务中，会设定支付时间，如果一直未支付，会直接关闭订单，而这个场景可以通过死信队列的来解决

示例代码

可以通过继承baseintegrationeventhandler或者iintegrationeventhandler，再通过queueconsumer特性进行标识，具体代码如下

  [queueconsumer("userlogindatechangehandler",queueconsumermode.normal)]
    public  class userlogindatechangehandler : baseintegrationeventhandler<userevent>
    {
        private readonly iuserservice _userservice;
        public userlogindatechangehandler()
        {
            _userservice = servicelocator.getservice<iuserservice>("user");
        }
        public override async task handle(userevent @event)
        {
            console.writeline($"消费1。");
            await _userservice.update(@event.userid, new usermodel()
            {
                age = @event.age,
                name = @event.name,
                userid = @event.userid
            });
            console.writeline($"消费1失败。");
            throw new exception();
        }

        public override task handled(eventcontext context)
        {
            console.writeline($"调用{context.count}次。类型:{context.type}");
            var model = context.content as userevent;
            return task.completedtask;
        }
    }

可以通过以下选项去更改配置

 1 "eventbus": {
 2     "eventbusconnection": "${eventbusconnection}|localhost",
 3     "eventbususername": "${eventbususername}|guest",//用户名
 4     "eventbuspassword": "${eventbuspassword}|guest",//密码
 5     "virtualhost": "${virtualhost}|/",
 6     "messagettl": "${messagettl}|30000",//消息过期时间，比如过期时间是30分钟就是1800000
 7     "retrycount": "${retrycount}|1",//重试次数，这里设置的延迟队列，只能设置为1
 8     "failcount": "${failcount}|3",//处理失败流程重试次数，如果出现异常，会进行重试
 9     "prefetchcount": "${prefetchcount}|0",//设置均匀分配消费者消息的个数
10     "brokername": "${brokername}|surging_demo",//exchange 名称
11     "port": "${eventbusport}|5672"//端口
12   }

生成绑定的队列如下图

通过rabbitmq管理工具，可以通过properties来查看重试次数count 等一些信息，如下图所示

4、如何部署

surging 服务引擎构建镜像部署在docker中，可以按照业务需求自定义化引擎，也可以从 docker hub中pull镜像，可以按照如下流程从docker hub 拉取部署镜像

如何pull镜像

可以通过命令：

docker pull serviceengine/surging

可以指定具体的tag来拉取，比如需要拉取v0.9.0.2，执行以下命令

docker pull serviceengine/surging:v0.9.0.2

如何配置

1.镜像可以用环境变量设置相关参数，而通过以下的默认配置文件知晓如何通过环境变量配置参数，配置的规则：${环境变量名}|默认值

{
  "surging": {
    "ip": "${surging_server_ip}|0.0.0.0",
    "watchinterval": 30,
    "port": "${surging_server_port}|99",
    "mappingip": "${mapping_ip}",
    "mappingport": "${mapping_port}",
    "token": "true",
    "maxconcurrentrequests": 20,
    "executiontimeoutinmilliseconds": 30000,
    "protocol": "${protocol}|none", //http、tcp、none
    "rootpath": "${rootpath}|d:\\userapp",
    "ports": {
      "httpport": "${httpport}|280",
      "wsport": "${wsport}|96"
    },
    "requestcacheenabled": false,
    "packages": [
      {
        "typename": "enginepartmodule",
        "using": "${useengineparts}|dotnettymodule;nlogmodule;messagepackmodule;consulmodule;httpprotocolmodule;wsprotocolmodule;eventbusrabbitmqmodule;"
      }
    ]
  }, //如果引用多个同类型的组件，需要配置packages，如果是自定义按需引用，无需配置packages
  "consul": {
    "connectionstring": "${register_conn}|127.0.0.1:8500", // "127.0.0.1:8500",
    "sessiontimeout": "${register_sessiontimeout}|50",
    "routepath": "${register_routepath}",
    "reloadonchange": true
  },
  "eventbus_kafka": {
    "servers": "${eventbusconnection}|localhost:9092",
    "maxqueuebuffering": "${maxqueuebuffering}|10",
    "maxsocketblocking": "${maxsocketblocking}|10",
    "enableautocommit": "${enableautocommit}|false",
    "logconnectionclose": "${logconnectionclose}|false",
    "offsetreset": "${offsetreset}|earliest",
    "groupid": "${eventbusgroupid}|surgingdemo"
  },
  "eventbus": {
    "eventbusconnection": "${eventbusconnection}|localhost",
    "eventbususername": "${eventbususername}|guest",
    "eventbuspassword": "${eventbuspassword}|guest",
    "virtualhost": "${virtualhost}|/",
    "messagettl": "${messagettl}|30000",
    "retrycount": "${retrycount}|1",
    "failcount": "${failcount}|3",
    "brokername": "${brokername}|surging_demo",
    "port": "${eventbusport}|5672"
  },
  "zookeeper": {
    "connectionstring": "${zookeeper_connectionstring}|127.0.0.1:2181",
    "sessiontimeout": 50,
    "reloadonchange": true
  },
  "logging": {
    "debug": {
      "loglevel": {
        "default": "information"
      }
    },
    "console": {
      "includescopes": true,
      "loglevel": {
        "default": "${loglevel}|debug"
      }
    },
    "loglevel": {
      "default": "${loglevel}|debug"
    }
  }
}

2.可以通过设置环境变量surgingpath和cachepath来指定自定义文件配置，比如，挂载/home/fanly 目录，通过以下命令参数 -v /home/fanly:/home/fanly 来设定，再通过设置以下命令参数用来设定自定义文件配置

--env surgingpath=/home/fanly/configs/surgingsettings.json
--env cachepath=/home/fanly/configs/cachesettings.json

如何启动内置引擎组件

引擎可以加载多个同一类型的引擎组件，可以通过以下配置启用哪一种引擎组件,如果是自定义的服务引擎，不需要配置以下配置，只需要按照需求引用组件

 "packages": [
      {
        "typename": "enginepartmodule",
        "using": "${useengineparts}|dotnettymodule;nlogmodule;messagepackmodule;consulmodule;httpprotocolmodule;wsprotocolmodule;eventbusrabbitmqmodule;"
      }
    ]

如何启动引擎

比如 pull 的镜像是serviceengine/surging:v0.9.0.2 ，可以按照以下命令进行启动

docker run --name surging --env surgingpath=/home/fanly/configs/surgingsettings.json  --env cachepath=/home/fanly/configs/cachesettings.json -v /home/fanly:/home/fanly  serviceengine/surging:v0.9.0.2

7.总结

如有问题请到提问，可以加入surging互相交流qq群：542283494，引擎组件扩展沟通群：615562965

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！点击进行留言回复

详解.NET Core 3.0 里新的JSON API

为什么需要新的 json api ？json.net 大家都用过，老版本的 asp.net core 也依赖于 json.net 。然而这个依赖就会引起一些版... [阅读全文]
Net Core Web Api项目与在NginX下发布的方法

前言本文将介绍net core的一些基础知识和如何nginx下发布net core的webapi项目。测试环境操作系统：windows 10 开发工具：v... [阅读全文]
浅谈ASP.NET Core 中jwt授权认证的流程原理

1，快速实现授权验证什么是 jwt ？为什么要用 jwt ？jwt 的组成？这些百度可以直接找到，这里不再赘述。实际上，只需要知道 jwt 认证模式是使用一段 ... [阅读全文]
.Net Core 实现图片验证码的实现示例

记录自己的学习，参考了网上各位大佬的技术，往往在登录的时候需要使用到验证码来进行简单的一个校验，这边使用在.net core上进行生成图片二维码思路很简单=》 ... [阅读全文]
asp.net core3.1 引用的元包dll版本兼容性问题解决方案

自从.netcore 3.1出来后，大家都想立马升级到最新版本。我也是如此，微软也对.netcore 3.1 的官方组件不断升级，几乎每隔几天就会有部分元包可以... [阅读全文]
IdentityServer4实现.Net Core API接口权限认证(快速入门)

什么是identityserver4官方解释：identityserver4是基于asp.net core实现的认证和授权框架，是对openid connect... [阅读全文]
从ASP.NET Core3.1迁移到5.0的方法

3月中旬，微软官方已经发布了dotnet 5的第一个预览版：5.0.0-preview.1。dotnet core经过前几个版本的发展和沉淀，到3.1已经基本趋... [阅读全文]
.NET Core中创建和使用NuGet包的示例代码

在.net core的项目中，如果我们要在项目中引用其它dll文件，不建议直接在项目引用中添加dll文件（虽然在.net core项目中也可以这么做），建议是去... [阅读全文]
ASP.NET Core MVC通过IViewLocationExpander扩展视图搜索路径的实现

iviewlocationexpander api expandviewlocations razor视图路径，视图引擎会搜索该路径. populateva... [阅读全文]
ASP.NET Core中的Controller使用示例

asp.net core出现之前我们实现的controller，mvc都继承自controller基类，webapi的话继承自apicontroller。现在a... [阅读全文]