I need to write a TCP server for a project at work, and I googled around how. I got the MSDN response and managed to get it working, but I don’t know how to get the data in order to be able to get back and forth. Sockets will not connect for more than 30 seconds MAX (because my boss does not want the connectors to be open on computers). The purpose of this class is to provide a quick way for me in my main program to get data about the computer and its user.
By the name of the namespace, you can probably guess this for a computer lab, which.
namespace LabAssist.Server.Common.Objects {
using Atlantis.Net.Sockets;
using LabAssist.Server.Common.Data;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Windows.Forms;
public class TcpServer {
#region Constructor(s)
public TcpServer(IPEndPoint endPoint) {
RemoteEndPoint = endPoint;
Host = new Socket(RemoteEndPoint.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
public TcpServer(String hostNameOrIpAddress, Int32 port) {
RemoteEndPoint = new IPEndPoint(Dns.GetHostEntry(hostNameOrIpAddress).AddressList[0], port);
Host = new Socket(RemoteEndPoint.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
public TcpServer(Int32 port) {
RemoteEndPoint = new IPEndPoint(Dns.GetHostEntry(Dns.GetHostName()).AddressList[0], port);
Host = new Socket(RemoteEndPoint.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
#endregion
#region Fields
private Boolean m_IsBound = false;
private List<Socket> m_Connections = new List<Socket>(50);
private static System.Threading.ManualResetEvent AllDone = new System.Threading.ManualResetEvent(false);
#endregion
#region Properties
private Int32 m_Backlog = 32;
public Int32 Backlog {
set {
m_Backlog = value;
}
get {
return m_Backlog;
}
}
private Socket m_Host = null;
public Socket Host {
private set {
m_Host = value;
}
get {
return m_Host;
}
}
private Int32 m_Port = 1337;
public Int32 Port {
set {
m_Port = value;
}
get {
return m_Port;
}
}
private IPEndPoint m_EndPoint = null;
public IPEndPoint RemoteEndPoint {
private set {
m_EndPoint = value;
}
get {
if (m_EndPoint == null) {
RemoteEndPoint = new IPEndPoint(Dns.GetHostEntry(Dns.GetHostName()).AddressList[0], Port);
}
return m_EndPoint;
}
}
#endregion
#region Methods
private void AcceptCallback(IAsyncResult ar) {
Socket client = ((Socket)ar.AsyncState);
Socket handler = client.EndAccept(ar);
m_Connections.Add(handler);
AllDone.Set();
Console.WriteLine("Client accepted.\t Remote address and port : {0}", handler.RemoteEndPoint.ToString());
Byte[] buf = Encoding.ASCII.GetBytes("hello world. This is my first TCP Server >:)");
Int32 ret = 0;
Boolean ext = false;
try {
ret = client.Send(buf, buf.Length, SocketFlags.None);
} catch (Exception ex) {
ext = true;
ConsoleColor c = Console.ForegroundColor;
Console.ForegroundColor = ConsoleColor.Yellow;
Console.WriteLine(ex.ToString());
Console.ForegroundColor = c;
}
if (ret > 0) {
Console.WriteLine("Sent -> {0}", Encoding.ASCII.GetString(buf, 0, buf.Length));
} else {
if (ext) {
ConsoleColor c = Console.ForegroundColor;
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine("Caught an exception");
Console.ForegroundColor = c;
}
Console.WriteLine("Failed to send welcome packet to client.");
}
State state = new State();
state.WorkSocket = handler;
handler.BeginReceive(state.Buffer, 0, State.BufferSize, 0, new AsyncCallback(ReceiveDataCallback), state);
}
public void Initialise() {
Host.Bind(RemoteEndPoint);
Console.WriteLine("Local address and port : {0}", RemoteEndPoint.ToString());
m_IsBound = true;
Host.Listen(Backlog);
try {
while (true) {
AllDone.Reset();
Console.WriteLine("Awaiting{0} client connection...", (m_Connections.Count > 0 ? " another" : ""));
Host.BeginAccept(new AsyncCallback(AcceptCallback), Host);
AllDone.WaitOne();
Application.DoEvents();
}
} catch (Exception e) {
Log.HandledException(e);
}
}
private void ReceiveDataCallback(IAsyncResult ar) {
State state = ((State)ar.AsyncState);
Socket handler = state.WorkSocket;
if (!handler.IsConnected()) {
return;
}
Int32 read = handler.EndReceive(ar);
if (read > 0) {
state.DataReceived.Append(Encoding.ASCII.GetString(state.Buffer, 0, read));
handler.BeginReceive(state.Buffer, 0, State.BufferSize, SocketFlags.None, new AsyncCallback(ReceiveDataCallback), state);
} else {
if (state.DataReceived.Length > 1) {
String content = state.DataReceived.ToString();
Console.WriteLine("Read {0} bytes from socket.\n Data: {1}", content.Length, content);
}
handler.Close();
}
}
#endregion
}
}
, , , - " !". - . - "" ( ) MSDN. MSDN ( ), , , !: (
System.Net.Sockets.SocketException: A request to send or receive data was disall owed because the socket is not connected and (when sending on a datagram socket using a sendto call) no address was supplied
at System.Net.Sockets.Socket.Send(Byte[] buffer, Int32 offset, Int32 size, SocketFlags socketFlags)
at System.Net.Sockets.Socket.Send(Byte[] buffer, Int32 size, SocketFlags socketFlags)
at LabAssist.Server.Common.Objects.TcpServer.AcceptCallback(IAsyncResult ar) in F:\Source\ACCL\Lab Suite\Code\LabAssist.Server\Common\Objects\TcpServer.cs:li
ne 119