问题需求如下：
服务器一台，客户端若干个。
现在就是要实现服务器和客户端之间的通讯，服务器端如何实现和各个客户端之间通过TCP/IP通讯，并把各个客户端发送过来的数据存储到数据库中。
我在实现P2P的点对点通讯中已经实现了，但在1：N的通讯中不知道怎么设计（架构），在这样的通讯过程中是不是要考虑并发问题？另外我的客户端不是PC，是硬件终端，如：ARM，电子称之类的东西。请各位高手出招。谢谢！
服务器一台，客户端若干个。
现在就是要实现服务器和客户端之间的通讯，服务器端如何实现和各个客户端之间通过TCP/IP通讯，并把各个客户端发送过来的数据存储到数据库中。
我在实现P2P的点对点通讯中已经实现了，但在1：N的通讯中不知道怎么设计（架构），在这样的通讯过程中是不是要考虑并发问题？另外我的客户端不是PC，是硬件终端，如：ARM，电子称之类的东西。请各位高手出招。谢谢！
另注：只要发言，大家都有分，不够我再加。呵呵，有现成的例子也可以发送到我信箱里，地址[email protected]，感激不尽，谢谢大家！
using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Collections;
using System.Collections.Generic;
using System.Text;namespace TCPServerDemo
{
class ClientHandler
{
public TcpClient clientSocket; public void RunClient()
{
//Create the stream classes
Console.WriteLine(clientSocket.Client.AddressFamily.ToString());
StreamReader readerStream = new StreamReader(clientSocket.GetStream());
NetworkStream writestream = clientSocket.GetStream(); string returnData = readerStream.ReadLine();
string userName = returnData; Console.WriteLine("Welcome " + userName + " to the Server");
while (true)
{
returnData = readerStream.ReadLine();
if (returnData.IndexOf("QUIT") > -1)
{
Console.WriteLine("Bye Bye " + userName);
break;
} Console.WriteLine(userName + ": " + returnData);
returnData += "\r\n"; byte[] dataWrite = Encoding.ASCII.GetBytes(returnData);
writestream.Write(dataWrite, 0, dataWrite.Length);
}
clientSocket.Close();
}
}
public class EchoServer
{
const int ECHO_PORT = 8080;
public static int nClient = 0; static void Main(string[] args)
{
try
{
//Bind the Server to local port
TcpListener clientListener = new TcpListener(IPAddress.Parse("127.0.0.1"),ECHO_PORT); //start to listen
clientListener.Start(); Console.WriteLine("Waiting for connection..."); while (true)
{
//Accept the connection
TcpClient client = clientListener.AcceptTcpClient();
ClientHandler cHandler = new ClientHandler(); //pass value to the ClientHandler object
cHandler.clientSocket = client;
string ipaddressport = client.Client.RemoteEndPoint.ToString();
Console.WriteLine(ipaddressport.Substring(0, ipaddressport.IndexOf(":")) + "--------------"+ipaddressport.Substring(ipaddressport.IndexOf(":")+1), ipaddressport.Length - ipaddressport.IndexOf(":")-1);
//Create a new thread for the client
Thread clientThread = new Thread(new ThreadStart(cHandler.RunClient));
clientThread.Start();
}
clientListener.Stop();
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
}
}
using System;
using System.Net;
using System.IO;
using System.Net.Sockets;
using System.Text;namespace TCPClientDemo
{
class Program
{
const int ECHO_PORT = 8080;
static void Main(string[] args)
{
Console.Write("Your UserName:");
string userName = Console.ReadLine();
Console.WriteLine("-----Logged in-----"); try
{
//Create a connection with the Chatserver
TcpClient eClient = new TcpClient("127.0.0.1", ECHO_PORT); //Create the stream classes
StreamReader readerStream = new StreamReader(eClient.GetStream());
NetworkStream writeStream = eClient.GetStream(); string dataToSend; dataToSend = userName;
dataToSend += "\r\n"; //Send username to the server
byte[] data = Encoding.ASCII.GetBytes(dataToSend);
writeStream.Write(data, 0, data.Length); while (true)
{
Console.WriteLine(userName + ":");
//Read line from server
dataToSend = Console.ReadLine();
dataToSend += "\r\n";
data = Encoding.ASCII.GetBytes(dataToSend);
writeStream.Write(data, 0, data.Length);
//If QUIT is sent, then quit application
if (dataToSend.IndexOf("QUIT") > -1)
break; string returnData; //Receive response from server
returnData = readerStream.ReadLine();
Console.WriteLine("Server: " + returnData);
} //Close TcpClient
eClient.Close();
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
}
}