server file rename
This commit is contained in:
@@ -1,75 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
using System.Linq;
|
|
||||||
using System.Text;
|
|
||||||
using System.Net.Sockets;
|
|
||||||
using System.Threading;
|
|
||||||
using System.IO;
|
|
||||||
using System.Net;
|
|
||||||
|
|
||||||
namespace OpenRA.Server
|
|
||||||
{
|
|
||||||
static class Program
|
|
||||||
{
|
|
||||||
static void Main(string[] args)
|
|
||||||
{
|
|
||||||
var listener = new TcpListener(IPAddress.Any, 1234);
|
|
||||||
var clients = new List<TcpClient>();
|
|
||||||
|
|
||||||
listener.Start();
|
|
||||||
|
|
||||||
for (; ; )
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var conn = listener.AcceptTcpClient();
|
|
||||||
conn.NoDelay = true;
|
|
||||||
Console.WriteLine("Accepted connection from {0}",
|
|
||||||
conn.Client.RemoteEndPoint.ToString());
|
|
||||||
|
|
||||||
new Thread(() =>
|
|
||||||
{
|
|
||||||
lock (clients)
|
|
||||||
clients.Add(conn);
|
|
||||||
|
|
||||||
var ns = conn.GetStream();
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
for (; ; )
|
|
||||||
{
|
|
||||||
var frame = BitConverter.ToInt32(ns.Read(4), 0);
|
|
||||||
var length = BitConverter.ToInt32(ns.Read(4), 0);
|
|
||||||
var data = ns.Read(length);
|
|
||||||
|
|
||||||
lock (clients)
|
|
||||||
foreach (var c in clients)
|
|
||||||
if (c != conn)
|
|
||||||
{
|
|
||||||
var otherStream = c.GetStream();
|
|
||||||
otherStream.Write(BitConverter.GetBytes(frame));
|
|
||||||
otherStream.Write(BitConverter.GetBytes(length));
|
|
||||||
otherStream.Write(data);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
Console.WriteLine("Client dropped: {0}", conn.Client.RemoteEndPoint.ToString());
|
|
||||||
|
|
||||||
lock (clients)
|
|
||||||
clients.Remove(conn);
|
|
||||||
}
|
|
||||||
}) { IsBackground = true }.Start();
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
Console.WriteLine(e.ToString());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void Write(this Stream s, byte[] data) { s.Write(data, 0, data.Length); }
|
|
||||||
public static byte[] Read(this Stream s, int len) { var data = new byte[len]; s.Read(data, 0, len); return data; }
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -48,7 +48,7 @@
|
|||||||
<Reference Include="System.Xml" />
|
<Reference Include="System.Xml" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<Compile Include="Class1.cs" />
|
<Compile Include="Server.cs" />
|
||||||
<Compile Include="Properties\AssemblyInfo.cs" />
|
<Compile Include="Properties\AssemblyInfo.cs" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
|
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
|
||||||
|
|||||||
Reference in New Issue
Block a user