BeetleX网关自定义请求日志插件

网关转发日志非常有用可以进行数据和行为分析,组件提供一个默认的日志插件,但默认记录的东西比较简单不一定满足业务的需要;其实组件提供信息非常完善足以满足不同情况的需要。在这里介绍一下如何实现一个日志插件来记录自己需要的信息,。

插件接口

IRequestedHandler是一个代理转发完成的接口,通过实现这一接口可以把转发的结果信息记录下来,先看一下这个接口的定义:

    public interface IPlugin{string Name { get; }string Description { get; }PluginLevel Level { get; }void Init(Gateway gateway, Assembly assembly);void LoadSetting(JToken setting);object SaveSetting();}public interface IRequestedHandler : IPlugin{void Execute(EventRequestCompletedArgs e);}

IRequestedHandler承继了IPlugin,而IPlugin则是描述一个插件的基础信息,主要有包括名称,说明,执行级别和配置处理等.

实现

接下来实现一个转发完成把信息输出控制台的扩展:

    class ConsoleLog : Bumblebee.Plugins.IRequestedHandler{public string Name => "custom_console_log";public string Description => "custom_console_log";public PluginLevel Level => PluginLevel.None;public void Execute(EventRequestCompletedArgs e){Console.WriteLine($"{DateTime.Now} {e.RemoteIPAddress} {e.Gateway.InstanceID} {e.RequestID} {e.SourceUrl} {e.Code}");}public void Init(Gateway gateway, Assembly assembly){}public void LoadSetting(JToken setting){}public object SaveSetting(){return null;}}

代码很简单就是把转发完成的信息在控制台打印出来,LoadSettingSaveSetting并没有实现,因为这个记录日志的功能并不需要配置;如果需要把内容写入数据库或一些服务那则需要实现这两个方法来加载和配置处理相关服务信息。

事件信息

接下来就看了下完成事件提供有那些信息了:

    public struct EventRequestCompletedArgs{public Routes.UrlRoute UrlRoute { get; set; }public int Code { get; }public ServerAgent Server { get; set; }public long Time { get; set; }public bool UrlRewrite { get; set; }public string SourceBaseUrl { get; set; }public string SourceUrl { get; set; }public string SourcePath { get; set; }public long RequestID { get; set; }public string Method { get; set; }public IDictionary<string, string> Cookies { get; set; }public IDictionary<string, object> Data { get; set; }public string RemoteIPAddress { get; set; }public Gateway Gateway { get; set; }public string BaseUrl { get; set; }public string Url { get; set; }public string Path { get; set; }public string Host { get; set; }public IDictionary<string, string> Headers { get; set; }public string Error { get; set; }}

这个类提供了非常详细的信息,请求有那些信息,是否有经过url重写,来源于那个地址和转发到那个服务节点上都有详细记录。

使用插件

插件的引入非常简单,只需要通过组件Gateway.LoadPlugin加载插件所在的程序集即可,代码如下:

gateway.LoadPlugin(typeof(Bumblebee.Configuration.Config).Assembly, typeof(Program).Assembly);

插件加载完成后还需要配置到网关中

 gateway.Pluginer.SetRequested("custom_console_log");

通过以上配置,这个日志插件就会把所有代理请求都输出到控制台用。

获取示例详细代码: https://github.com/IKende/BeetleX-Samples/tree/master/Gateway.LogPlugin

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/312316.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C++函数调用运算符重载

1.函数调用运算符&#xff08;&#xff09;也可以重载 2.由于重载后使用方式非常像函数的调用&#xff0c;因此也称为仿函数 3.仿函数没有固定写法&#xff0c;非常灵活 C函数调用运算符重载代码如下&#xff1a; #include <iostream> using namespace std; #include &…

java gt_JAVA泛型知识--gt; lt;? extends Tgt;和lt;? super Tgt;

extends T> 和 super T> 是Java泛型中的“通配符(Wildcards)” 和 “边界(Bounds)”的概念extends T> 是指 “上界通配符(Upper Bounds Wildcards)”super T> 是指 “下界通配符(Lower Bounds Wildcards)”1. 为什么要用通配符和边界&#xff1f;使用泛型的过程…

使用SignalR从服务端主动推送警报日志到各种终端(桌面、移动、网页)

工作上有个业务&#xff0c;.Net Core WebAPI作为服务端&#xff0c;需要将运行过程中产生的日志分类&#xff0c;并实时推送到各种终端进行报警&#xff0c;终端有桌面(WPF)、移动(Xamarin.Forms)、网站(Angular.JS)等&#xff0c;使用SignalR进行警报日志推送。微信公众号&am…

java图形包_java流布局图形包

第一步&#xff1a;导包import java.awt.FlowLayout;import javax.swing.JButton;import javax.swing.JFrame;第二步&#xff1a;定义类public class TestFlayOut {public static void main(String[] args) {JFrame jf new JFrame("流布局DEMO"); //建立一个窗口Flo…

C++继承的基本语法

首先我们看看没有继承会造成什么问题&#xff1f; 代码如下&#xff1a; #include <iostream> using namespace std;//普通实现页面//Java页面class Java {public:void header() {cout << "首页&#xff0c;公开课&#xff0c;登录&#xff0c;注册...(公共头…

ASP.Net Core 3.1 中使用JWT认证

JWT认证简单介绍关于Jwt的介绍网上很多&#xff0c;此处不在赘述&#xff0c;我们主要看看jwt的结构。JWT主要由三部分组成&#xff0c;如下&#xff1a;HEADER.PAYLOAD.SIGNATUREHEADER包含token的元数据&#xff0c;主要是加密算法&#xff0c;和签名的类型&#xff0c;如下面…

java jstack 死锁_利用jstack检测死锁DeadLock

首先&#xff0c;制造一个死锁程序如下&#xff1a;public class testJstack {final static Object obj_1 new Object();final static Object obj_2 new Object();public static void main(String[] args){Thread t1 new Thread("t1"){public void run(){synchron…

C++继承的继承方式

继承方式一共有三种&#xff1a; 1.公共继承 2.保护继承 3.私有继承

与其每天重复,不如试着构建「正反馈闭环」

大家好&#xff0c;我是Z哥。我们程序员应该算是相对比较有毅力的一个群体了&#xff0c;毕竟入行的高门槛首先就刷掉了一批无法坚持到胜任coding工作的人。况且&#xff0c;新技术的更迭相比其它行业快的多&#xff0c;需要持续学习。即使这样&#xff0c;肯定每个程序员都还有…

java while等待 yeild_Java中run(), start(), join(), wait(), yield(), sleep()的使用

run(), start(), join(), yield(), sleep()这些是多线程中常用到的方法.run(): 每个Thread中需要实现的方法, 如果直接调用的话, 会是和单线程一样的效果, 要另起线程需要使用start().start(): 新起线程调用run(). 主线程不等待直接往下执行join(): 如果有一个Thread a, 在a.st…

C++继承中的对象模型

问题&#xff1a;从父类继承过来的成员&#xff0c;哪些属于子类对象中&#xff1f; 首先我们先看这段代码&#xff1a; #include <iostream> using namespace std;//继承中的对象模型class Base {public:int m_A;protected:int m_B;private:int m_C;};class Son : pub…

2008至今,Chrome如何成长为霸主

2008 年&#xff0c;微软的 Internet Explorer&#xff08;IE&#xff09;浏览器几乎占据了全球浏览器市场份额的 60%&#xff1b;Mozilla 的 Firefox 紧随其后&#xff0c;市场份额约为三分之一&#xff1b;于当年 9 月 2 日初亮相的 Chrome 浏览器则仅占有 0.3% 的市场份额。…

C++继承中构造和析构顺序

子类继承父类后&#xff0c;当创建子类对象&#xff0c;也会调用父类的构造函数 问题&#xff1a;父类和子类的构造和析构顺序是谁先谁后&#xff1f; 代码如下&#xff1a; #include <iostream> using namespace std; //继承中的构造和析构顺序class Base {public:Ba…

linux java -xms_java.lang.OutOfMemoryError及解决方法

主要有3种比较常见的OutOfMemory Error&#xff1a;Java.lang.OutOfMemoryError: Java heap spacejava.lang.OutOfMemoryError: PermGen spacejava.lang.OutOfMemoryError: GC overhead limit exceeded1. java.lang.OutOfMemoryError: Java heap spaceJava heap space&#xff…

Excel模板导出之导出教材订购表

说明本教程主要说明如果使用Magicodes.IE.Excel完成教材订购表的Excel模板导出。要点本教程使用Magicodes.IE.Excel来完成Excel模板导出需要通过创建Dto来完成导出需要按要求准备Excel模板主要步骤1.安装包Magicodes.IE.Excel在本篇教程中&#xff0c;我们仅演示使用Excel来完成…

java jar 目录_将Java类路径中的所有jar包括在一个目录中

有没有一种方法可以将所有的jar文件包含在类路径的目录中&#xff1f;我正在尝试java -classpath lib / *。jar :. my.package.Program&#xff0c;它无法找到当然在这些罐子里的类文件。我是否需要将每个jar文件分别添加到类路径中&#xff1f;使用Java 6或更高版本&#xff0…

AspNetCore 启动地址配置详解

背景程序在发布部署时候&#xff0c;设置环境ASPNETCORE_URLS不生效&#xff0c;也没在代码里使用UseUrls("xxxx"),启动一直是http://localhost:5000.最后测试发现只有在appsettings.json中配置urls才生效&#xff0c;网上找了半天资料也没看到有什么问题。最终翻看源…

C++继承同名成员处理方式

问题&#xff1a;当子类与父类出现同名的成员&#xff0c;如何通过子类对象&#xff0c;访问到子类或父类中同名的数据呢&#xff1f; 1.访问子类同名成员 直接访问即可 2.访问父类同名成员 需要加作用域 一、同名成员属性处理方式 代码如下&#xff1a; #include <iostre…

yii输出mysql查询日志_Yii2框架设置错误日志输出到日志或数据库

设置Yii的错误日志&#xff0c;可按照设置错误级别输入到日志或数据库中。对yii\log\FileTarget做了重写。1、设置common/config/main.php$db require(__DIR__ . /db.php);return [vendorPath > dirname(dirname(__DIR__)) . /vendor,bootstrap > [log],components >…

BeetleX网关非法Url请求拦截插件

一旦网站部署到互联网上&#xff0c;就会受到一些非法的请求&#xff0c;而这些请求的Url都是一些特定的路径或带上一些无关请求的字符用于探测一些服务存在的问题&#xff1b;还有这些请求会落到日志中&#xff0c;导致日志臃肿和转发到后台服务带来处理上的损耗。为了应对拦截…