欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

C# Socket实现简单控制台案例

程序员文章站 2023-12-01 23:05:52
一、服务器端 1. 实例化并设置socket实例对象     a.创建ip地址和端口     b.绑定...

一、服务器端

1. 实例化并设置socket实例对象

    a.创建ip地址和端口

    b.绑定监听地址

    c.设置一下允许同时访问数

2. 监听连接

    a.通过启动一个新的线程执行,这样主线程不会假死(启动线程,所带的参数必须是object类型)

    b.利用循环等待连接并返回一个负责通信的socket实例

    c.返回的socket实例中可以获取到所连接客服的ip地址

3. 接收客服的发送过来的消息

    a.在监听方法中启动一个新的线程执行

    b.利用循环获取发送过来的消息,调用获取消息的方法需要传递一个字节变量参数,作为容器。方法返回值为int,表示获取到的有效字节数

    c.如果有效字节数为0则跳出循环

    d.接收到消息给客服的返回消息

4. 控制台程序服务器端代码

using system;
using system.net;
using system.net.sockets;
using system.text;
using system.threading;

namespace serversocket
{
 class program
 {
  static void main(string[] args)
  {
   console.writeline("hello world!");
   socket serversocket = new socket(sockettype.stream, protocoltype.tcp);
   ipaddress ip = ipaddress.any;
   ipendpoint point = new ipendpoint(ip, 2333);
   //socket绑定监听地址
   serversocket.bind(point);
   console.writeline("listen success");
   //设置同时连接个数
   serversocket.listen(10);

   //利用线程后台执行监听,否则程序会假死
   thread thread = new thread(listen);
   thread.isbackground = true;
   thread.start(serversocket);

   console.read();
  }

  /// <summary>
  /// 监听连接
  /// </summary>
  /// <param name="o"></param>
  static void listen(object o)
  {
   var serversocket = o as socket;
   while (true)
   {
    //等待连接并且创建一个负责通讯的socket
    var send = serversocket.accept();
    //获取链接的ip地址
    var sendipoint = send.remoteendpoint.tostring();
    console.writeline($"{sendipoint}connection");
    //开启一个新线程不停接收消息
    thread thread = new thread(recive);
    thread.isbackground = true;
    thread.start(send);
   }
  }

  /// <summary>
  /// 接收消息
  /// </summary>
  /// <param name="o"></param>
  static void recive(object o)
  {
   var send = o as socket;
   while (true)
   {
    //获取发送过来的消息容器
    byte[] buffer = new byte[1024 * 1024 * 2];
    var effective = send.receive(buffer);
    //有效字节为0则跳过
    if (effective == 0)
    {
     break;
    }
    var str = encoding.utf8.getstring(buffer,0, effective);
    console.writeline(str);
           var buffers = encoding.utf8.getbytes("server return message");
           send.send(buffers);

   }
  }
 }
}

二、客户端

1. 实例化并进行连接socket实例对象

    a.创建ip地址和端口(服务器的ip和端口)

    b.与服务器端建立链接

2. 接收服务器发送的消息

    a.启动一个新的线程执行

    b.利用循环获取发送过来的消息,调用获取消息的方法需要传递一个字节变量参数,作为容器。方法返回值为int,表示获取到的有效字节数

    c.如果有效字节数为0则跳出循环

3. 给服务器发送消息

    a. 调用socket对象的send()方法直接发送

4. 控制台程序客户端代码

using system;
using system.net;
using system.net.sockets;
using system.text;
using system.threading;

namespace socketclient
{
 class program
 {
  static void main(string[] args)
  {
   console.writeline("hello world!");
   //创建实例
   socket socketclient = new socket(sockettype.stream, protocoltype.tcp);
   ipaddress ip = ipaddress.parse("192.168.0.111");
   ipendpoint point = new ipendpoint(ip, 2333);
   //进行连接
   socketclient.connect(point);
   
   //不停的接收服务器端发送的消息
   thread thread = new thread(recive);
   thread.isbackground = true;
   thread.start(socketclient);

   //不停的给服务器发送数据
   int i = 0;
   while (true)
   {
    i++;
    var buffter = encoding.utf8.getbytes($"test send message:{i}");
    var temp = socketclient.send(buffter);
    thread.sleep(1000);
   }
   
  }


  /// <summary>
  /// 接收消息
  /// </summary>
  /// <param name="o"></param>
  static void recive(object o)
  {
   var send = o as socket;
   while (true)
   {
    //获取发送过来的消息
    byte[] buffer = new byte[1024 * 1024 * 2];
    var effective = send.receive(buffer);
    if (effective == 0)
    {
     break;
    }
    var str = encoding.utf8.getstring(buffer, 0, effective);
    console.writeline(str);
   }
  }
 }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。