Server / klient program

klassisk loesning er jo:
  accept connection
  create client handler objekt
  gem client i collection
  start traad for client

Hej Arne,
Kan jeg få dig til at beskrive de steps lidt dybere, evt. med kode henvisning?

jeg lavede noget kode til et andet spoergsmaal engang

ikke nogen speciel god kode, men det boer illustrere teknikken

using System;
using System.Collections;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;

class ChatMain
{
    public static void Main(string[] args)
    {
        Server srv = new Server();
        srv.Run();
    }
}

class Server
{
    private ArrayList allclients;
    public void Run()
    {
        allclients = new ArrayList();
        TcpListener server = new TcpListener(IPAddress.Any, 50000);
        server.Start();
        while(true)
        {
            TcpClient client = server.AcceptTcpClient();
            ClientHandler ch = new ClientHandler(client, this);
            allclients.Add(ch);
            (new Thread(new ThreadStart(ch.Run))).Start();
        }
    }
    public void SendAll(string msg)
    {
        foreach(ClientHandler ch in allclients)
        {
            ch.Send(msg);
        }
    }
    public void Remove(ClientHandler ch)
    {
        allclients.Remove(ch);
    }
}

class ClientHandler
{
    private StreamReader rdr;
    private StreamWriter wrt;
    private Server srv;
    public ClientHandler(TcpClient cli, Server srv)
    {
        rdr = new StreamReader(cli.GetStream());
        wrt = new StreamWriter(cli.GetStream());
        this.srv = srv;
    }
    public void Run()
    {
        while(true)
        {
            string line = rdr.ReadLine();
            string cmd = line.Split(" ".ToCharArray())[0];
            if(cmd == "SEND")
            {
                srv.SendAll(line.Substring(5));
            }
            else if(cmd == "EXIT")
            {
                srv.Remove(this);
                return;
            }
        }
    }
    public void Send(string msg)
    {
        lock(wrt)
        {
            wrt.WriteLine(msg);
            wrt.Flush();
        }
    }
}

using System;
using System.IO;
using System.Net.Sockets;
using System.Threading;

class ChatClient
{
    public static void Main(string[] args)
    {
        TcpClient client = new TcpClient("localhost", 50000);
        StreamWriter wrt = new StreamWriter(client.GetStream());
        (new Thread(new ThreadStart((new Reader(client)).Run))).Start();
        string line;
        while((line = Console.ReadLine()) != null)
        {
            wrt.WriteLine("SEND " + line);
            wrt.Flush();
        }
        wrt.WriteLine("EXIT");
        wrt.Flush();
        wrt.Close();
        client.Close();
    }
}

class Reader
{
    private StreamReader rdr;
    public Reader(TcpClient cli)
    {
        rdr = new StreamReader(cli.GetStream());
    }
    public void Run()
    {
        try
        {
            string line;
            while((line = rdr.ReadLine()) != null)
            {
                Console.WriteLine(line);
            }
        }
        catch(Exception)
        {
            // nothing
        }
    }
}

Hej Arne,
Tak - hvordan kan jeg så snakke med en specifik klient fra serveren af?
Jeg kan se at alle klienterne bliver samlet i en arrayliste, men hvordan går jeg ind og finder feks klienten fra ip 192.168.10.12 ?

Og jeg skal jo sådan set også kunne identificere klienten på serveren hver gang den evt skulle sende noget, så jeg kan håndtere det som data fra denne klient.

enten kan du loebe ArrayListen igennem og finde den rigtige client

eller du kan erstatte den ArrayList med en Hashtable

Smid et eksempel på det, så får du point, hvis jeg får yderligere spørgsmål kan vi evt. snakkes ved - det udløser selvfølgelig flere point.

Tak for det i hvertfald

Et eks på hvordan jeg finder eks 192.168.10.12, og sender en besked, eks HELLO :o)

jeg tilretter eksemplet senere

using System;
using System.Collections;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;

class ChatMain
{
    public static void Main(string[] args)
    {
        Server srv = new Server();
        srv.Run();
    }
}

class Server
{
    private ArrayList allclients;
    public void Run()
    {
        allclients = new ArrayList();
        TcpListener server = new TcpListener(IPAddress.Any, 50000);
        server.Start();
        while(true)
        {
            TcpClient client = server.AcceptTcpClient();
            ClientHandler ch = new ClientHandler(client, this);
            allclients.Add(ch);
            (new Thread(new ThreadStart(ch.Run))).Start();
        }
    }
    public void SendAll(string msg)
    {
        foreach(ClientHandler ch in allclients)
        {
            ch.Send(msg);
        }
    }
    public void SendOne(string msg, string address)
    {
        foreach(ClientHandler ch in allclients)
        {
            if(ch.Remote.IndexOf(address) == 0)
            {
                ch.Send(msg);
            }
        }
    }
    public void Remove(ClientHandler ch)
    {
        allclients.Remove(ch);
    }
}

class ClientHandler
{
    private string remote;
    private StreamReader rdr;
    private StreamWriter wrt;
    private Server srv;
    public ClientHandler(TcpClient cli, Server srv)
    {
        remote = cli.Client.RemoteEndPoint.ToString();
        rdr = new StreamReader(cli.GetStream());
        wrt = new StreamWriter(cli.GetStream());
        this.srv = srv;
    }
    public void Run()
    {
        while(true)
        {
            string line = rdr.ReadLine();
            string[] parts = line.Split(" ".ToCharArray());
            string cmd = parts[0];
            if(cmd == "SEND")
            {
                string address = parts[1];
                if(address == "*")
                {
                    srv.SendAll(line.Substring(cmd.Length + address.Length + 2));
                }
                else
                {
                    srv.SendOne(line.Substring(cmd.Length + address.Length + 2), address);
                }
            }
            else if(cmd == "EXIT")
            {
                srv.Remove(this);
                return;
            }
        }
    }
    public void Send(string msg)
    {
        lock(wrt)
        {
            wrt.WriteLine(msg);
            wrt.Flush();
        }
    }
    public string Remote
    {
        get
        {
            return remote;
        }
    }
}

Hvis man i client skriver:

* Hello

får alle client beskeden.

Hvis man i client skriver:

192.168.10.12 Hello

så er det kun client 192.168.10.12 som får beskeden

P.g.a. den måde jeg tester så vil:

192.168 Hello

gå til alle 192.168.*.*

men det kan du jo selv arbejde videre med

kode kræver .NET 2.0 fordi TcpCLient Client property er protected i .NET 1.1

og client tester ikke på om der er det krævede mellemrum i input

hvis ikke => server crasher

men det kan du jo også forbedre

og et svar

Hej Arne,
Jeg har nu implementeret det og tilpasset det min winform...
Jeg har et problem, når jeg vil lukke min winform hænger den pga:

            while (true)
            {
                TcpClient client = server.AcceptTcpClient();
                ClientHandler ch = new ClientHandler(client, this);
                allclients.Add(ch);
                GetAgents();
                (new Thread(new ThreadStart(ch.Run))).Start();
            }

Har du en idé til hvordan jeg kan undgå at den står der og hænger, og faktisk forhindrer mig i at lukke programmet.

enten skal du have stppet alle traade

ellers prøv:

        Application.Run(new MainForm());
        Application.Exit();
        Environment.Exit(0);

Environment.Exit(0);

Det er bare guldet, tak ;)