C# networkcomms 3.0实现模拟登陆总结_c#

最近项目需要做一个客户查询状态系统,当前上位机缺少服务功能,于是找到了networkcomms 开源框架,作为项目使用.

最新版networkcomms 下载地址:https://github.com/marcfletcher/networkcomms.net

下载直接vs打开

新建服务器端

using messagecontract;
using networkcommsdotnet;
using networkcommsdotnet.connections;
using networkcommsdotnet.connections.tcp;
using networkcommsdotnet.dpsbase;
using system;
using system.collections.generic;
using system.componentmodel;
using system.data;
using system.drawing;
using system.linq;
using system.net;
using system.text;
using system.windows.forms;
namespace appserver
{
  public partial class maiform : form
  {
    public maiform()
    {
      initializecomponent();
    }
    sendreceiveoptions aboveoptions = new sendreceiveoptions(dpsmanager.getdataserializer<protobufserializer>(), null, null);
    private void button1_click(object sender, eventargs e)
    {
      //服务器开始监听客户端的请求
      connection.startlistening(connectiontype.tcp, new ipendpoint(ipaddress.parse(txtip.text), int.parse(txtport.text)));
      //服务器开始监听客户端的请求      
      //ipendpoint thepoint = new ipendpoint(ipaddress.parse(txtip.text), int.parse(txtport.text));
      //tcpconnection.startlistening(thepoint, false);
      button1.text = "监听中";
      button1.enabled = false;
      //button1.text = "监听中";
      //button1.enabled = false;
      //此方法中包含服务器具体的处理方法。
      startlistening();
    }
    private void startlistening()
    {
      //开启日志记录 
      //配置日志记录器
      //ilogger logger = new litelogger(litelogger.logmode.consoleandlogfile, "serverlogfile_" + networkcomms.networkidentifier + ".txt");
      //networkcomms.enablelogging(logger);
      //禁用日志记录 服务器端正式使用时，赢禁用日志记录
      networkcomms.disablelogging();
      //服务器端处理收到的消息
      //为简单起见，此示例中我们只处理字符类型的信息，也返回字符类型的信息。
      //处理的信息可以使自定义类，具体见下一个demo
      networkcomms.appendglobalincomingpackethandler<logincontract>("reqlogin", incomingloginrequest);
    }
    //处理某个具体的请求
    private void incomingloginrequest(packetheader header, connection connection, logincontract logincontract)
    {
      try
      {
        string resmsg = "";
        //为了简单，这里不调用数据库，而是模拟一下登录
        if (logincontract.userid == "1000" && logincontract.password == "123")
          resmsg = "登录成功";
        else
          resmsg = "用户名密码错误";
        //把返回结果写入到契约类中，后面返回给客户端
        //resmsgcontract contract = new resmsgcontract();
        //contract.message = resmsg;
        //connection.sendobject<resmsgcontract>("reslogin", contract);
        resmsgcontract contract = new resmsgcontract();
        contract.message = resmsg;
        connection.sendobject("reslogin", contract);
      }
      catch (exception ex)
      {
        // logtools.logexception(ex, "incomingmsghandle");
      }
    }
  }
}

在别的帮助中往往少了这行:导致出现客户端发送时,类型打包出现问题. 这行代码是客户端服务器两端都要加上的,是指定传输方式

 sendreceiveoptions aboveoptions = new sendreceiveoptions(dpsmanager.getdataserializer<protobufserializer>(), null, null);

就是这个报错了

一下是客户端

using messagecontract;
using networkcommsdotnet;
using networkcommsdotnet.connections;
using networkcommsdotnet.connections.tcp;
using networkcommsdotnet.dpsbase;
using system;
using system.collections.generic;
using system.componentmodel;
using system.data;
using system.drawing;
using system.linq;
using system.text;
using system.windows.forms;
namespace appclient
{
  public partial class mainform : form
  {
    public mainform()
    {
      initializecomponent();
    }
    //连接信息对象
    public connectioninfo conninfo = null;
    //连接对象
    connection newtcpconnection;
    sendreceiveoptions aboveoptions = new sendreceiveoptions(dpsmanager.getdataserializer<protobufserializer>(), null, null);
    private void button1_click(object sender, eventargs e)
    {
      //给连接信息对象赋值
      conninfo = new connectioninfo(txtip.text, int.parse(txtport.text));
      //如果不成功，会弹出异常信息
      newtcpconnection = tcpconnection.getconnection(conninfo);
      button1.enabled = false;
      button1.text = "连接成功";
    }
    private void btnlogin_click(object sender, eventargs e)
    {
      //给契约类赋值
      logincontract contract = new logincontract(txtusername.text, txtpassword.text);
      //contract.userid = txtusername.text;
      //contract.password = txtpassword.text;
      //向服务器发送登录信息并获取登录结果
       resmsgcontract resmsg = newtcpconnection.sendreceiveobject<logincontract, resmsgcontract>("reqlogin", "reslogin", 5000, contract);
      //向服务器发送登录信息并获取登录结果
      // resmsgcontract resmsg = newtcpconnection.sendreceiveobject<resmsgcontract>("reqlogin", "reslogin", 5000, contract);
      if (resmsg.message == "登录成功")
      {
        messagebox.show("登录成功");
      }
      else
      {
        messagebox.show("用户名密码错误");
      }
    }
  }
}

契约类

using system;
using system.collections.generic;
using system.linq;
using system.text;
namespace messagecontract
{
  [protocontract]
  public class logincontract
  {
    [protomember(1)]
    public string userid { get; set; }
    [protomember(2)]
    public string password { get; set; }
    public logincontract() { }
    public logincontract(string userid, string password)
    {
      this.userid = userid;
      this.password = password;
    }
  }
}
using protobuf;
using system;
using system.collections.generic;
using system.linq;
using system.text;
namespace messagecontract
{
  [protocontract]
  public class resmsgcontract
  {
    [protomember(1)]
    public string message;
    public resmsgcontract() { }
    public resmsgcontract(string message)
    {
      this.message = message;
    }
  }
}

注意:

使用这个框架要配合谷歌的protobuf 要选好版本.本人没重复测试最高版本,因为在调试登录过程中出现别的问题过程中,也顺改了protobuf 的版本,至今未测试最高版本是否存在兼容问题.本人成功的使用的是2.0.0.668

protobuf简介protobuf是google提供的一个开源序列化框架,类似于xml,json这样的数据表示语言,其最大的特点是基于二进制,因此比传统的xml表示高效短小

vs nuget添加方式