Imports System.Net
Imports System.Net.Sockets
Imports System.Threading
Imports System.Text
Imports System.Diagnostics


Public Class frmServer


? ? '服務(wù)端的Socket
? ? Dim listener As Socket
? ? '與客戶(hù)端會(huì)話(huà)的Socket
? ? Dim mySocket As Socket
? ? '服務(wù)端的運(yùn)行狀態(tài)
? ? Dim IsRun As Boolean = False
? ? Dim IsThread1 As Byte = 0
? ? '監(jiān)聽(tīng)接收數(shù)據(jù)線(xiàn)程
? ? Dim myThread As Thread


? ? Private Sub Form1_Load(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles MyBase.Load
? ? ? ? myThread = New Thread(AddressOf Listen)
? ? ? ? Timer1.Enabled = True
? ? ? ? Timer1.Interval = 1000
? ? ? ? TextBox2.Text = "192.168.3.50"
? ? End Sub


? ? Public Sub Listen()
? ? ? ? Dim bytes() As Byte = New [Byte](102400) {}
? ? ? ? Dim data As String = String.Empty
? ? ? ? Dim tokens() As String
? ? ? ? If (IsThread1 = 1) Then
? ? ? ? ? ? BeginInvoke(New EventHandler(AddressOf AddInfo), "線(xiàn)程重新啟動(dòng)，正在等待連接......")
? ? ? ? ? ? IsThread1 = 0
? ? ? ? Else
? ? ? ? ? ? Dim localEndPoint As New IPEndPoint(Net.IPAddress.Parse(TextBox2.Text), 2052)
? ? ? ? ? ? '初始化socket
? ? ? ? ? ? listener = New Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
? ? ? ? ? ? '綁定端口
? ? ? ? ? ? listener.Bind(localEndPoint)
? ? ? ? ? ? '開(kāi)始監(jiān)聽(tīng)
? ? ? ? ? ? listener.Listen(10)


? ? ? ? ? ? BeginInvoke(New EventHandler(AddressOf AddInfo), "服務(wù)端已啟動(dòng)，正在等待連接......")
? ? ? ? ? ? BeginInvoke(New EventHandler(AddressOf AddInfo), "正在等待連接......")
? ? ? ? End If
? ? ? ?


? ? ? ? mySocket = listener.Accept()
? ? ? ? IsRun = True
? ? ? ??
? ? ? ? While True
? ? ? ? ? ? Dim bytesRec As Integer = mySocket.Receive(bytes)
? ? ? ? ? ? data = Encoding.UTF8.GetString(bytes, 0, bytesRec)


? ? ? ? ? ? tokens = data.Trim.Split("|")
? ? ? ? ? ? Select Case tokens(0) '分析接收到的數(shù)據(jù)，可自己定義更多一些
? ? ? ? ? ? ? ? Case "0Xaa"
? ? ? ? ? ? ? ? ? ? BeginInvoke(New EventHandler(AddressOf AddInfo), tokens(1)) ?'Invoke保證線(xiàn)程安全
? ? ? ? ? ? ? ? Case "Exit"
? ? ? ? ? ? ? ? ? ? IsRun = False
? ? ? ? ? ? ? ? ? ? BeginInvoke(New EventHandler(AddressOf AddInfo), tokens(1)) ?'Invoke保證線(xiàn)程安全
? ? ? ? ? ? ? ? ? ? mySocket.Shutdown(SocketShutdown.Both)
? ? ? ? ? ? ? ? ? ? mySocket.Close()
? ? ? ? ? ? ? ? ? ? IsThread1 = 1
? ? ? ? ? ? ? ? ? ? myThread.Abort()
? ? ? ? ? ? ? ? ? ? Exit Sub
? ? ? ? ? ? End Select
? ? ? ? End While


? ? End Sub


? ? '發(fā)送信息
? ? Private Sub btnSend_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles btnSend.Click
? ? ? ? Dim msg As Byte() = Encoding.UTF8.GetBytes("0Xaa|" + TextBox1.Text)
? ? ? ? mySocket.Send(msg)
? ? ? ? ListBox1.Items.Add("0Xaa" + TextBox1.Text)
? ? ? ? 'TextBox1.Text = ""
? ? End Sub


? ? '非UI線(xiàn)程調(diào)用窗體控件，保證線(xiàn)程安全。與聊天實(shí)現(xiàn)無(wú)關(guān)。
? ? Sub AddInfo(ByVal sender As System.Object, ByVal e As System.EventArgs)
? ? ? ? ListBox1.Items.Add("0Xaa " + sender.ToString)
? ? End Sub


? ? '關(guān)閉窗口時(shí)發(fā)關(guān)退出信息并清理資源
? ? Private Sub Form1_FormClosing(ByVal sender As Object, ByVal e As System.Windows.Forms.FormClosingEventArgs) Handles Me.FormClosing
? ? ? ? If IsRun Then
? ? ? ? ? ? Dim msg As Byte() = Encoding.UTF8.GetBytes("Exit|服務(wù)端退出: " + Me.Handle.ToString)
? ? ? ? ? ? Dim bytesSent As Integer = mySocket.Send(msg)
? ? ? ? End If
? ? ? ? listener.Close()
? ? ? ? mySocket = Nothing
? ? ? ? myThread.Abort()
? ? End Sub


? ? Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click
? ? ? ? Button1.Enabled = False
? ? ? ? myThread.Start()
? ? End Sub

? ? Private Sub Button2_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button2.Click
? ? ? ? End
? ? End Sub

? ? Private Sub Timer1_Tick(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Timer1.Tick
? ? ? ? If (IsThread1 = 1) Then
? ? ? ? ? ? myThread = New Thread(AddressOf Listen)
? ? ? ? ? ? myThread.Start()
? ? ? ? End If
? ? End Sub
End Class

總結(jié)

以上是生活随笔為你收集整理的VB2010网络通信服务器的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。