当前位置：网站首页>C how TCP restricts the access traffic of a single client

C how TCP restricts the access traffic of a single client

2022-07-05 16:55:00 【Ruo Qiming】

List of articles

One 、 explain

Use RRQMSocket After creating the server , Want to realize a current limiting function , How should it be realized ？

Two 、 Assembly source code

2.1 Source location

2.2 documentation

The front page of the document

3、 ... and 、 install

Nuget install RRQMSocket that will do , See link blog for specific steps .

VS、Unity Installation and use Nuget package

Four 、 Creating plug-ins

public class MyThrottlingPlugin : TcpPluginBase
{
    
    private readonly int m_max;

    [DependencyInject(10)]
    public MyThrottlingPlugin(int max)
    {
    
        this.m_max = max;
        this.Order = int.MaxValue;// Raise priority 
    }

    protected override void OnConnected(ITcpClientBase client, RRQMEventArgs e)
    {
    
        client.InitFlowGate(this.m_max);// Initialize the flow counter .
        base.OnConnected(client, e);
    }

    protected override void OnReceivedData(ITcpClientBase client, ReceivedDataEventArgs e)
    {
    
        client.GetFlowGate().AddCheckWait(e.ByteBlock.Len);// It is assumed here that ByteBlock data . If it is a custom adapter , Increment as needed .
        base.OnReceivedData(client, e);
    }
}

5、 ... and 、 Create an extension class

 /// <summary>
 ///  A flow counter extension .
 /// </summary>
 static class DependencyExtensions
 {
    
     public static readonly DependencyProperty FlowGateProperty =
         DependencyProperty.Register("FlowGate", typeof(FlowGate), typeof(DependencyExtensions), null);

     public static void InitFlowGate(this IRRQMDependencyObject dependencyObject, int max)
     {
    
         dependencyObject.SetValue(FlowGateProperty, new FlowGate() {
     Maximum = max });
     }

     public static FlowGate GetFlowGate(this IRRQMDependencyObject dependencyObject)
     {
    
         return dependencyObject.GetValue<FlowGate>(FlowGateProperty);
     }
 }

6、 ... and 、 Start the server

static void Main(string[] args)
{
    
    TcpService service = new TcpService();
    service.Connecting += (client, e) => {
     };// A client is connecting 
    service.Connected += (client, e) => {
     };// There is a client connection 
    service.Disconnected += (client, e) => {
     };// A client is disconnected 
    service.Received += (client, byteBlock, requestInfo) =>
    {
    
        // Receive message from client 
        string mes = Encoding.UTF8.GetString(byteBlock.Buffer, 0, byteBlock.Len);
        Console.WriteLine($" From {
      client.ID} Received information ：{
      mes}");

        client.Send(mes);// Return the received information directly to the sender 
    };

    service.Setup(new RRQMConfig()// Load configuration  
        .UsePlugin()
        .SetListenIPHosts(new IPHost[] {
     new IPHost("127.0.0.1:7789"), new IPHost(7790) })// Listen to two addresses at the same time 
        .SetMaxCount(10000)
        .SetThreadCount(100))
        .Start();// start-up 
    service.AddPlugin<MyThrottlingPlugin>();

    Console.ReadLine();
}