.Net Socket Questions

Question

0.00/5 (No votes)

See more:

.NET3.5

hi
i trying To Creat Server Client Application Using .Net Sockets

With The BeginXXX & EndXXX Or SocketAsyncEventArgs

The Server Only Push The data To Clients

i Used The Socket Class To Create Client & Server But I All Worked Fine But I Have One Problem
the Data Is Confilect When Sending Fast

Ex
When I Send 1000 Message Some Message may Be lost Or Arrived in The Same Time

Thank

Posted 5-Dec-10 15:35pm

nileoflove

Add a Solution

Comments

fjdiewornncalwe 7-Dec-10 21:00pm

Do you need to create this application as an assignment of some sort. If this is for a professional client, then have you considered MSMQ (Message Queuing)?

1 solution

Add a Solution

Add your solution here

Treat my content as plain text, not as HTML

Preview 0

…

Existing Members

Sign in to your account

...or Join us

Download, Vote, Comment, Publish.

Your Email
Password
Forgot your password?

Your Email
This email is in use. Do you need your password?
Optional Password

I have read and agree to the Terms of Service and Privacy Policy
Please subscribe me to the CodeProject newsletters

When answering a question please:

Read the question carefully.
Understand that English isn't everyone's first language so be lenient of bad spelling and grammar.
If a question is poorly phrased then either ask for clarification, ignore it, or edit the question and fix the problem. Insults are not welcome.
Don't tell someone to read the manual. Chances are they have and don't get it. Provide an answer or move on to the next question.

Let's work to help developers, not make them feel stupid.

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

sandipapatel · Answer 1 · 2010-12-05T16:43:00

Server.cs

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

namespace ConsoleApplication1
{
class Server
{
public void Chat(object o)
{
TcpClient srv = (TcpClient)o;
StreamReader read;
StreamWriter write;
String msg;
read = new StreamReader(srv.GetStream());
write = new StreamWriter(srv.GetStream());

while (true)
{

msg = read.ReadLine();
Console.WriteLine("From Client {0}:{1}",Thread.CurrentThread.Name,msg);
write.WriteLine(msg);
write.Flush();
if (msg.Equals("Exit"))
break;
}
Console.WriteLine("Client {0} Disconnected....", Thread.CurrentThread.Name, msg);
read.Close();
write.Close();
srv.Close();
}
}
public class Test
{
static void Main(string[] args)
{
// IPAddress ip = new IPAddress();
TcpListener list = new TcpListener(IPAddress.Loopback, 9999);
int count = 0;
while (true)
{
list.Start();
Console.WriteLine("Server Ready....Waiting for Clients!");
TcpClient srv = list.AcceptTcpClient();
Console.WriteLine("Client {0} connected", ++count);
Server s = new Server();
ParameterizedThreadStart del = new ParameterizedThreadStart(s.Chat);
Thread t = new Thread(del);
t.Name = "" + count;
t.Start(srv);
}
}
}
}

Client.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.IO;
using System.Net;
using System.Net.Sockets;

namespace ConsoleApplication11
{
class Client
{
public static void Main(String[] arg)
{
//IPEndPoint ip = new IPEndPoint(
// IPAddress ip = new IPAddress();
TcpClient cl = new TcpClient("localhost", 9999);
String msg;
StreamReader read;
StreamWriter write;
read = new StreamReader(cl.GetStream());
write = new StreamWriter(cl.GetStream());
while (true)
{
msg = Console.ReadLine();
write.WriteLine(msg);
write.Flush();
msg=read.ReadLine();
Console.WriteLine(msg);
if (msg.Equals("Exit"))
break;
}
read.Close();
write.Close();
cl.Close();
}
}
}