您的位置：首页 > 编程语言 > C#

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

2017-05-06 15:45 681 查看

一、服务器端

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);
}
}
}
}

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

您可能感兴趣的文章:

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签： C# Socket 控制台

相关文章推荐

新的分享

章节导航