using System;
using System.Net;
using System.Net.Sockets;
using System.Threading.Tasks;
using System.Diagnostics;
namespace MultiDup
{
internal class Program
{
const int serverport = 6005; // 用于监听服务端连接的端口号
public static ServerPeer serverPeer = null; // 战斗server的连接
const int port = 6004; // 端口号(用来监听的)
static void Main(string[] args)
{
selfTest();
Console.WriteLine("开启监听......");
Console.WriteLine("ctrl + c 退出程序......");
Task[] tasks = new Task[2];
tasks[0] = Task.Run(WatchConnecting);
tasks[1] = Task.Run(WatchServerPeerConnecting);
Task.WaitAll(tasks); // 开启监听线程
}
static void selfTest()
{
var rdb = Redis.Ins.GetDatabase(0);
Debug.Assert(rdb.StringSet("test", "wanggang" + DateTime.Now.ToString("yyyyMMddHHmmss")), "Redis读写失败!");
}
///
/// 监听客户端发来的请求
///
async static Task WatchConnecting()
{
IPAddress ip = IPAddress.Any;
IPEndPoint ipe = new IPEndPoint(ip, port); //将IP地址和端口号绑定到网络节点point上
//定义一个套接字用于监听客户端发来的消息,包含三个参数(IP4寻址协议,流式连接,Tcp协议)
Socket SocketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
SocketWatch.Bind(ipe); // 监听绑定的网络节点
SocketWatch.Listen(20); // 将套接字的监听队列长度限制为20
while (true) // 持续不断监听客户端发来的请求
{
Socket connection;
try
{
connection = await SocketWatch.AcceptAsync();
}
catch (Exception ex)
{
Console.WriteLine(ex.Message); // 提示套接字监听异常
break;
}
Lobby.Instance.OnNewPeerConnected(new Peer(connection)); // 有新客户端连入
}
SocketWatch.Close(); // 结束监听socket
}
///
/// 监听服务端发来的请求
///
async static Task WatchServerPeerConnecting()
{
IPAddress ip = IPAddress.Any;
IPEndPoint ipe = new IPEndPoint(ip, serverport); //将IP地址和端口号绑定到网络节点point上
//定义一个套接字用于监听客户端发来的消息,包含三个参数(IP4寻址协议,流式连接,Tcp协议)
Socket SocketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
SocketWatch.Bind(ipe); // 监听绑定的网络节点
SocketWatch.Listen(20); // 将套接字的监听队列长度限制为20
while (true) // 持续不断监听客户端发来的请求
{
Socket connection;
try
{
connection = await SocketWatch.AcceptAsync();
}
catch (Exception ex)
{
Console.WriteLine(ex.Message); // 提示套接字监听异常
break;
}
Console.WriteLine("server peer 连接上来了.");
serverPeer = new ServerPeer(connection); // 建立与服务端的连接
}
SocketWatch.Close(); // 结束监听socket
}
}
}