文件 · 4.x版本 · 若汝棋茗 / RRQMSocket · GitCode

RRQMTcpService service = new RRQMTcpService();

//Subscribe event
//service.ClientConnected += Service_ClientConnected;//Subscribe to the connection event
//service.ClientDisconnected += Service_ClientDisconnected;//Subscribe to disconnection
//service.CreatSocketCliect += Service_CreatSocketCliect;//Subscribe to create a secondary event, you can set other properties directly.
//service.OnReceived += Service_OnReceived;//You can directly subscribe to the received data event.

//Property setting
service.IsCheckClientAlive = true;//Using empty package test activity, there is no impact on the data.
service.BufferLength = 1024;//Set the cache pool size, which is often used in the framework for application byteblock, so this value affects the efficiency of the memory pool.
service.IDFormat = "TcpSocketClient_{0}";//Set the format of the assigned ID, the format must match the string format, at least one reset, the initial value is "{0} -tcp"
service.Logger = new Log();//Set the internal log recorder, the default log is the console output.
service.MaxCount = 1000;//Set the maximum number of connections, which can be dynamically set, and the client will be disconnected when the received number exceeds the set value.

//method
service.Bind(7789, 2);//Binding listening, bind IPv6, can listen all the addresses.

Console.WriteLine("RRQMTcpService Binding success");

TokenTcpService<MyTcpSocketClient> service = new TokenTcpService<MyTcpSocketClient>();
service.VerifyToken = "ABC";

//method
service.Bind(7789, 2);//Binding listening, bind IPv6, can listen all the addresses.

Console.WriteLine("TokenTcpService Binding success");

TcpClient client = new TcpClient();

//Attributes
client.BufferLength = 1024;//Set the cache pool size, which is often used in the framework for application byteblock, so this value affects the efficiency of the memory pool.
client.Logger = new Log();//Set the internal log recorder, the default log is the console output.
client.DataHandlingAdapter = new NormalDataHandlingAdapter();//Data processing adapters can be used to process adhesive bags, parse objects.

//event
//client.ConnectedService += Client_ConnectedService;
//client.DisconnectedService += Client_DisconnectedService;
//client.OnReceived += Client_OnReceived;

//method
client.Connect(new IPHost("127.0.0.1:7789"));//connection
Console.WriteLine("connection succeeded");
client.Send(Encoding.UTF8.GetBytes("若汝棋茗"));//send data
Console.WriteLine("Sent successfully");

TokenTcpClient client = new TokenTcpClient();

//Attributes
client.VerifyToken="ABC";//Set the link password.
client.BufferLength = 1024;//Set the cache pool size, which is often used in the framework for application byteblock, so this value affects the efficiency of the memory pool.
client.Logger = new Log();//Set the internal log recorder, the default log is the console output.
client.DataHandlingAdapter = new NormalDataHandlingAdapter();//Data processing adapters can be used to process adhesive bags, parse objects.

//event
//client.ConnectedService += Client_ConnectedService;
//client.DisconnectedService += Client_DisconnectedService;
//client.OnReceived += Client_OnReceived;

//method
client.Connect(new IPHost("127.0.0.1:7789"));//connection
Console.WriteLine("connection succeeded");
client.Send(Encoding.UTF8.GetBytes("若汝棋茗"));//send data
Console.WriteLine("Sent successfully");

client.DataHandlingAdapter = new NormalDataHandlingAdapter();//Data processing adapters can be used to process adhesive bags, parse objects.
 private static void Service_CreatSocketCliect(RRQMSocketClient arg1, CreatOption arg2)
 {
     if (arg2.NewCreate)
     {
         arg1.DataHandlingAdapter = new NormalDataHandlingAdapter();
     }
 }

public class MyTcpSocketClient : TcpSocketClient
{
    /// <summary>
    /// The initial creation of objects is equivalent to constructing, but the time to call the timing after constructor, the parent class method can be overwritten.
    /// </summary>
    public override void Create()
    {
        this.DataHandlingAdapter = new NormalDataHandlingAdapter();//Ordinary TCP packet processor

    }
}

 FileService fileService = new FileService();
 fileService.VerifyToken ="123ABC";

 fileService.BreakpointResume = true;//Support breakpoint resume
 try
 {
     fileService.Bind(7789,2);//Listening directly to the 7789 port number. Multi-thread, default is 1, here settings the number of threads 2
/* Subscribe to related events
 fileService.ClientConnected += FileService_ClientConnected;
 fileService.ClientDisconnected += FileService_ClientDisconnected;

 fileService.BeforeTransfer += FileService_BeforeTransfer ;
 fileService.FinishedTransfer += FileService_FinishedTransfer ;
 fileService.ReceiveSystemMes += FileService_ReceiveSystemMes;
*/
 }
 catch (Exception ex)
 {
     MessageBox.Show(ex.Message);
 }

FileClient fileClient = new FileClient();
//订阅事件
//fileClient.TransferFileError += FileClient_TransferFileError;
//fileClient.BeforeFileTransfer += this.FileClient_BeforeFileTransfer; ;
//fileClient.FinishedFileTransfer += this.FileClient_FinishedFileTransfer; ;
//fileClient.DisconnectedService += FileClient_DisConnectedService;
//fileClient.ReceiveSystemMes += this.FileClient_ReceiveSystemMes;
//fileClient.ConnectedService += this.FileClient_ConnectedService;
//fileClient.FileTransferCollectionChanged += this.FileClient_FileTransferCollectionChanged;
fileClient.Connect(new IPHost("127.0.0.1:7789"));//connect to the server.


//The Restart property can be freely set.
//BreakPointResume can also be freely specified, but it is best to get attributes from FileClient.
UrlFileInfo urlFileInfo = UrlFileInfo.CreatUpload("C:/1.txt", restart: true, breakpointResume: this.fileClient.BreakpointResume);
fileClient.RequestTransfer(urlFileInfo);

//The Restart property can be freely set.
UrlFileInfo urlFileInfo = UrlFileInfo.CreatDownload("C:/1.txt", restart: true);
fileClient.RequestTransfer(urlFileInfo);
fileClient.PauseTransfer();//Suspend transmission
fileClient.ResumeTransfer();//Restore transmission

foreach (var item in fileClient.FileTransferCollection)
{
    fileClient.CancelTransfer(item);//Get transfer information from the transfer list, then cancel the transfer task
    break;
}

fileClient.StopThisTransfer();//Stop current download
fileClient.StopAllTransfer();//Stop all downloads
fileClient.SendSystemMessage("RRQM");//Send system message
fileClient.SendBytesWaitReturn(new byte[10],0,10);//An array of bytes and wait for returning

public class Server: ServerProvider
{
    [RRQMRPCMethod]
    public string TestOne(string str)
    {
        return "若汝棋茗";
    }
 }
RPCService rpcService = new RPCService();
rpcService.RegistAllService();//Register all services

TcpRPCParser tcpRPCParser = new TcpRPCParser();
tcpRPCParser.SerializeConverter = new BinarySerializeConverter();
tcpRPCParser.Bind(7789, 5);
tcpRPCParser.NameSpace = "RRQMTest";
Console.WriteLine("TCP parser added to complete");

rpcService.AddRPCParser("TcpParser", tcpRPCParser);

rpcService.OpenRPCServer();
Console.WriteLine("RPC starts completion");

Console.ReadKey();

RPCClient client = new RPCClient();

client.InitializedRPC(new IPHost("127.0.0.1:7789"));

Server server = new Server(client);

string mes=server.TestOne("RRQM");//Call
[Route("/[controller]/[action]")]
public class Server: ServerProvider
{
    [Route]
    public string TestOne(string str)
    {
        return "若汝棋茗";
    }
 }
RPCService rpcService = new RPCService();
rpcService.RegistAllService();//Register all services

WebApiParser webApiParser = new WebApiParser();
webApiParser.Bind(7792, 5);
Console.WriteLine("WebApiParser parser added to complete");

rpcService.AddRPCParser("webApiParser", webApiParser);

rpcService.OpenRPCServer();
Console.WriteLine("RPC starts completion");

Console.ReadKey();

public class Server: ServerProvider
{
    [XmlRpc]
    public string TestOne(string str)
    {
        return "若汝棋茗";
    }
 }
RPCService rpcService = new RPCService();
rpcService.RegistAllService();//Register all services

XmlRpcParser xmlRpcParser = new XmlRpcParser();
xmlRpcParser.Bind(7793, 5);
Console.WriteLine("XMLRPCPARSER parser added to complete");

rpcService.AddRPCParser("xmlRpcParser", xmlRpcParser);

rpcService.OpenRPCServer();
Console.WriteLine("RPC starts completion");

Console.ReadKey();

public class Server: ServerProvider
{
    [JsonRpc]
    public string TestOne(string str)
    {
        return "若汝棋茗";
    }
 }
RPCService rpcService = new RPCService();
rpcService.RegistAllService();//Register all services

JsonRpcParser jsonRpcParser = new JsonRpcParser();
jsonRpcParser.Bind(7793, 5);
Console.WriteLine("JSONRPCPARSER parser added to complete");

rpcService.AddRPCParser("jsonRpcParser", jsonRpcParser);

rpcService.OpenRPCServer();
Console.WriteLine("RPC starts completion");

Console.ReadKey();

TcpClient tcpClient = new TcpClient();
//tcpClient.OnReceived += TcpClient_OnReceived;//Receive returns data.
tcpClient.Connect(new IPHost("127.0.0.1:7793"));

tcpClient.Send(Encoding.UTF8.GetBytes("{\"jsonrpc\":\"2.0\",\"method\":\"TestOne\",\"params\":[5],\"id\":1}\r\n"));// "\r\n" must be included here.