.net中的socket异步通信实现

.net中的socket异步通信实现--服务器端代码


项目的需求是这样的：
1.需要能够实现多个工作站互相进行异步数据传输
2.能够根据不同工作站的配置情况选择从哪个工作站申请数据
3.能够及时收获各工作站的配置变更和在线情况
4.收到的数据信息量较大，需要进行处理后送到其他模块备用。
根据这些需求让我觉得我要做的这部分程序有点像QQ的功能，因此我需要在服务器端程序建立一个服务程序。
各工作站通过服务程序获得其他工作站的在线列表和每个工作站的配置信息，所有工作站的配置一旦更新，全部上传到服务器端保留。

Imports System.ServiceProcess
Imports System.Net.Sockets
Imports System.Net
Imports System.Threading
Imports System.Collections
Imports System.Text
Imports System.IO

Public Class Server
    Inherits System.ServiceProcess.ServiceBase

#Region "全局变量"
    Dim ServerSocket As New Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp)
    Dim ipep As IPEndPoint = New IPEndPoint(IPAddress.Any, 11000)
    Dim htUserList As New Hashtable  '用来保存在线用户和用户的"IP和端口" 
    Dim userName(0) As String
    Dim userIPEP(0) As IPEndPoint
    Dim userTime(0) As Integer
    Dim DataServerInfor(0) As String
    Dim DataServerSaveEnd(0) As Boolean
    Dim timerDelegate As New TimerCallback(AddressOf onLineTimeOut)
    Dim sw As StreamWriter
    Dim movelenth As Integer = 512 '最大为512，乘以2为传送的最大字节数：1024
    Private Shared LongSendID As Integer = 0
    Private LongSendMax As Integer = 50
    Private dealing As Boolean = False
    Private ReceiveDataList As DataQueue
#End Region

#Region "参数"

    '以下是客户端到服务器端的消息开头 
    Const LOGININ As String = "10" '请求登陆的消息|||消息形式:10+自己的用户名 
    Const LOGINOUT As String = "11" '请求登出的消息|||消息形式:11+自己的用户名 
    Const GETULIST As String = "12" '请求获得在线用户列表|||消息形式:12 
    Const P2PCONN As String = "13" '请求P2P连接的消息|||消息形式:13+自己的用户名+|+对方的用户名 
    Const HOLDLINE As String = "14" '保持连接.|||消息开式:14+自己的用户名 

    '以下是服务器到客户端的消息开头 
    Const HVUSER As String = "20" '用户名已存在 
    Const GETUSER As String = "21" '在线用户列表|||消息格式:21+用户名+EP 
    Const MAKHOLD As String = "22" '打洞命令|||消息格式:22+IP 
    Const LOGINOK As String = "23" '登陆成功 
    Const SERVCLS As String = "24" '服务器关闭 
    Const MSGEND As String = "25" '消息结束 
    Const ONEOFF As String = "26" '一个客户端下线

    '以下是服务器端的命名 
    Const EXITPRO As String = "EXIT" '退出命令 
    Const SHOWULIST As String = "SHOWUSER" '显示在线用户 
    Const HELP As String = "HELP" '显示帮助 

    '以下是工作站发送给服务器的消息开头：
    Const RECDEVINFO As String = "45" '工作站发送给服务器的设备配置信息

    '以下是ICU客户端发送给本服务器程序的命令：
    Const GETDATASERVER As String = "50"        '获取当前在线的数据服务器（即工作站）
    Const SHOWDATASERVER As String = "51"       '将在线的数据服务器
    Const GETDSERVERINFOR As String = "52"      '获取某个数据服务器的配置信息

#End Region

#Region " 组件设计器生成的代码 "

    Public Sub New()
        MyBase.New()

        ' 该调用是组件设计器所必需的。
        InitializeComponent()

        ' 在 InitializeComponent() 调用之后添加任何初始化

    End Sub

    'UserService 重写 dispose 以清理组件列表。
    Protected Overloads Overrides Sub Dispose(ByVal disposing As Boolean)
        If disposing Then
            If Not (components Is Nothing) Then
                components.Dispose()
            End If
        End If
        MyBase.Dispose(disposing)
    End Sub

    ' 进程的主入口点
    <MTAThread()> _
    Shared Sub Main()
        Dim ServicesToRun() As System.ServiceProcess.ServiceBase

        ' 在同一进程中可以运行不止一个 NT 服务。若要将
        ' 另一个服务添加到此进程，请更改下行以
        ' 创建另一个服务对象。例如，
        '
        '   ServicesToRun = New System.ServiceProcess.ServiceBase () {New Service1, New MySecondUserService}
        '

在上一篇文章中主要介绍了socket异步通信实现的服务器端代码，下面我们来分析一下客户端代码：
那么在设计客户端代码时我们主要考虑哪些问题呢？
第一是如何接收数据，往往一次传输的数据量较大，但socket一次的传输量是1024个byte，因此需要对数据在发送端进行拆分，而在接收端进行组合。
第二是需要建立缓冲区，网络传输的速度肯定比我们处理数据的速度快。
大家如果需要使用这段代码，需要编写一下其中的ClassSetup类，该类包含每个工作站的配置信息，由于版权问题，在这里就不公开了。
客户端代码如下：

End Class