Click here to Skip to main content
15,909,530 members
Home / Discussions / C#
   

C#

 
QuestionUpdating a Form while coping files Pin
ah-a26-Oct-05 21:50
ah-a26-Oct-05 21:50 
AnswerRe: Updating a Form while coping files Pin
mav.northwind27-Oct-05 3:15
mav.northwind27-Oct-05 3:15 
QuestionException on Instantiating TextBox Pin
wasife26-Oct-05 19:58
wasife26-Oct-05 19:58 
AnswerRe: Exception on Instantiating TextBox Pin
MoustafaS26-Oct-05 20:12
MoustafaS26-Oct-05 20:12 
GeneralRe: Exception on Instantiating TextBox Pin
mav.northwind26-Oct-05 20:51
mav.northwind26-Oct-05 20:51 
GeneralRe: Exception on Instantiating TextBox Pin
wasife29-Oct-05 4:26
wasife29-Oct-05 4:26 
GeneralRe: Exception on Instantiating TextBox Pin
mav.northwind29-Oct-05 8:24
mav.northwind29-Oct-05 8:24 
QuestionAsynchronous Sockets Pin
akshayswaroop26-Oct-05 19:44
akshayswaroop26-Oct-05 19:44 
Hi!, I want to exchange multiple messages between my server and client.But the trouble is that no furthur messages are sent after the first exchange.


using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using Microsoft.Samples.Security.SSPI;
using Microsoft.Samples.Security.SSPI.Sample.ClassLibrary.Server;
using Microsoft.Samples.Security.SSPI.Sample.ClassLibrary.Client;

This is my server code

// State object for reading client data asynchronously
public class StateObject
{
// Client socket.
public Socket workSocket = null;
// Size of receive buffer.
public const int BufferSize = 1024;
// Receive buffer.
public byte[] buffer = new byte[BufferSize];
// Received data string.
public StringBuilder sb = new StringBuilder();
}

public class AsynchronousSocketListener
{

// Incoming data from client.
public static string data = null;

// Thread signal.
public static ManualResetEvent allDone = new ManualResetEvent(false);

public AsynchronousSocketListener()
{
}

public static void StartListening()
{
// Data buffer for incoming data.
byte[] bytes = new Byte[1024];

// Establish the local endpoint for the socket.
// The DNS name of the computer
// running the listener is "host.contoso.com".
Console.WriteLine(Dns.GetHostName().ToString());
IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 5000);

// Create a TCP/IP socket.
Socket listener = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp );

// Bind the socket to the local endpoint and listen for incoming connections.
try
{
listener.Bind(localEndPoint);
listener.Listen(100);

while (true)
{
// Set the event to nonsignaled state.
allDone.Reset();


// Start an asynchronous socket to listen for connections.
Console.WriteLine("Waiting for a connection...");
listener.BeginAccept(
new AsyncCallback(AcceptCallback),
listener );

// Wait until a connection is made before continuing.
allDone.WaitOne();
}

}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}

Console.WriteLine("\nPress ENTER to continue...");
Console.Read();

}

public static void AcceptCallback(IAsyncResult ar)
{
// Signal the main thread to continue.
allDone.Set();

// Get the socket that handles the client request.
Socket listener = (Socket) ar.AsyncState;
Socket handler = listener.EndAccept(ar);

// Create the state object.
StateObject state = new StateObject();
state.workSocket = handler;
handler.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReadCallback), state);
}

public static void ReadCallback(IAsyncResult ar)
{
String content = String.Empty;

// Retrieve the state object and the handler socket
// from the asynchronous state object.
StateObject state = (StateObject) ar.AsyncState;
Socket handler = state.workSocket;

// Read data from the client socket.
int bytesRead = handler.EndReceive(ar);

if (bytesRead > 0)
{
// There might be more data, so store the data received so far.
state.sb.Append(Encoding.ASCII.GetString(
state.buffer,0,bytesRead));

// Check for end-of-file tag. If it is not there, read
// more data.
content = state.sb.ToString();
if (content.IndexOf("<eof>") > -1)
{
// All the data has been read from the
// client. Display it on the console.
Console.WriteLine("Read {0} bytes from socket. \n Data : {1}",
content.Length, content );
// Echo the data back to the client.

Send(handler, content);
}
else
{
// Not all data received. Get more.
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReadCallback), state);
}
}
}

private static void Send(Socket handler, String data)
{
// Convert the string data to byte data using ASCII encoding.
StringBuilder appendEof = new StringBuilder();
ServerContext _ServerContext = null;
ServerCredential serverCred =
new ServerCredential(Credential.Package.NTLM);

_ServerContext = new ServerContext(serverCred,Encoding.ASCII.GetBytes(data));
//string eof="<eof>";
appendEof.Append(_ServerContext.Token);
//appendEof.Append(eof);
//byte[] byteData = Encoding.ASCII.GetBytes(appendEof.ToString());


// Begin sending the data to the remote device.
handler.BeginSend(_ServerContext.Token, 0, _ServerContext.Token.Length, 0,
new AsyncCallback(SendCallback), handler);
}

private static void SendCallback(IAsyncResult ar)
{
try
{
// Retrieve the socket from the state object.
Socket handler = (Socket) ar.AsyncState;

// Complete sending the data to the remote device.
int bytesSent = handler.EndSend(ar);
Console.WriteLine("Sent {0} bytes to client.", bytesSent);

//handler.Shutdown(SocketShutdown.Both);
//handler.Close();

}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}


public static int Main(String[] args)
{
StartListening();

return 0;
}
}


This is my client code


using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Text;
using Microsoft.Samples.Security.SSPI;
using Microsoft.Samples.Security.SSPI.Sample.ClassLibrary.Server;
using Microsoft.Samples.Security.SSPI.Sample.ClassLibrary.Client;


// State object for receiving data from remote device.
public class StateObject
{
// Client socket.
public Socket workSocket = null;
// Size of receive buffer.
public const int BufferSize = 256;
// Receive buffer.
public byte[] buffer = new byte[BufferSize];
// Received data string.
public StringBuilder sb = new StringBuilder();
}

public class AsynchronousClient
{
// The port number for the remote device.
private const int port = 5000;

// ManualResetEvent instances signal completion.
private static ManualResetEvent connectDone =
new ManualResetEvent(false);
private static ManualResetEvent sendDone =
new ManualResetEvent(false);
private static ManualResetEvent receiveDone =
new ManualResetEvent(false);
public ClientCredential clientCred;
public ClientContext clientContext;



// The response from the remote device.
private static String response = String.Empty;

private static void StartClient()
{
// Connect to a remote device.
try
{
// Establish the remote endpoint for the socket.
// The name of the
// remote device is "host.contoso.com".
IPHostEntry ipHostInfo = Dns.Resolve("impetus-591");
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint remoteEP = new IPEndPoint(ipAddress, port);

// Create a TCP/IP socket.
Socket client = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);

// Connect to the remote endpoint.
client.BeginConnect( remoteEP,
new AsyncCallback(ConnectCallback), client);
connectDone.WaitOne();

//Assigning NTLM package
ClientCredential clientCred =new ClientCredential(Credential.Package.NTLM);

//Establishing context
ClientContext clientContext =new ClientContext(clientCred, "",ClientContext.ContextAttributeFlags.None);
string tokenString=Encoding.ASCII.GetString(clientContext.Token);

// Send test data to the remote device.
Send(client,"<eof>",tokenString);
sendDone.WaitOne();

// Receive the response from the remote device.
Receive(client);
receiveDone.WaitOne();

// Write the response to the console.
Console.WriteLine("Response received : {0}", response.Length);

/*
// complete the authentication handshake
while (clientContext.ContinueProcessing == true)
{
try
{
clientContext.Initialize(Encoding.ASCII.GetBytes(response));
}
catch(Exception ex)
{
Console.WriteLine("\nException: ",ex.ToString());
}

if (clientContext.Token != null)
{

// send the authenticate request to the server
//Console.WriteLine("\nSending the authentication request now..."+clientContext.Token.Length);
tokenString=Encoding.ASCII.GetString(clientContext.Token);
Send(client,"<eof>",tokenString);
sendDone.WaitOne();

//Recieve the response from the server
//Receive the response from the remote device.
Receive(client);
receiveDone.WaitOne();

/*if(length!=0)
{
Console.WriteLine("The length of server response is "+length);
Byte[] serverToken1=new Byte[length];
Console.WriteLine("Reading the server response now..\n");
serverToken1=binaryReader.ReadBytes(length);
}*/

// }

//}

//Console.WriteLine("\n Authentication Completed ");


// Release the socket.

client.Shutdown(SocketShutdown.Both);
client.Close();

}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}

private static void ConnectCallback(IAsyncResult ar)
{
try
{
// Retrieve the socket from the state object.
Socket client = (Socket) ar.AsyncState;

// Complete the connection.
client.EndConnect(ar);

Console.WriteLine("Socket connected to {0}",
client.RemoteEndPoint.ToString());

// Signal that the connection has been made.
connectDone.Set();
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}

private static void Receive(Socket client)
{
try
{
// Create the state object.
StateObject state = new StateObject();
state.workSocket = client;

// Begin receiving the data from the remote device.
Console.WriteLine("Reading response from server::");
client.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReceiveCallback), state);
}
catch (Exception e)
{

Console.WriteLine("In exception:"+e.StackTrace);
}
}

private static void ReceiveCallback( IAsyncResult ar )
{
try
{
// Retrieve the state object and the client socket
// from the asynchronous state object.
StateObject state = (StateObject) ar.AsyncState;
Socket client = state.workSocket;

// Read data from the remote device.
int bytesRead = client.EndReceive(ar);

if (bytesRead > 0)
{
// There might be more data, so store the data received so far.
state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead));

// Get the rest of the data.
client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,
new AsyncCallback(ReceiveCallback), state);
}
else
{
// All the data has arrived; put it in response.
if (state.sb.Length > 1)
{
response = state.sb.ToString();
}
// Signal that all bytes have been received.
receiveDone.Set();
}
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}

private static void Send(Socket client, String data,String tokenstring)
{

StringBuilder appendEof = new StringBuilder();

appendEof.Append(tokenstring);
appendEof.Append(data);

// Convert the string data to byte data using ASCII encoding.
byte[] byteData = Encoding.ASCII.GetBytes(appendEof.ToString());

// Begin sending the data to the remote device.
client.BeginSend(byteData, 0, byteData.Length, 0,
new AsyncCallback(SendCallback), client);
//client.BeginSend(clientContext.Token, 0, clientContext.Token.Length, 0,
// new AsyncCallback(SendCallback), client);
}

private static void SendCallback(IAsyncResult ar)
{
try
{
// Retrieve the socket from the state object.
Socket client = (Socket) ar.AsyncState;

// Complete sending the data to the remote device.
int bytesSent = client.EndSend(ar);
Console.WriteLine("Sent {0} bytes to server.", bytesSent);

// Signal that all bytes have been sent.
sendDone.Set();
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}

public static int Main(String[] args)
{
StartClient();
return 0;
}
}
QuestionAdding Data and Sorting ListView Pin
MJay26-Oct-05 19:32
MJay26-Oct-05 19:32 
Questionweb design Pin
momoo26-Oct-05 16:36
momoo26-Oct-05 16:36 
AnswerRe: web design Pin
Christian Graus26-Oct-05 16:44
protectorChristian Graus26-Oct-05 16:44 
QuestionPlease help - problem on using FileSystemWatcher Pin
Tigger9926-Oct-05 16:04
Tigger9926-Oct-05 16:04 
AnswerRe: Please help - problem on using FileSystemWatcher Pin
Christian Graus26-Oct-05 16:13
protectorChristian Graus26-Oct-05 16:13 
GeneralRe: Please help - problem on using FileSystemWatcher Pin
Tigger9926-Oct-05 16:16
Tigger9926-Oct-05 16:16 
GeneralRe: Please help - problem on using FileSystemWatcher Pin
Christian Graus26-Oct-05 16:19
protectorChristian Graus26-Oct-05 16:19 
Questionprogram execution Pin
Zjaded26-Oct-05 15:24
Zjaded26-Oct-05 15:24 
AnswerRe: program execution Pin
leppie26-Oct-05 15:28
leppie26-Oct-05 15:28 
AnswerRe: program execution Pin
Christian Graus26-Oct-05 15:51
protectorChristian Graus26-Oct-05 15:51 
Questionsystem.array as parameter Pin
Member 239309226-Oct-05 14:56
Member 239309226-Oct-05 14:56 
AnswerRe: system.array as parameter Pin
leppie26-Oct-05 15:00
leppie26-Oct-05 15:00 
GeneralRe: system.array as parameter Pin
Member 239309226-Oct-05 15:12
Member 239309226-Oct-05 15:12 
AnswerRe: system.array as parameter Pin
leppie26-Oct-05 15:26
leppie26-Oct-05 15:26 
QuestionC# and mysql Pin
vandread126-Oct-05 13:51
vandread126-Oct-05 13:51 
AnswerRe: C# and mysql Pin
Christian Graus26-Oct-05 13:55
protectorChristian Graus26-Oct-05 13:55 
AnswerRe: C# and mysql Pin
Wjousts26-Oct-05 14:50
Wjousts26-Oct-05 14:50 

General General    News News    Suggestion Suggestion    Question Question    Bug Bug    Answer Answer    Joke Joke    Praise Praise    Rant Rant    Admin Admin   

Use Ctrl+Left/Right to switch messages, Ctrl+Up/Down to switch threads, Ctrl+Shift+Left/Right to switch pages.