这篇文章主要为大家分享了c# socket简单的控制台案例，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
一、服务器端
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实现简单控制台案例的详细内容。