Saber si un Socket esta vivo C#

[chcma]

Hola buenas tardes foreros !!!

Bueno, la cuestión es la siguiente, tengo una aplicación que recibe conexiones de diferentes equipos, cada vez que hay una nueva conexion, agrego el objeto Socket a una lista.

Hasta aqui OK.

Bien, hora lo que quiero es testear constantemente que esos sockets siguen conectados, ya que no hay ningún Evento en el objeto socket para comprobar esto mismo.

Mi intención es hacer algo similar a:

Código:

foreach(Socket socketTemporal in listaSockets)
{
     if(!socketTemporal.Connected)
            listaSockets.Remove(socketTemporal);
}

Esto sería perfecto, el problema es que si el socket se cierra por lado del cliente, esta propiedad(Socket.Connected) sigue dando como TRUE.

En fin, si alguien puede hecharme un cable, se lo agradecería.

Saludos.

[chcma]

Bueno, ya esta todo resuelto.

He terminado mi clase la cual acepta múltiples sockets, controla si estan conectados o si se han cerrado (Tanto de forma inesperada como de forma voluntaria). Acepta envio de mensajes de forma selectiva y demás.

Si alguien quiere meterse en el mundo de sockets y le interesa el proyecto que me lo diga, que no tengo ningún problema en compartir mi proyecto.

Se basa de dos proyectos Visual Studio. Uno es mi proyecto de Servidor y otro es una pequeña aplicacion windows que muestra el uso de dicha libreria.

Un saludo.

[jose_d]

Hola, yo estoy entrando en este cuento y me interesa mucho el poder hacer lo que hiciste, ya que quiero poder controlar remotamente un cliente enviarle mensajes etc. para esto me imagino que necesito multiples conexiones para poder controlar varios equipos bueno total te agradeceria mucho si me podes contactar y hablamos.

[chcma]

Amigo, por supuesto cualquier cosa en la que te pueda ayudar, encantado lo haré. No soy ningún experto, pero gracias al desarrollo que estoy haciendo he aprendido bastante sobre sockets.

Si solo vas a trabajar de Cliente a Cliente, puedes usar las clases TcpListener y TcpClient. Si lo que quieres es montar un servidor potente... entonces tendrás que trabajar directamente con la clase Socket y con funciones asíncronas.

Exponme tus dudas o si quieres que te pase el código de lo que hice, dime tu eMail y te lo mando sin ningún reparo.

Pd: En las FAQS (Mira en la última - penúltima página) dejé documentación sobre sockets también amigo.

Un saludo.

[jose_d]

Hola gracias por el dato, mira lo que quiero hacer es algo que siempre me ha causado curiosidad no se si conoscas el programa www.Logmein.com que es para acceso remoto y control de un equipo X mediante el protocolo TCP segun lo que he podido observar del proceso. y pues la verdad quiero hacer algo parecido, lo que mas me llama la atencion es que el programa se conecta desde internet sin necesidad de nada mas.

Pero bueno sigo con el proyecto voy a ver como lo logro hacer por el momento pienso que con remouting y con TCP se puede hacer.

[fenryrSulven]

Hola amigo chma estuve buscando precisamente informacion sobre remouting o sockets en C# y encontre tu post donde describes el programa que hiciste y es parecido a lo que deseo implementar.
Lo que voy a implementar es un chat en una LAN y necesito saber de sockets y conecciones remotas a un servidor mas aun me gustaria darle un vistazo a tu codigo y ver como funciona te estaria realmente agradecido si pudieras enviarmelo al correo ' [email protected] '.

Tambien me gustaria hacerte algunas preguntas sobre el tema una vez lo haya estudiado.
Muchas gracias de antemano chao amigo.

[chcma]

Claro que no me importa pasarte el código amigo. Ya te lo he mandado. Está hecho en 3.5 y usa un poco de LinQ.

Sobre el cliente que te mando, me falta implementarlo todavía ya que quiero hacerlo con XAML y estoy estudiandolo todavía. Ahora lo tengo parado por que estoy con unos exámenes.

Te explico un poco el funcionamiento del serivdor:

1-. El cliente se conecta al servidor, y este almacena el socket creado en una Lista.
2-. El cliente envia un mensaje XML al servidor para poder relacionar dicho Socket agregado anteriormente en la lista a una direccion de eMail.
3-. Cuando el cliente envia un mensaje, este se envia en formato XML al servidor, con un TAG en el que se especifica el destinatario (donde va el eMail), el servidor recorre la lista de sockets buscando el que se corresponda con el eMail y envia el mensaje.

[chonex]

Hola chcma, estoy en el mismo caso que el amigo anterior fenryrSulven, por favor enviame esa clase que has desarrollado que se ve muy interesante! mi correo es [email protected] muchas gracias de antemano!

[chcma]

Hola chonex, perdona por no haberte contestado antes, miré el POST en su día y vi tu mensaje pero se me pasó (Gracias por recordarmelo).

Ahora mismo te lo envio.

Un saludo.

[maki2008]

Hola chcma...

me puedes decir como solucionaste el problema de las desconexiones de los sockets?

[chcma]

Si, por supuesto (Asumo que conoces la programación asíncrona):

Código:

//Inicio mi Socket para aceptar conexiones.
objSocketServidor.BeginAccept(new AsyncCallback(ConexionRealizada), null);



//Metodo que captura la llamada Asincrona anterior y generera la ESCUCHA ASINCRONA
        private void ConexionRealizada(IAsyncResult iAr)
        {
            try
            {
                Socket objSocket = objSocketServidor.EndAccept(iAr);
                ClsSocket objCliente = new ClsSocket(objSocket);
                listaSockets.Add(objCliente);

                objSocketServidor.BeginAccept(new AsyncCallback(ConexionRealizada), null);
                objSocket.BeginReceive(bytesDatos, 0, bytesDatos.Length, SocketFlags.None, new AsyncCallback(DatosLlegados), objSocket);

                if (NuevaConexion != null)
                {
                    string ipClienteConectado = ((IPEndPoint)objSocket.RemoteEndPoint).Address.ToString();
                    int puertoClienteConectado = ((IPEndPoint)objSocket.RemoteEndPoint).Port;
                    NuevaConexion(ipClienteConectado, puertoClienteConectado);
                }
            }
            catch (Exception ex)
            {
                if (DatosErrores != null)
                    this.DatosErrores(MethodBase.GetCurrentMethod().Name, ex.Message);
            }
        }





        private void DatosLlegados(IAsyncResult iAr)
        {
            Socket objSocket = (Socket)iAr.AsyncState;
            try
            {
                int tamanioDatosRecibidos = objSocket.EndReceive(iAr);
                if (tamanioDatosRecibidos > 0)
                {
                    byte[] bytesDatosReales = new byte[tamanioDatosRecibidos];
                    Array.Copy(bytesDatos, bytesDatosReales, tamanioDatosRecibidos);
                    string txtDatosReales = Encoding.ASCII.GetString(bytesDatosReales);

                    if (DatosRecibidos != null)
                    {
                        string ipClienteConectado = ((IPEndPoint)objSocket.RemoteEndPoint).Address.ToString();
                        int puertoClienteConectado = ((IPEndPoint)objSocket.RemoteEndPoint).Port;
                        this.DatosRecibidos(objSocket, ipClienteConectado, puertoClienteConectado, txtDatosReales);
                    }

                    objSocket.BeginReceive(bytesDatos, 0, bytesDatos.Length, SocketFlags.None, new AsyncCallback(DatosLlegados), objSocket);
                }
                else
                {
                    EliminarCliente(objSocket);
                }
            }
            catch (SocketException exSocket)
            {
                if (exSocket.SocketErrorCode == SocketError.ConnectionReset)
                    EliminarCliente(objSocket);
                else
                {
                    if (DatosErrores != null)
                        this.DatosErrores(MethodBase.GetCurrentMethod().Name, exSocket.Message);
                }
            }
            catch (Exception ex)
            {
                if (DatosErrores != null)
                    this.DatosErrores(MethodBase.GetCurrentMethod().Name, ex.Message);
            }
        }

Siempre que se envia un dato al socket, se entra por este metodo. Cuando se pierde la conexión, también se entra por este metodo, solo que el tamanio de bytes es 0, entonces es cuando sabes que se ha perdido la conexión, fijate en la condicional

Código:

if (tamanioDatosRecibidos > 0)
{
    //Sigue conectado
}else{
    //Se ha perdido la conexion.
}

[maki2008]

Gracias... por la respuesta.

[fulfaro]

Saludos chcma,

Estoy interesado en tus ejemplos, por que he estado trabajando con Sockets, y tengo un problema cuando hago llamadas desde varios clientes a un mismo servidor, llega un punto que colapsan los socket. He estado investigando lo de los sockets asincronos, el detalle esta que el cliente tambien debe manejar las llamadas asincronas, cosa que me limita cuando tengo un aplicativo cliente en otra plataforma que no sea .Net.

Muchas Gracias de antemano por tu respuesta.

[moffly]

Hola chcma, he leido tu post y estoy interesada en tu codigo sobre sockets en C#, ya que estoy haciendo un proyecto que se basa en que varios clientes simultaneamente, deben poder conectarse a un servidor y he encontrado poca informacion. Si no es mucha molestia me ayudarías mucho si me lo enviases a: [email protected].

Gracias por adelantado!!

[dirc_dirc]

Hola chcma
He leido tu post y tengo los problemas de la programacion de mi socket, porque tengo problemas porque no puedo saber cuando mi servidor se desconecta , mi cliente marca errores inesperados, queria pedirte si podias ayudarme o darme algunos tips de que funciones o comandos puedo incluir para darme cuenta cuando mi servidor se ha caido.
Gracias .

[chcma]

Hola a todos !!!

Perdonar mi demora, pero estuve de vacaciones y bueno... Aqui no tengo el código para mandaros el ejemplo, vais a tener que esperar unos días (10 de Septiembre) a que vuelva a mi lugar de residencia para enviaros el codigo. Si alguien de a quienes se lo he enviado os lo puede mandar os lo agradecería.

Voy a poner aqui el código del servidor y del cliente en cuanto lo tenga para que os sirva. No obstante lo de detectar cuando se ha caido el servidor o el cliente, lo teneis en este link de las faqs: http://www.forosdelweb.com/f29/faq-s...48/index5.html

Las líneas en concreto son:

Código:

        private void DatosLlegados(IAsyncResult iAr)
        {            
            Socket objSocket = (Socket)iAr.AsyncState;
            try
            {
                int tamanioDatosRecibidos = objSocket.EndReceive(iAr);
                if (tamanioDatosRecibidos > 0)
                {
                      //TRATAMOS LOS DATOS RECIBIDOS
                }else{
                      //SE HA CAIDO EL CLIENTE
                }

Cuando un socket se desconecta se envía un valor 0, lo leí en un post de C++ hace tiempo y bueno... con esto me va todo perfectamente, aun que recomiendan por ahí hacer "pings" al servidor, de esta forma como la tengo yo, desconectas el equipo y se detecta que el cliente se ha desconectado... asi que .... creo que uno se puede ahorrar el implementar un keep alive. Que alguien me corriga si discrepa.

Un saludo gente. (Espero haber sido de ayuda, al menos temporalmente)

[bugmenotya]

Muy buenas!!

Yo también estoy interesado en el código, quiero intentar controlar un reproductor de vídeo con el servidor telnet que incorpora :)

mi correo es: bugmenot.ya (a) gmail.com

Muchas gracias!

[jhonwilliams]

Hola, tengo que hacer una aplicación cliente-servidor con sockets, si alguien me hace el favor de enviarme el ejemplo estare enorme mente agradecido. mi correo [email protected]

Gracias

[Farookh_Bulsara]

chcma yo tb estoy con un proyecto, usando sockets,quisiera saber si es q puedes pasarme tu proyecto para q pueda aprender mas sobre sockets,mi mail es:
[email protected]
y tambien seria bueno si es q tienes manuales o tutoriales sobre sockets
tanks

[shoen]

Iniciado por chcma

Bueno, ya esta todo resuelto.

He terminado mi clase la cual acepta múltiples sockets, controla si estan conectados o si se han cerrado (Tanto de forma inesperada como de forma voluntaria). Acepta envio de mensajes de forma selectiva y demás.

Si alguien quiere meterse en el mundo de sockets y le interesa el proyecto que me lo diga, que no tengo ningún problema en compartir mi proyecto.

Se basa de dos proyectos Visual Studio. Uno es mi proyecto de Servidor y otro es una pequeña aplicacion windows que muestra el uso de dicha libreria.

Un saludo.

Hola CHCMA
Queria saber si tu solucion soluciona el siguiente problema y si lo podrias compartir, el problema es el siguiente tengo un conexion tcp entre 2 puntos, resulta que una vez, se me corto el cable fisico que los conectaba, esto es posilbe de saber en cualqueir punto cuando esto sucede?



Muchas Gracias, Shoen

[chcma]

Mi último post lo explica. Un saludo.

[icoba]

hola chcma!

soy nuevo en el foro

quisiera saber como enviar mensajes de forma selectiva usando sockets asincronos, es decir que al seleccionar un cliente conectado le envie solo a el, el mensaje.

gracias

[chcma]

Bueno... yo lo hago de la siguiente manera.

1-. Tengo mi servidor.

2-. Los clientes se conectan al servidor, y mandan un mensaje para registrarse, por ejemplo en XML (Si no mandan este mensaje, el socket estará conectado, pero LA APLICACIÓN no sabrá como identificar un socket de otro.

2.1-. Al mandar el mensaje, asocio, por ejemplo, en una hashtable, el nombre del usuario, junto con su socket. Asi, cuando queira mandar algo, mando el nombre del usuario y el msanje a un método, este método recorrerá el hashtable, hasta encontrar el nombre de usuairo y entonces usará ese socket para mandar el mensaje.

¿Me expliqué?


Te muestro un pequeño ejemplo de mi código, en este caso, en vez de usar un hashtable, use una List<T> con una clase mia.

Código:

        //El txtEmail, es lo que uso para recoger el socket específico de entre todos los que están conectados a mi servidor.
        public void EnviarDatosCliente(string txtEmail, string txtMensaje)
        {
            ClsSocket objCliente = (from cliente in listaSockets where cliente.DireccionEmail == txtEmail select cliente).First<ClsSocket>();

            byte[] bytesMensaje = Encoding.UTF8.GetBytes(txtMensaje);
            EnviarDatos(objCliente.ObjSocket, bytesMensaje);
        }
        private void EnviarDatos(Socket objSocket, byte[] bytesMensaje)
        {
            objSocket.BeginSend(bytesMensaje, 0, bytesMensaje.Length, SocketFlags.None, new AsyncCallback(DatosEnviadosAr), new Object[] { objSocket, bytesMensaje });
        }

[icoba]

muchas gracias chcma!
tengo una duda. Como almacenas el usuario y su socket correspondiente en tu List<T>?, porque yo tengo algo parecido, solo que manejo una estructura con la informacion del cliente.
Aqui te muestro mi codigo del server:

namespace Server
{
enum Command
{
Login,
Logout,
Message,
List,
Null
}

public partial class SGSserverForm : Form
{
struct ClientInfo
{
public Socket socket;
public string strName;
public string strHostname;
}

ArrayList clientList;
public string strHostName = Dns.GetHostName();

Socket serverSocket;

byte[] byteData = new byte[1024];

public SGSserverForm()
{
clientList = new ArrayList();
InitializeComponent();
}

private void Form1_Load(object sender, EventArgs e)
{

try

{
serverSocket = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);

IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Any, 1000);

serverSocket.Bind(ipEndPoint);
serverSocket.Listen(10);

serverSocket.BeginAccept(new AsyncCallback(OnAccept), null);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "server",MessageBoxButtons.OK, MessageBoxIcon.Error);
}

}

private void OnAccept(IAsyncResult ar)
{
try
{
Socket clientSocket = serverSocket.EndAccept(ar);

serverSocket.BeginAccept(new AsyncCallback(OnAccept), null);

clientSocket.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None,
new AsyncCallback(OnReceive), clientSocket);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "server",MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}

private void OnReceive(IAsyncResult ar)
{
try
{
Socket clientSocket = (Socket)ar.AsyncState;
clientSocket.EndReceive(ar);

Data msgReceived = new Data(byteData);

Data msgToSend = new Data();

byte [] message;

msgToSend.cmdCommand = msgReceived.cmdCommand;
msgToSend.strName = msgReceived.strName;


switch (msgReceived.cmdCommand)
{

case Command.Login:

ClientInfo clientInfo = new ClientInfo();
clientInfo.socket = clientSocket;
clientInfo.strHostname = msgReceived.strMessage;
clientInfo.strName = msgReceived.strName;

clientList.Add(clientInfo);

msgToSend.strMessage = msgReceived.strName + " conectado";
msgToSend.strMessage = "<<" + strHostName + " conectado>>";

break;

case Command.Logout:

int nIndex = 0;
foreach (ClientInfo client in clientList)
{
if (client.socket == clientSocket)
{
clientList.RemoveAt(nIndex);
break;
}
++nIndex;
}

clientSocket.Close();

msgToSend.strMessage = msgReceived.strName + " desconectado";
msgToSend.strMessage = "<<" + strHostName + " desconectado>>";
break;

case Command.Message:

msgToSend.strMessage = msgReceived.strName + ": " + msgReceived.strMessage;
break;

case Command.List:

msgToSend.cmdCommand = Command.List;
msgToSend.strName = null;
msgToSend.strMessage = null;

foreach (ClientInfo client in clientList)
{
msgToSend.strMessage += client.strName + "*";
}

message = msgToSend.ToByte();
clientSocket.BeginSend(message, 0, message.Length, SocketFlags.None,
new AsyncCallback(OnSend), clientSocket);
break;
}

if (msgToSend.cmdCommand != Command.List)
{
message = msgToSend.ToByte();

foreach (ClientInfo clientInfo in clientList)
{
if (clientInfo.socket != clientSocket ||
msgToSend.cmdCommand != Command.Login)
{
clientInfo.socket.BeginSend(message, 0, message.Length, SocketFlags.None,
new AsyncCallback(OnSend), clientInfo.socket);
}
}

TextLogAddText(DateTime.Now.ToString("yyyy/MM/dd") + " " + DateTime.Now.ToString("hh:mm:ss")+ " " + msgToSend.strMessage + "\r\n");

}

if (msgReceived.cmdCommand != Command.Logout)
{
clientSocket.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None, new AsyncCallback(OnReceive), clientSocket);
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "server", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}

private void TextLogAddText(string Text)
{
if (txtLog.InvokeRequired)
{
txtLog.Invoke(new MethodInvoker(delegate { TextLogAddText(Text); }));
return;
}
txtLog.Text += Text;
}

public void OnSend(IAsyncResult ar)
{
try
{
Socket client = (Socket)ar.AsyncState;
client.EndSend(ar);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "server", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}

gracias.

[chcma]

Pues tu List<T> debería ser con los datos de la estructura.

De todas formas... ya lo tienes puesto en tu código, solo que con un ArrayList, sería cambiarlo por una Lista Genérica y listo. Asi podrías usar linQ por si quieres hacer consultas sobre los clientes conectados o lo que sea.

Código:

ClientInfo clientInfo = new ClientInfo();
clientInfo.socket = clientSocket;
clientInfo.strHostname = msgReceived.strMessage;
clientInfo.strName = msgReceived.strName;

clientList.Add(clientInfo);

[icoba]

hola chcma!

muchas gracias por tu respuesta, me fue de gran ayuda. hice algunas modificaciones al servidor, pero la idea de buscar en el arraylist el nombre del socket me fue de mucha utilidad, gracias a eso funciono.

otra vez gracias.

[chcma]

Me alegro.

[websist]

Iniciado por chcma

Me alegro.

Estimado CHCMA estare muy agradecido me envies tu ejemplo. [email protected]

[lys43062]

Hola CHMA, Podrias por favor ayudarme compartiendo tu proyecto? Anexo mi correo [email protected] Gracias y felices fiestas!!

[Halverth]

Hola amigo como estas, yo tambien estoy intentando hacer una aplicacion cliente / servidor que envie mensaje entre ellos y se conecten multiples clientes, podrias ayudarme por favor mi correo es [email protected] Gracias