C# Socket实现简单控制台案例
一、服务器端
1.实例化并设置socket实例对象
a.创建ip地址和端口
b.绑定监听地址
c.设置一下允许同时访问数
2.监听连接
a.通过启动一个新的线程执行，这样主线程不会假死(启动线程，所带的参数必须是object类型)
b.利用循环等待连接并返回一个负责通信的socket实例
c.返回的socket实例中可以获取到所连接客服的IP地址
3.接收客服的发送过来的消息
a.在监听方法中启动一个新的线程执行
b.利用循环获取发送过来的消息，调用获取消息的方法需要传递一个字节变量参数，作为容器。方法返回值为int，表示获取到的有效字节数
c.如果有效字节数为0则跳出循环
d.接收到消息给客服的返回消息
4.控制台程序服务器端代码
usingSystem;
usingSystem.Net;
usingSystem.Net.Sockets;
usingSystem.Text;
usingSystem.Threading;
namespaceServerSocket
{
classProgram
{
staticvoidMain(string[]args)
{
Console.WriteLine("HelloWorld!");
SocketserverSocket=newSocket(SocketType.Stream,ProtocolType.Tcp);
IPAddressip=IPAddress.Any;
IPEndPointpoint=newIPEndPoint(ip,2333);
//socket绑定监听地址
serverSocket.Bind(point);
Console.WriteLine("ListenSuccess");
//设置同时连接个数
serverSocket.Listen(10);
//利用线程后台执行监听,否则程序会假死
Threadthread=newThread(Listen);
thread.IsBackground=true;
thread.Start(serverSocket);
Console.Read();
}
///
///监听连接
///
///
staticvoidListen(objecto)
{
varserverSocket=oasSocket;
while(true)
{
//等待连接并且创建一个负责通讯的socket
varsend=serverSocket.Accept();
//获取链接的IP地址
varsendIpoint=send.RemoteEndPoint.ToString();
Console.WriteLine($"{sendIpoint}Connection");
//开启一个新线程不停接收消息
Threadthread=newThread(Recive);
thread.IsBackground=true;
thread.Start(send);
}
}
///
///接收消息
///
///
staticvoidRecive(objecto)
{
varsend=oasSocket;
while(true)
{
//获取发送过来的消息容器
byte[]buffer=newbyte[1024*1024*2];
vareffective=send.Receive(buffer);
//有效字节为0则跳过
if(effective==0)
{
break;
}
varstr=Encoding.UTF8.GetString(buffer,0,effective);
Console.WriteLine(str);
varbuffers=Encoding.UTF8.GetBytes("ServerReturnMessage");
send.Send(buffers);
}
}
}
}
二、客户端
1.实例化并进行连接socket实例对象
a.创建ip地址和端口(服务器的IP和端口)
b.与服务器端建立链接
2.接收服务器发送的消息
a.启动一个新的线程执行
b.利用循环获取发送过来的消息，调用获取消息的方法需要传递一个字节变量参数，作为容器。方法返回值为int，表示获取到的有效字节数
c.如果有效字节数为0则跳出循环
3.给服务器发送消息
a.调用socket对象的send()方法直接发送
4.控制台程序客户端代码
usingSystem;
usingSystem.Net;
usingSystem.Net.Sockets;
usingSystem.Text;
usingSystem.Threading;
namespaceSocketClient
{
classProgram
{
staticvoidMain(string[]args)
{
Console.WriteLine("HelloWorld!");
//创建实例
SocketsocketClient=newSocket(SocketType.Stream,ProtocolType.Tcp);
IPAddressip=IPAddress.Parse("192.168.0.111");
IPEndPointpoint=newIPEndPoint(ip,2333);
//进行连接
socketClient.Connect(point);
//不停的接收服务器端发送的消息
Threadthread=newThread(Recive);
thread.IsBackground=true;
thread.Start(socketClient);
//不停的给服务器发送数据
inti=0;
while(true)
{
i++;
varbuffter=Encoding.UTF8.GetBytes($"TestSendMessage:{i}");
vartemp=socketClient.Send(buffter);
Thread.Sleep(1000);
}
}
///
///接收消息
///
///
staticvoidRecive(objecto)
{
varsend=oasSocket;
while(true)
{
//获取发送过来的消息
byte[]buffer=newbyte[1024*1024*2];
vareffective=send.Receive(buffer);
if(effective==0)
{
break;
}
varstr=Encoding.UTF8.GetString(buffer,0,effective);
Console.WriteLine(str);
}
}
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。