Programming Forums > Application Development > C#

Kilo · Mar 31st, 2008, 6:08 PM

I'm working a a chat application for me and my girlfriend. Mu ultimate goal to is construct one class to utilize in both the client and server apps. The trouble I'm running into is being able to return recieved data back to the app from the class and post it in the text box. Below I will post the class constructor and a few linked methods it uses.

(Toggle Plain Text)

        public xsocket(int port, int maxCon, bool isServer)
        {
            i_Port = port;

            if (isServer)
            {
                i_maxConnections = maxCon;

                tcp_listener = new TcpListener(i_Port);
                tcp_listener.Start();
                s_serverIP = tcp_listener.LocalEndpoint.ToString();

                thd_tcp = new Thread(new ThreadStart(ListenLoop));
                hash_threads.Add(i_connectID, thd_tcp);
                thd_tcp.Start();
            }
            else
            {
                sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            }
        }

        public void ListenLoop()
        {
            while (b_waitForClients)
            {
                sock_newClient = tcp_listener.AcceptSocket();

                if (hash_sockets.Count <= i_maxConnections)
                {
                    while (hash_sockets.Contains(i_connectID))
                    {
                        Interlocked.Increment(ref i_connectID);
                    }

                    thd_dataReader = new Thread(new ThreadStart(DataReader));

                    hash_sockets.Add(i_connectID, sock_newClient);
                    hash_threads.Add(i_connectID, thd_dataReader);

                    thd_dataReader.Start();
                }
            }
        }

        public void DataReader()
        {
            if (b_isServer)
            {
                i_userID = i_connectID;
                sock_dataRet = (Socket)hash_sockets[i_userID];

                while (true)
                {
                    if (sock_dataRet.Connected)
                    {
                        Byte[] b_newData = new Byte[1024];
                        try
                        {
                            int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0);

                            if (retrievedData > 0)
                            {
                                string s_temp;
                                s_temp = Encoding.ASCII.GetString(b_newData);
                            }
                        }
                        catch
                        {
                            if (b_isServer)
                                RemoveClient(i_userID);
                        }
                    }
                }
            }
            else
            {
                Byte[] b_dataRet = new Byte[1024];
                string tempData;

                try
                {
                    int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0);

                    if (ret > 0)
                    {
                        // find a way to return the data
                        tempData = Encoding.ASCII.GetString(b_dataRet);
                    }
                }
                catch
                {
                    // connection lost??? return error
                }
            }
        }

        public xsocket(int port, int maxCon, bool isServer)
        {
            i_Port = port;

            if (isServer)
            {
                i_maxConnections = maxCon;

                tcp_listener = new TcpListener(i_Port);
                tcp_listener.Start();
                s_serverIP = tcp_listener.LocalEndpoint.ToString();

                thd_tcp = new Thread(new ThreadStart(ListenLoop));
                hash_threads.Add(i_connectID, thd_tcp);
                thd_tcp.Start();
            }
            else
            {
                sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            }
        }

        public void ListenLoop()
        {
            while (b_waitForClients)
            {
                sock_newClient = tcp_listener.AcceptSocket();

                if (hash_sockets.Count <= i_maxConnections)
                {
                    while (hash_sockets.Contains(i_connectID))
                    {
                        Interlocked.Increment(ref i_connectID);
                    }

                    thd_dataReader = new Thread(new ThreadStart(DataReader));

                    hash_sockets.Add(i_connectID, sock_newClient);
                    hash_threads.Add(i_connectID, thd_dataReader);

                    thd_dataReader.Start();
                }
            }
        }

        public void DataReader()
        {
            if (b_isServer)
            {
                i_userID = i_connectID;
                sock_dataRet = (Socket)hash_sockets[i_userID];

                while (true)
                {
                    if (sock_dataRet.Connected)
                    {
                        Byte[] b_newData = new Byte[1024];
                        try
                        {
                            int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0);

                            if (retrievedData > 0)
                            {
                                string s_temp;
                                s_temp = Encoding.ASCII.GetString(b_newData);
                            }
                        }
                        catch
                        {
                            if (b_isServer)
                                RemoveClient(i_userID);
                        }
                    }
                }
            }
            else
            {
                Byte[] b_dataRet = new Byte[1024];
                string tempData;

                try
                {
                    int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0);

                    if (ret > 0)
                    {
                        // find a way to return the data
                        tempData = Encoding.ASCII.GetString(b_dataRet);
                    }
                }
                catch
                {
                    // connection lost??? return error
                }
            }
        }

If you need anymore code let me know... I didn't want to spam it. Thanks!

kruptof · Apr 1st, 2008, 7:12 AM

Why not just have an attribute and set that to the data returned.And have a getter method for that? Then in your main app you can just assign the texboes Text attribute to this value.

(Toggle Plain Text)

class Sock
{
private String data = "";;

public getData()
{
 return data;
}
...
}

and in your main app do:

(Toggle Plain Text)

Sock s = new Sock();
TextBox.Text = s.getData()

Kilo · Apr 1st, 2008, 11:54 AM

Yea I thought that would have been a good quick fix too... but the main issue I'm running into is that this is a chat app and I'm not sure when the user will be sending data.... So i need to be able to detect from the application that the socket class has recieved new data. I believe this is a good time to implement some sort of event... but I have never made one..only utilized them.

thanks

kruptof · Apr 2nd, 2008, 4:32 AM

Have an attribute in your class which is a delegate, (I think delegates work like function pointers, look it up) and when you receive data invoke the delegate. You need to set the delegate before the data receiver method is invoked, probably in the constructor.

Kilo · Apr 6th, 2008, 3:36 PM

Thanks for your help so far man... much appreciated.

I ended up passing a ref to the textbox through the contructor. When data is recieved a function is called to update the ref to the textbox. I have now encountered a new problem. I can only send 1 msg from the client to the server. None from the client and no more than 1 from the server. I think The DataReader function is only being called the first time date arrives... what about the second time? Believe I'm posting the entire class. Is there something I need to do to link the DataReader function to an event handler for the socket.

EDIT: I noticed my code for the client sending is commented out. So i guess the only issue is the DataReader problem.

 C# Syntax (Toggle Plain Text) 
using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Collections;
using System.Threading;
using System.Windows.Forms;
 
namespace Kraken
{
    public class xsocket
    {
        public string s_serverIP = null;
 
        //public delegate void del_DataHandler(string dataPost);
 
        //public event del_DataHandler DataPost;
 
        private Socket sock_newClient, sock_dataRet, sock_dataSend, sock_client;
 
        private int i_connectID = 0, i_userID = 0, i_maxConnections = 100, i_Port;
 
        private bool b_waitForClients = true, b_isServer;
 
        private TcpListener tcp_listener;
        private Hashtable hash_sockets = new Hashtable();
        private Hashtable hash_threads = new Hashtable();
 
        private Thread thd_tcp, thd_dataReader;
 
        private TextBox tb_chatBox;
        //server,client
        public xsocket(int port, int maxCon, ref TextBox tb_tempChatBox, bool isServer)
        {
            i_Port = port;
            tb_chatBox = tb_tempChatBox;
            b_isServer = isServer;
 
            if (b_isServer)
            {
                i_maxConnections = maxCon;
 
                tcp_listener = new TcpListener(i_Port);
                tcp_listener.Start();
                s_serverIP = tcp_listener.LocalEndpoint.ToString();
 
                thd_tcp = new Thread(new ThreadStart(ListenLoop));
                thd_tcp.Start();
            }
            else
            {
                sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            }
        }
        //server,client
        ~xsocket()
        {
            if(b_isServer)
                tcp_listener.Stop();
            if (thd_dataReader.IsAlive)
                thd_dataReader.Abort();
            if (thd_tcp.IsAlive)
                thd_tcp.Abort();
 
            sock_newClient.Close();
            sock_dataRet.Close();
            sock_dataSend.Close();
            sock_client.Close();
        }
        //client,server
        protected void OnDataPost(string dataPost)
        {
            tb_chatBox.Text += dataPost + System.Environment.NewLine;
        }
        //client
        public string ClientConnect(string servIP, string nickName)
        {
            IPAddress ip_servAddy = IPAddress.Parse(servIP);
            IPEndPoint ep_ip = new IPEndPoint(ip_servAddy, i_Port);
 
            try
            {
                sock_client.Connect(ep_ip);
 
                if (sock_client.Connected)
                {
                    // add nickname sending
                    thd_dataReader = new Thread(new ThreadStart(DataReader));
                    thd_dataReader.Start();
 
                    return "Connected to Kraken server.";
                }
                else
                    return "Failed to connect.";
            }
            catch(Exception ex)
            {
                return ex.Message;
            }
        }
        //server
        public void ListenLoop()
        {
            while (b_waitForClients)
            {
                sock_newClient = tcp_listener.AcceptSocket();
 
                if (hash_sockets.Count <= i_maxConnections)
                {
                    while (hash_sockets.Contains(i_connectID))
                    {
                        Interlocked.Increment(ref i_connectID);
                    }
 
                    thd_dataReader = new Thread(new ThreadStart(DataReader));
 
                    hash_sockets.Add(i_connectID, sock_newClient);
                    hash_threads.Add(i_connectID, thd_dataReader);
 
                    thd_dataReader.Start();
                }
            }
        }
        //server,client
        public void DataReader()
        {
            if (b_isServer)
            {
                i_userID = i_connectID;
                sock_dataRet = (Socket)hash_sockets[i_userID];
 
                while (true)
                {
                    if (sock_dataRet.Connected)
                    {
                        Byte[] b_newData = new Byte[5000];
                        try
                        {
                            int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0);
 
                            if (retrievedData > 0)
                            {
                                OnDataPost(Encoding.ASCII.GetString(b_newData));
                            }
                        }
                        catch
                        {
                            if (b_isServer)
                                RemoveClient(i_userID);
                        }
                    }
                }
            }
            else
            {
                Byte[] b_dataRet = new Byte[5000];
 
                try
                {
                    int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0);
 
                    if (ret > 0)
                    {
                        OnDataPost(Encoding.ASCII.GetString(b_dataRet));
                    }
                }
                catch
                {
                    // connection lost??? return error
                }
            }
        }
        //server
        public void StopAccepting()
        {
            b_waitForClients = false;
        }
        //server,client
        public void SendData(string tempSendData)
        {
            if (b_isServer)
            {
                foreach (int sock_keys in hash_sockets.Keys)
                {
                    sock_dataSend = (Socket)hash_sockets[sock_keys];
 
                    if (sock_dataSend.Connected)
                    {
                        Byte[] b_sendData = Encoding.ASCII.GetBytes(tempSendData.ToCharArray());
 
                        try
                        {
                            sock_dataSend.Send(b_sendData, b_sendData.Length, 0);
                        }
                        catch
                        {
                            RemoveClient(sock_keys);
                        }
                    }
                }
            }
            else
            {
 
 
                //try
                //{
                //    sock_dataSend.Send(b_sendData, b_sendData.Length, 0);
                //}
                //catch
                //{
                //    RemoveClient(sock_keys);
                //}
            }
        }
        //server
        public void RemoveClient(int client)
        {
            Thread thd_removeClient = (Thread)hash_threads[client];
            hash_sockets.Remove(client);
            hash_threads.Remove(client);
            if (thd_removeClient.IsAlive)
                thd_removeClient.Abort();
        }
        //client
        public bool IsClientConnected()
        {
            return (sock_client.Connected);
        }
    }
}
using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Collections;
using System.Threading;
using System.Windows.Forms;

namespace Kraken
{
    public class xsocket
    {
        public string s_serverIP = null;
        
        //public delegate void del_DataHandler(string dataPost);

        //public event del_DataHandler DataPost;

        private Socket sock_newClient, sock_dataRet, sock_dataSend, sock_client;
        
        private int i_connectID = 0, i_userID = 0, i_maxConnections = 100, i_Port;

        private bool b_waitForClients = true, b_isServer;

        private TcpListener tcp_listener;
        private Hashtable hash_sockets = new Hashtable();
        private Hashtable hash_threads = new Hashtable();

        private Thread thd_tcp, thd_dataReader;

        private TextBox tb_chatBox;
        //server,client
        public xsocket(int port, int maxCon, ref TextBox tb_tempChatBox, bool isServer)
        {
            i_Port = port;
            tb_chatBox = tb_tempChatBox;
            b_isServer = isServer;

            if (b_isServer)
            {
                i_maxConnections = maxCon;

                tcp_listener = new TcpListener(i_Port);
                tcp_listener.Start();
                s_serverIP = tcp_listener.LocalEndpoint.ToString();

                thd_tcp = new Thread(new ThreadStart(ListenLoop));
                thd_tcp.Start();
            }
            else
            {
                sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            }
        }
        //server,client
        ~xsocket()
        {
            if(b_isServer)
                tcp_listener.Stop();
            if (thd_dataReader.IsAlive)
                thd_dataReader.Abort();
            if (thd_tcp.IsAlive)
                thd_tcp.Abort();

            sock_newClient.Close();
            sock_dataRet.Close();
            sock_dataSend.Close();
            sock_client.Close();
        }
        //client,server
        protected void OnDataPost(string dataPost)
        {
            tb_chatBox.Text += dataPost + System.Environment.NewLine;
        }
        //client
        public string ClientConnect(string servIP, string nickName)
        {
            IPAddress ip_servAddy = IPAddress.Parse(servIP);
            IPEndPoint ep_ip = new IPEndPoint(ip_servAddy, i_Port);

            try
            {
                sock_client.Connect(ep_ip);

                if (sock_client.Connected)
                {
                    // add nickname sending
                    thd_dataReader = new Thread(new ThreadStart(DataReader));
                    thd_dataReader.Start();
                    
                    return "Connected to Kraken server.";
                }
                else
                    return "Failed to connect.";
            }
            catch(Exception ex)
            {
                return ex.Message;
            }
        }
        //server
        public void ListenLoop()
        {
            while (b_waitForClients)
            {
                sock_newClient = tcp_listener.AcceptSocket();

                if (hash_sockets.Count <= i_maxConnections)
                {
                    while (hash_sockets.Contains(i_connectID))
                    {
                        Interlocked.Increment(ref i_connectID);
                    }

                    thd_dataReader = new Thread(new ThreadStart(DataReader));

                    hash_sockets.Add(i_connectID, sock_newClient);
                    hash_threads.Add(i_connectID, thd_dataReader);

                    thd_dataReader.Start();
                }
            }
        }
        //server,client
        public void DataReader()
        {
            if (b_isServer)
            {
                i_userID = i_connectID;
                sock_dataRet = (Socket)hash_sockets[i_userID];

                while (true)
                {
                    if (sock_dataRet.Connected)
                    {
                        Byte[] b_newData = new Byte[5000];
                        try
                        {
                            int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0);

                            if (retrievedData > 0)
                            {
                                OnDataPost(Encoding.ASCII.GetString(b_newData));
                            }
                        }
                        catch
                        {
                            if (b_isServer)
                                RemoveClient(i_userID);
                        }
                    }
                }
            }
            else
            {
                Byte[] b_dataRet = new Byte[5000];

                try
                {
                    int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0);

                    if (ret > 0)
                    {
                        OnDataPost(Encoding.ASCII.GetString(b_dataRet));
                    }
                }
                catch
                {
                    // connection lost??? return error
                }
            }
        }
        //server
        public void StopAccepting()
        {
            b_waitForClients = false;
        }
        //server,client
        public void SendData(string tempSendData)
        {
            if (b_isServer)
            {
                foreach (int sock_keys in hash_sockets.Keys)
                {
                    sock_dataSend = (Socket)hash_sockets[sock_keys];

                    if (sock_dataSend.Connected)
                    {
                        Byte[] b_sendData = Encoding.ASCII.GetBytes(tempSendData.ToCharArray());

                        try
                        {
                            sock_dataSend.Send(b_sendData, b_sendData.Length, 0);
                        }
                        catch
                        {
                            RemoveClient(sock_keys);
                        }
                    }
                }
            }
            else
            {


                //try
                //{
                //    sock_dataSend.Send(b_sendData, b_sendData.Length, 0);
                //}
                //catch
                //{
                //    RemoveClient(sock_keys);
                //}
            }
        }
        //server
        public void RemoveClient(int client)
        {
            Thread thd_removeClient = (Thread)hash_threads[client];
            hash_sockets.Remove(client);
            hash_threads.Remove(client);
            if (thd_removeClient.IsAlive)
                thd_removeClient.Abort();
        }
        //client
        public bool IsClientConnected()
        {
            return (sock_client.Connected);
        }
    }
}

Jabo · Apr 6th, 2008, 6:57 PM

This may help, I made a prog that pings various servers and emails results to me. I have to destroy each instance of ping and I think smtp message too before I can send another.

Kilo · Apr 8th, 2008, 4:55 PM

Hehe... I realized that it was looping the data reader... I accomplished that by throwing the code in a while loop and throwing it on it's own thread. The problem where a few simple corrections within the send and recieve functions.

Thanks for the help!

Mar 31st, 2008, 6:08 PM	#1
Kilo Expert Programmer Join Date: Nov 2005 Location: In Pink Clam? Posts: 542 Rep Power: 0	Returning data from a class I'm working a a chat application for me and my girlfriend. Mu ultimate goal to is construct one class to utilize in both the client and server apps. The trouble I'm running into is being able to return recieved data back to the app from the class and post it in the text box. Below I will post the class constructor and a few linked methods it uses. (Toggle Plain Text) public xsocket(int port, int maxCon, bool isServer) { i_Port = port; if (isServer) { i_maxConnections = maxCon; tcp_listener = new TcpListener(i_Port); tcp_listener.Start(); s_serverIP = tcp_listener.LocalEndpoint.ToString(); thd_tcp = new Thread(new ThreadStart(ListenLoop)); hash_threads.Add(i_connectID, thd_tcp); thd_tcp.Start(); } else { sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); } } public void ListenLoop() { while (b_waitForClients) { sock_newClient = tcp_listener.AcceptSocket(); if (hash_sockets.Count <= i_maxConnections) { while (hash_sockets.Contains(i_connectID)) { Interlocked.Increment(ref i_connectID); } thd_dataReader = new Thread(new ThreadStart(DataReader)); hash_sockets.Add(i_connectID, sock_newClient); hash_threads.Add(i_connectID, thd_dataReader); thd_dataReader.Start(); } } } public void DataReader() { if (b_isServer) { i_userID = i_connectID; sock_dataRet = (Socket)hash_sockets[i_userID]; while (true) { if (sock_dataRet.Connected) { Byte[] b_newData = new Byte[1024]; try { int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0); if (retrievedData > 0) { string s_temp; s_temp = Encoding.ASCII.GetString(b_newData); } } catch { if (b_isServer) RemoveClient(i_userID); } } } } else { Byte[] b_dataRet = new Byte[1024]; string tempData; try { int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0); if (ret > 0) { // find a way to return the data tempData = Encoding.ASCII.GetString(b_dataRet); } } catch { // connection lost??? return error } } } public xsocket(int port, int maxCon, bool isServer) { i_Port = port; if (isServer) { i_maxConnections = maxCon; tcp_listener = new TcpListener(i_Port); tcp_listener.Start(); s_serverIP = tcp_listener.LocalEndpoint.ToString(); thd_tcp = new Thread(new ThreadStart(ListenLoop)); hash_threads.Add(i_connectID, thd_tcp); thd_tcp.Start(); } else { sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); } } public void ListenLoop() { while (b_waitForClients) { sock_newClient = tcp_listener.AcceptSocket(); if (hash_sockets.Count <= i_maxConnections) { while (hash_sockets.Contains(i_connectID)) { Interlocked.Increment(ref i_connectID); } thd_dataReader = new Thread(new ThreadStart(DataReader)); hash_sockets.Add(i_connectID, sock_newClient); hash_threads.Add(i_connectID, thd_dataReader); thd_dataReader.Start(); } } } public void DataReader() { if (b_isServer) { i_userID = i_connectID; sock_dataRet = (Socket)hash_sockets[i_userID]; while (true) { if (sock_dataRet.Connected) { Byte[] b_newData = new Byte[1024]; try { int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0); if (retrievedData > 0) { string s_temp; s_temp = Encoding.ASCII.GetString(b_newData); } } catch { if (b_isServer) RemoveClient(i_userID); } } } } else { Byte[] b_dataRet = new Byte[1024]; string tempData; try { int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0); if (ret > 0) { // find a way to return the data tempData = Encoding.ASCII.GetString(b_dataRet); } } catch { // connection lost??? return error } } } If you need anymore code let me know... I didn't want to spam it. Thanks! __________________ "When in Rome, Do as the Romans Do" "Beauty is in the eye of the BEER holder" "Save your breath your going to need it for your blow up doll later" SearchLores.org

Apr 1st, 2008, 11:54 AM	#3
Kilo Expert Programmer Join Date: Nov 2005 Location: In Pink Clam? Posts: 542 Rep Power: 0	Re: Returning data from a class Yea I thought that would have been a good quick fix too... but the main issue I'm running into is that this is a chat app and I'm not sure when the user will be sending data.... So i need to be able to detect from the application that the socket class has recieved new data. I believe this is a good time to implement some sort of event... but I have never made one..only utilized them. thanks __________________ "When in Rome, Do as the Romans Do" "Beauty is in the eye of the BEER holder" "Save your breath your going to need it for your blow up doll later" SearchLores.org

Apr 6th, 2008, 3:36 PM	#5
Kilo Expert Programmer Join Date: Nov 2005 Location: In Pink Clam? Posts: 542 Rep Power: 0	Re: Returning data from a class Thanks for your help so far man... much appreciated. I ended up passing a ref to the textbox through the contructor. When data is recieved a function is called to update the ref to the textbox. I have now encountered a new problem. I can only send 1 msg from the client to the server. None from the client and no more than 1 from the server. I think The DataReader function is only being called the first time date arrives... what about the second time? Believe I'm posting the entire class. Is there something I need to do to link the DataReader function to an event handler for the socket. EDIT: I noticed my code for the client sending is commented out. So i guess the only issue is the DataReader problem. C# Syntax (Toggle Plain Text) using System; using System.Collections.Generic; using System.Text; using System.Net; using System.Net.Sockets; using System.Collections; using System.Threading; using System.Windows.Forms; namespace Kraken { public class xsocket { public string s_serverIP = null; //public delegate void del_DataHandler(string dataPost); //public event del_DataHandler DataPost; private Socket sock_newClient, sock_dataRet, sock_dataSend, sock_client; private int i_connectID = 0, i_userID = 0, i_maxConnections = 100, i_Port; private bool b_waitForClients = true, b_isServer; private TcpListener tcp_listener; private Hashtable hash_sockets = new Hashtable(); private Hashtable hash_threads = new Hashtable(); private Thread thd_tcp, thd_dataReader; private TextBox tb_chatBox; //server,client public xsocket(int port, int maxCon, ref TextBox tb_tempChatBox, bool isServer) { i_Port = port; tb_chatBox = tb_tempChatBox; b_isServer = isServer; if (b_isServer) { i_maxConnections = maxCon; tcp_listener = new TcpListener(i_Port); tcp_listener.Start(); s_serverIP = tcp_listener.LocalEndpoint.ToString(); thd_tcp = new Thread(new ThreadStart(ListenLoop)); thd_tcp.Start(); } else { sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); } } //server,client ~xsocket() { if(b_isServer) tcp_listener.Stop(); if (thd_dataReader.IsAlive) thd_dataReader.Abort(); if (thd_tcp.IsAlive) thd_tcp.Abort(); sock_newClient.Close(); sock_dataRet.Close(); sock_dataSend.Close(); sock_client.Close(); } //client,server protected void OnDataPost(string dataPost) { tb_chatBox.Text += dataPost + System.Environment.NewLine; } //client public string ClientConnect(string servIP, string nickName) { IPAddress ip_servAddy = IPAddress.Parse(servIP); IPEndPoint ep_ip = new IPEndPoint(ip_servAddy, i_Port); try { sock_client.Connect(ep_ip); if (sock_client.Connected) { // add nickname sending thd_dataReader = new Thread(new ThreadStart(DataReader)); thd_dataReader.Start(); return "Connected to Kraken server."; } else return "Failed to connect."; } catch(Exception ex) { return ex.Message; } } //server public void ListenLoop() { while (b_waitForClients) { sock_newClient = tcp_listener.AcceptSocket(); if (hash_sockets.Count <= i_maxConnections) { while (hash_sockets.Contains(i_connectID)) { Interlocked.Increment(ref i_connectID); } thd_dataReader = new Thread(new ThreadStart(DataReader)); hash_sockets.Add(i_connectID, sock_newClient); hash_threads.Add(i_connectID, thd_dataReader); thd_dataReader.Start(); } } } //server,client public void DataReader() { if (b_isServer) { i_userID = i_connectID; sock_dataRet = (Socket)hash_sockets[i_userID]; while (true) { if (sock_dataRet.Connected) { Byte[] b_newData = new Byte[5000]; try { int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0); if (retrievedData > 0) { OnDataPost(Encoding.ASCII.GetString(b_newData)); } } catch { if (b_isServer) RemoveClient(i_userID); } } } } else { Byte[] b_dataRet = new Byte[5000]; try { int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0); if (ret > 0) { OnDataPost(Encoding.ASCII.GetString(b_dataRet)); } } catch { // connection lost??? return error } } } //server public void StopAccepting() { b_waitForClients = false; } //server,client public void SendData(string tempSendData) { if (b_isServer) { foreach (int sock_keys in hash_sockets.Keys) { sock_dataSend = (Socket)hash_sockets[sock_keys]; if (sock_dataSend.Connected) { Byte[] b_sendData = Encoding.ASCII.GetBytes(tempSendData.ToCharArray()); try { sock_dataSend.Send(b_sendData, b_sendData.Length, 0); } catch { RemoveClient(sock_keys); } } } } else { //try //{ // sock_dataSend.Send(b_sendData, b_sendData.Length, 0); //} //catch //{ // RemoveClient(sock_keys); //} } } //server public void RemoveClient(int client) { Thread thd_removeClient = (Thread)hash_threads[client]; hash_sockets.Remove(client); hash_threads.Remove(client); if (thd_removeClient.IsAlive) thd_removeClient.Abort(); } //client public bool IsClientConnected() { return (sock_client.Connected); } } } using System; using System.Collections.Generic; using System.Text; using System.Net; using System.Net.Sockets; using System.Collections; using System.Threading; using System.Windows.Forms; namespace Kraken { public class xsocket { public string s_serverIP = null; //public delegate void del_DataHandler(string dataPost); //public event del_DataHandler DataPost; private Socket sock_newClient, sock_dataRet, sock_dataSend, sock_client; private int i_connectID = 0, i_userID = 0, i_maxConnections = 100, i_Port; private bool b_waitForClients = true, b_isServer; private TcpListener tcp_listener; private Hashtable hash_sockets = new Hashtable(); private Hashtable hash_threads = new Hashtable(); private Thread thd_tcp, thd_dataReader; private TextBox tb_chatBox; //server,client public xsocket(int port, int maxCon, ref TextBox tb_tempChatBox, bool isServer) { i_Port = port; tb_chatBox = tb_tempChatBox; b_isServer = isServer; if (b_isServer) { i_maxConnections = maxCon; tcp_listener = new TcpListener(i_Port); tcp_listener.Start(); s_serverIP = tcp_listener.LocalEndpoint.ToString(); thd_tcp = new Thread(new ThreadStart(ListenLoop)); thd_tcp.Start(); } else { sock_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); } } //server,client ~xsocket() { if(b_isServer) tcp_listener.Stop(); if (thd_dataReader.IsAlive) thd_dataReader.Abort(); if (thd_tcp.IsAlive) thd_tcp.Abort(); sock_newClient.Close(); sock_dataRet.Close(); sock_dataSend.Close(); sock_client.Close(); } //client,server protected void OnDataPost(string dataPost) { tb_chatBox.Text += dataPost + System.Environment.NewLine; } //client public string ClientConnect(string servIP, string nickName) { IPAddress ip_servAddy = IPAddress.Parse(servIP); IPEndPoint ep_ip = new IPEndPoint(ip_servAddy, i_Port); try { sock_client.Connect(ep_ip); if (sock_client.Connected) { // add nickname sending thd_dataReader = new Thread(new ThreadStart(DataReader)); thd_dataReader.Start(); return "Connected to Kraken server."; } else return "Failed to connect."; } catch(Exception ex) { return ex.Message; } } //server public void ListenLoop() { while (b_waitForClients) { sock_newClient = tcp_listener.AcceptSocket(); if (hash_sockets.Count <= i_maxConnections) { while (hash_sockets.Contains(i_connectID)) { Interlocked.Increment(ref i_connectID); } thd_dataReader = new Thread(new ThreadStart(DataReader)); hash_sockets.Add(i_connectID, sock_newClient); hash_threads.Add(i_connectID, thd_dataReader); thd_dataReader.Start(); } } } //server,client public void DataReader() { if (b_isServer) { i_userID = i_connectID; sock_dataRet = (Socket)hash_sockets[i_userID]; while (true) { if (sock_dataRet.Connected) { Byte[] b_newData = new Byte[5000]; try { int retrievedData = sock_dataRet.Receive(b_newData, b_newData.Length, 0); if (retrievedData > 0) { OnDataPost(Encoding.ASCII.GetString(b_newData)); } } catch { if (b_isServer) RemoveClient(i_userID); } } } } else { Byte[] b_dataRet = new Byte[5000]; try { int ret = sock_client.Receive(b_dataRet, b_dataRet.Length, 0); if (ret > 0) { OnDataPost(Encoding.ASCII.GetString(b_dataRet)); } } catch { // connection lost??? return error } } } //server public void StopAccepting() { b_waitForClients = false; } //server,client public void SendData(string tempSendData) { if (b_isServer) { foreach (int sock_keys in hash_sockets.Keys) { sock_dataSend = (Socket)hash_sockets[sock_keys]; if (sock_dataSend.Connected) { Byte[] b_sendData = Encoding.ASCII.GetBytes(tempSendData.ToCharArray()); try { sock_dataSend.Send(b_sendData, b_sendData.Length, 0); } catch { RemoveClient(sock_keys); } } } } else { //try //{ // sock_dataSend.Send(b_sendData, b_sendData.Length, 0); //} //catch //{ // RemoveClient(sock_keys); //} } } //server public void RemoveClient(int client) { Thread thd_removeClient = (Thread)hash_threads[client]; hash_sockets.Remove(client); hash_threads.Remove(client); if (thd_removeClient.IsAlive) thd_removeClient.Abort(); } //client public bool IsClientConnected() { return (sock_client.Connected); } } } __________________ "When in Rome, Do as the Romans Do" "Beauty is in the eye of the BEER holder" "Save your breath your going to need it for your blow up doll later" SearchLores.org

Apr 6th, 2008, 6:57 PM	#6
Jabo Not a user? Join Date: Sep 2007 Posts: 245 Rep Power: 1	Re: Returning data from a class This may help, I made a prog that pings various servers and emails results to me. I have to destroy each instance of ping and I think smtp message too before I can send another.

Apr 8th, 2008, 4:55 PM	#7
Kilo Expert Programmer Join Date: Nov 2005 Location: In Pink Clam? Posts: 542 Rep Power: 0	Re: Returning data from a class Hehe... I realized that it was looping the data reader... I accomplished that by throwing the code in a while loop and throwing it on it's own thread. The problem where a few simple corrections within the send and recieve functions. Thanks for the help! __________________ "When in Rome, Do as the Romans Do" "Beauty is in the eye of the BEER holder" "Save your breath your going to need it for your blow up doll later" SearchLores.org

Currently Active Users Viewing This Thread: 1 (0 members and 1 guests)

Thread Tools
Show Printable Version Email this Page
Display Modes
Linear Mode Switch to Hybrid Mode Switch to Threaded Mode

Similar Threads
Thread	Thread Starter	Forum	Replies	Last Post
template class	brad sue	C++	1	Mar 25th, 2007 5:46 PM
Class problem	Ithaqua	Visual Basic .NET	4	Dec 5th, 2006 4:30 PM
URL class	Eric the Red	Java	5	Jun 24th, 2006 9:01 PM
Problem with class constructor	paeck	C++	8	Feb 7th, 2006 12:53 PM
Recommended Practice for returning data from function	Arla	C#	1	Aug 16th, 2005 12:21 PM

Programming Forums > Application Development > C#

Returning data from a class