如何用.net Remoting实现一个客户端需要连接多个服务器端
1、使用socekt通信一般步骤
1)服务器端:socker()建立套接字,绑定(bind)并监听(listen),用accept()等待客户端连接。
2)客户端:socker()建立套接字,连接(connect)服务器,连接上后使用send()和recv(),在套接字上写读数据,直至数据交换完毕,closesocket()关闭套接字。
3)服务器端:accept()发现有客户端连接,建立一个新的套接字,自身重新开始等待连接。该新产生的套接字使用send()和recv()写读数据,直至数据交换完毕,closesocket()关闭套接字。
2、多个客户端同时连接在一个服务器上
这时候服务器端应该使用多线程,每连接上一个客户端就给该客户端开启一个线程。监听端口的时候也要单独开一个线程、不然会阻塞主线程。这样做有一个明显的缺点,就是有N个客户端请求连接时,就会有N个线程,对程序的性能和计算机的性能影响很大,可以使用线程池进行管理。
使用线程池的好处:主要用于减少因频繁创建和销毁线程带来开销,因此那些经常使用且执行时间短的线程需要用线程池来管理。
3、C#版代码如下
服务器端代码:
[html] view plain copy
using System;
using SystemCollectionsGeneric;
using SystemLinq;
using SystemText;
using SystemNet;
using SystemNetSockets;
using SystemThreading;
using SystemIO;
namespace SockServer
{
class Program
{
static void Main(string[] args)
{
try
{
//把ip地址转换为实例
IPAddress ipa = IPAddressParse("127001");
//监听端口8001
TcpListener mylsn = new TcpListener(ipa, 8001);
//开启监听
mylsnStart();
//输出监听成功的信息
ConsoleWriteLine("在8001启动服务,等待连接");
//等待处理接入连接请求
while (true)
{
Socket mysock = mylsnAcceptSocket();
ConsoleWriteLine("有连接,连接来自" + mysockRemoteEndPoint);
work w = new work();
wmysock = mysock;
wmylsn = mylsn;
Thread t = new Thread(new ThreadStart(wmain));
tStart();
}
}
catch
{ }
finally
{ }
}
}
class work
{
public Socket mysock;
public TcpListener mylsn;
public void main()
{
//接收客户端消息
byte[] data = new byte[100];
mysockReceive(data);
string rt = SystemTextUTF8EncodingUTF8GetString(data);
ConsoleWriteLine(rt);
//给客户端发消息
mysockSend(UTF8EncodingUTF8GetBytes("server callback"));
//释放资源
mysockClose();
mylsnStop();
}
}
}
客户端代码:
[html] view plain copy
using System;
using SystemCollectionsGeneric;
using SystemLinq;
using SystemText;
using SystemNet;
using SystemNetSockets;
using SystemThreading;
using SystemIO;
namespace SockClient
{
class Program
{
public static void Main()
{
//新建客户端套接字
TcpClient tclient = new TcpClient();
//连接服务器
tclientConnect("127001", 8001);
ConsoleWriteLine("输入要发送的消息");
//读入要传输的字符
string str = ConsoleReadLine();
//得到流
Stream stm = tclientGetStream();
//发送字符串
ASCIIEncoding asen = new ASCIIEncoding();
byte[] data = asenGetBytes(str);
stmWrite(data, 0, dataLength);
//接受服务器返回的消息
byte[] back = new byte[100];
int k = stmRead(back, 0, 100);
//输出服务器返回的消息
for (int i = 0; i < k; i++)
{
ConsoleWrite(ConvertToChar(back[i]));
}
//关闭连接
tclientClose();
}
}
}
在服务器上要开发一个TCP服务端,功能是维护在线客户端列表、处理客户端(假设为客户1)连接请求,将客户1的请求推送到客户2,根据客户2 的响应决定是不是在客户1和2之间建立应用连接,一旦应用连接建立,服务端就持续交换转发客户1、2的数据,直到其中一方断开,这是所有数据都通过服务器中转的方式;还有一种方式服务端仅仅维护在线用户列表,客户端相互直接连接,数据不通过服务器中转,具体实现还有许多细节需要处理,希望能够帮到你。
建立多个线程就ok了 为每一个连接 创建一个线程去处理
while (true)
{
// 得到包含客户端信息的套接字
Socket client = serverAccept();
//创建消息服务线程对象
ClientThread newclient = new ClientThread(client);
//把ClientThread 类的ClientService方法委托给线程
Thread newthread = new Thread(new ThreadStart(newclientClientService));
// 启动消息服务线程
newthreadStart();
}
服务器接收多个客户端链接,可以把客户端标识保存在map中
map<SOCKET, ClientInfo>
因为调用accept返回的SOCKET其实就是int
一个服务器对多个客户端,你可以这样去实现:在服务器端程序中为每个连接上服务器的客户端开启一个线程。这也就是多线程编程的内容了,至于你说怎么阻止客户端做重复的动作,你可以在客户端运行某个动作时向服务器端发送一个标识符,服务器端用一个变量存储这些标识符,但服务器端在接受一个标识符后,会对存储这些标识符的变量进行遍历,如果这个标识符已经存在,那么表明是一个重复的动作,服务器端就可以禁止接受该重复动作
当然是支持多客户了,要不每个网站只能一个用户访问了。目前互联网全是基于TCP/IP协议运行的,而多用户的实现,则是依据每个连接的数据包中的一个16位的数字。详细的,可以研究一下TCP/IP协议,对每一层的数据包的结构定义,这样很多问题都有答案了,这些是学习或了解网络的基本。
有问题欢迎交流,。
0条评论