日期:2010-10-25  浏览次数:20537 次

以下示例程序实现简单的Socket通信,可以开多个客户端。本机测试通过,未做联机测试。

Server:

using System.Net;

using System.Net.Sockets;

using System.Threading;

using System.Collections;

namespace MySocketServer1

{

    public partial class Form1 : Form

    {

        private IPAddress serverIP = IPAddress.Parse("127.0.0.1");//以本机作测试

        private IPEndPoint serverFullAddr;//完整终端地址

        private Socket sock;

        private System.Timers.Timer myTimer;

        private ArrayList alSock;//当建立了多个连接时用于保存连接

        public Form1()

        {

            InitializeComponent();

        }

        private void btStart_Click(object sender, EventArgs e)

        {

            serverFullAddr = new IPEndPoint(serverIP, 1000);//取端口号1000

//构造Socket对象,套接字类型为“流套接字”,指定五元组中的协议元

            sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream,

ProtocolType.Tcp);

//指定五元组中的本地二元,即本地主机地址和端口号

            sock.Bind(serverFullAddr);

//监听是否有连接传入,指定挂起的连接队列的最大值为20

            sock.Listen(20);

            alSock = new ArrayList();

//构造定时器,时间间隙为1秒,即每隔一秒执行一次accept()方法,以获取连接请求队列中//第一个挂起的连接请求

            myTimer =new System.Timers.Timer(1000);

            myTimer.Elapsed +=new System.Timers.ElapsedEventHandler(myTimer_Elapsed);

            myTimer.Enabled = true;

        }

        private void myTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)

        {

            myTimer.Enabled = false;

//执行accept(),当挂起队列为空时将阻塞本线程,同时由于上一语句,定时器将停止,直//至有连接传入

            Socket acceptSock = sock.Accept();

//将accept()产生的Socket对象存入ArrayList

            alSock.Add(acceptSock);

// 构造Threading.Timer对象,这将导致程序另启线程。线程将执行回调函数,该委托限制//函数参数须为object型。Threading.Timer构造器的第二个参数即传入回调函数的参数;第//三个参数指定调用回调函数之前的延时,取0则立即启动;最后一个参数指定调用回调函数//的时间间隔,取0则只执行一次。

            System.Threading.Timer ti = new System.Threading.Timer(new

TimerCallback(ReceiveMsg), acceptSock, 0, 0);

            myTimer.Enabled = true;

        }

        private void ReceiveMsg(object obj)

        {

            Socket acceptSock = (Socket)obj;

            try

            {

                while (true)