问题描述
ImportsSystem.Net.SocketsImportsSystem.NetImportsSystem.ThreadingImportsSystem.TextPublicClassUsingAsyncSocketServerDimstrMessageAsStringDimmyListenerAsSocketDimbteAccept(65536)AsByteDimbteSend(65536)AsByteDimEndSocketAsSocketDimmyThread1AsThreadPrivateSub开始监听Button_Click(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)Handles开始监听Button.ClickmyThread1=NewThread(NewThreadStart(AddressOfStartListen))myThread1.Start()EndSubPrivateSub发送Button_Click(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)Handles发送Button.ClickDimmyThreadAsNewThread(NewThreadStart(AddressOfSendStart))myThread.Start()EndSubPrivateSubStartListen()DimintPortAsIntegerDimbidEndPointAsIPEndPointintPort=Integer.Parse(Me.通信端口TextBox.Text)bidEndPoint=NewIPEndPoint(IPAddress.Parse("10.111.1.36"),intPort)myListener=NewSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp)TrymyListener.Bind(bidEndPoint)DimmyAsyncCallbackAsNewAsyncCallback(AddressOfAcceptEnd)myListener.Listen(100)myListener.BeginAccept(myAsyncCallback,myListener)Me.联机信息RichTextBox.Text="等待联机中，开始整理数据......"CatchexAsExceptionMessageBox.Show(ex.Message,"打开连接错误",MessageBoxButtons.OK,MessageBoxIcon.Warning)EndTryEndSubPrivateSubAcceptEnd(ByValpIAsyncResultAsIAsyncResult)EndSocket=myListener.EndAccept(pIAsyncResult)Me.联机信息RichTextBox.Text+=vbCrLf&"已接受客户端联机请求!"DimmyAsyncCallbackAsNewAsyncCallback(AddressOfReceiveData)EndSocket.BeginReceive(bteAccept,0,65536,SocketFlags.None,myAsyncCallback,EndSocket)Me.联机信息RichTextBox.Text+=vbCrLf&"开始接收客户端传送的数据内容......"EndSubPrivateSubReceiveData(ByValpIAsyncResultAsIAsyncResult)DimintByteAsIntegerintByte=EndSocket.EndReceive(pIAsyncResult)IfintByte>0ThenMe.接收数据RichTextBox.Text+=Encoding.Default.GetString(bteAccept)EndIfMe.联机信息RichTextBox.Text+=vbCrLf&"成功接收客户端所传送的数据内容!"&intByte.ToString&"个字节"Array.Clear(bteAccept,0,bteAccept.Length)DimmyAsyncCallbackAsNewAsyncCallback(AddressOfReceiveData)EndSocket.BeginReceive(bteAccept,0,65536,SocketFlags.None,myAsyncCallback,EndSocket)EndSubPrivateSubSendStart()DimmyAsyncCallbackAsNewAsyncCallback(AddressOfSendData)bteSend=Encoding.Default.GetBytes(Me.发送数据RichTextBox.Text)EndSocket.BeginSend(bteSend,0,bteSend.Length,SocketFlags.DontRoute,myAsyncCallback,EndSocket)Me.联机信息RichTextBox.Text+=vbCrLf&"开始传送数据至客户端......"EndSubPrivateSubSendData(ByValpIAsyncResultAsIAsyncResult)DimintSendAsIntegerintSend=EndSocket.EndSend(pIAsyncResult)Me.联机信息RichTextBox.Text+=vbCrLf&"数据传送完成，总共传送"&intSend.ToString&"个字节!"EndSubPrivateSub停止联机Button_Click(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)Handles停止联机Button.ClickmyListener.Close()myThread1.Abort()MessageBox.Show("结束联机操作!","停止监听",MessageBoxButtons.OK,MessageBoxIcon.Information)EndSubPrivateSubUsingAsyncSocketServer_Load(ByValsenderAsObject,ByValeAsSystem.EventArgs)HandlesMe.LoadSystem.Windows.Forms.Control.CheckForIllegalCrossThreadCalls=FalseEndSubEndClass这是服务器端代码，怎么修改成多客户端的服务器端代码，万分感谢!
解决方案
解决方案二：
VB.Net程序设计:简单的通信系统-远程控制+聊天功能里面实现了一个服务端，多个客服端的功能。
解决方案三：
没有看到这个程序的代码呀，怎么下载呀，急呀......
解决方案四：
用线程来实现啊。
解决方案五：
PublicClassClientOrder''通过属性来进行外部访问PrivateClientIDAsIntegerPublicPropertyID()AsIntegerGetReturnClientIDEndGetSet(ByValvalueAsInteger)ClientID=valueEndSetEndPropertyEndClass
PublicClassClientOrder''直接访问PublicClientIDasInteger=0Endclass1.这个两种访问的区别在哪？2.对程序的影响有哪些，采用哪种较好3.在对这个类进行实例的时候，必须用New？为什么直接访问的时候不用new也可以？
解决方案六：
我知道用线程，但是不会用线程呀。还有就是是用线程好呢，还是线程池好呢。我这个就需要两个客户端就行了。请高手给指指，改改。跪谢
解决方案七：
如果有高手帮忙的话，分还可以继续加......
解决方案八：
具体点儿，能够实现多客户端的话，分还可以加.....
解决方案九：
代码以前写的。很差劲的。
解决方案十：
该回复于2012-03-16 09:05:29被版主删除
解决方案十一：
如果你想要我可以提供组件的方式给你，是很成熟的代码，在我的很多系统中都用到
解决方案十二：
行，十分感谢。我的邮箱是cuihanfeng123@163.com，万分感谢......
解决方案十三：
我很想要，分数可以加。我的邮箱是cuihanfeng123@163.com，拜托了，高手!
解决方案十四：
我很想要，分数可以加。我的邮箱是fangyufeng@163.com，拜托了，高手!
解决方案十五：
好像可以用WCF来实现！
解决方案：
ImportsSystem.Text.RegularExpressionsImportsSystem.XmlImportsSystem.NetImportsSystem.Net.SocketsImportsSystem.ThreadingImportsSystem.TextImportsSystem.DiagnosticsPublicClassfrmServerPrivateDelegateSubTxtDisplayInfoDelegate(ByValTextAsString)DimcliSocketAsSocketDimReceiveIPAsStringDimReceiveWordAsStringDimReceiveNameAsStringDimReceiveTimeAsStringDimSelectIPAsStringDimSelectNameAsStringDimIsEnterSendDataAsBoolean=FalseDimServerIPAsStringDimStopThreadAsBoolean=FalsePublicClassStateObject'Clientsocket.PublicworkSocketAsSocket=Nothing'Sizeofreceivebuffer.PublicConstBufferSizeAsInteger=4096'Receivebuffer.Publicbuffer(BufferSize)AsByte'Receiveddatastring.PublicsbAsNewStringBuilderEndClass'StateObject'服务端的SocketDimlistenerAsSocket'与客户端会话的SocketDimmySocketAsSocket'服务端的运行状态DimIsRunAsBoolean=False'监听接收数据线程DimmyThreadAsThreadPublicallDoneAsNewManualResetEvent(False)PrivateSubForm1_Load(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)HandlesMyBase.Load'XMLServer()Start()btnSend.Enabled=FalseXMLShow()TextBox1.SelectionColor=Color.BlueLabel2.Text=Dns.GetHostEntry(Dns.GetHostName).AddressList().GetValue(0).ToStringEndSubPrivateSubXMLShow()ListBox2.Items.Clear()DimxmlDocAsNewXmlDataDocumentxmlDoc.Load(Application.StartupPath&"UserDef.xml")DimxnAsXmlNode=xmlDoc.SelectSingleNode("collect")DimxnlAsXmlNodeList=xn.ChildNodesDimxnfAsXmlNodeForEachxnfInxnlDimxeAsXmlElement=CType(xnf,XmlElement)Ifxe.GetAttribute("IP")<>""ThenListBox2.Items.Add(xe.InnerText)'&vbCrLf'显示属性值EndIfNextxnfEndSubPrivateSubXMLServer()DimxmlDocAsNewXmlDataDocumentxmlDoc.Load(Application.StartupPath&"UserDef.xml")DimxnAsXmlNode=xmlDoc.SelectSingleNode("collect")DimxnlAsXmlNodeList=xn.ChildNodesDimxnfAsXmlNodeForEachxnfInxnlDimxeAsXmlElement=CType(xnf,XmlElement)Ifxe.GetAttribute("IP")<>""ThenServerIP=xe.InnerText'&vbCrLf'显示属性值Debug.Print(ServerIP)EndIfNextxnfEndSubPrivateSubStart()myThread=NewThread(AddressOfListen)myThread.Start()EndSubPublicSubListen()TryDimipHostInfoAsIPHostEntry=Dns.GetHostEntry(Dns.GetHostName)DimipAddressAsIPAddress=ipHostInfo.AddressList(0)DimlocalEndPointAsNewIPEndPoint(ipAddress,11000)'初始化socketlistener=NewSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp)'绑定端口listener.Bind(localEndPoint)'开始监听listener.Listen(10)BeginInvoke(NewEventHandler(AddressOfAddInfo),"本地服务端已启动，正在等待连接......")StartListen()CatchexAsExceptionMsgBox("错误"+ex.ToString,MsgBoxStyle.Information,"Listen")EndTryEndSubPublicSubStartListen()Dimbytes()AsByte=New[Byte](1024){}DimdataAsString=String.EmptyTryWhileTrueIfStopThread=FalseThenallDone.Reset()listener.BeginAccept(NewAsyncCallback(AddressOfAcceptCallback),listener)IsRun=TrueallDone.WaitOne()ElseExitSubEndIfEndWhileCatchexAsExceptionMsgBox("错误"+ex.ToString,MsgBoxStyle.Information,"StartListen")EndTryEndSub
解决方案：
PublicSubAcceptCallback(ByValarAsIAsyncResult)'Getthesocketthathandlestheclientrequest.DimlistenerAsSocket=CType(ar.AsyncState,Socket)'Endtheoperation.DimhandlerAsSocket=listener.EndAccept(ar)'Createthestateobjectfortheasyncreceive.DimstateAsNewStateObjectstate.workSocket=handlerhandler.BeginReceive(state.buffer,0,StateObject.BufferSize,0,NewAsyncCallback(AddressOfReadCallback),state)Debug.Print("AcceptCallback")EndSubPublicSubReadCallback(ByValarAsIAsyncResult)DimcontentAsString=String.Empty'Retrievethestateobjectandthehandlersocket'fromtheasynchronousstateobject.DimstateAsStateObject=CType(ar.AsyncState,StateObject)DimhandlerAsSocket=state.workSocket'Readdatafromtheclientsocket.DimbytesReadAsInteger=handler.EndReceive(ar)IfbytesRead>0Then'Theremightbemoredata,sostorethedatareceivedsofar.state.sb.Append(Encoding.UTF8.GetString(state.buffer,0,bytesRead))'Checkforend-of-filetag.Ifitisnotthere,read'moredata.content=state.sb.ToString()Ifcontent.IndexOf("<EOF>")>-1Then'Allthedatahasbeenreadfromthe'client.Displayitontheconsole.Dimtokens()AsStringtokens=content.Trim.Split("|")ReceiveIP=tokens(0)ReceiveWord=tokens(1)ReceiveTime=tokens(2)Debug.Print(content)DimdelAsNewTxtDisplayInfoDelegate(AddressOfDisplayStatus)'Me.Invoke(del,"Read{0}bytesfromsocket."+vbLf+"Data:{1}"&content.Length&content.ToString)Me.Invoke(del,content.ToString)Else'Notalldatareceived.Getmore.handler.BeginReceive(state.buffer,0,StateObject.BufferSize,0,NewAsyncCallback(AddressOfReadCallback),state)EndIfEndIfhandler.Shutdown(SocketShutdown.Both)handler.Close()'Signalthemainthreadtocontinue.allDone.Set()Debug.Print("ReadCallback")EndSub'ReadCallbackPrivateFunctionGetReceiveName()AsStringDimxmlDocAsNewXmlDataDocumentxmlDoc.Load(Application.StartupPath&"UserDef.xml")DimxnlAsXmlNodeList=xmlDoc.SelectSingleNode("collect").ChildNodesDimxnAsXmlNodeForEachxnInxnlDimxeAsXmlElement=CType(xn,XmlElement)Ifxe.GetAttribute("IP")=ReceiveIPThenGetReceiveName=xe.InnerTextExitFunctionEndIfNextxnGetReceiveName=ReceiveIPEndFunctionPrivateSubDisplayStatus(ByValTextAsString)'Me.ListBox1.Items.Add(SelectName&"说:"&ReceiveWord)IfIsEnterSendData=TrueThenMe.RichTextBox1.Text=Trim(Me.RichTextBox1.Text)&GetReceiveName()&"说:"&ReceiveTime&vbCrLf&""&Trim(ReceiveWord)ElseMe.RichTextBox1.Text=Trim(Me.RichTextBox1.Text)&GetReceiveName()&"说:"&ReceiveTime&vbCrLf&""&Trim(ReceiveWord)&vbCrLfEndIfRichTextBox1.SelectionStart=RichTextBox1.TextLengthRichTextBox1.Focus()PlaySound()TextBox1.Focus()'ListBox1.SelectedIndex=ListBox1.Items.Count-1EndSub'发送信息PrivateSubbtnSend_Click(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)HandlesbtnSend.ClickIsEnterSendData=FalseSendDataToServer()EndSubPrivateSubSendDataToServer()IfSelectIP=""ThenMsgBox("提示：没有选择发送对象！",MsgBoxStyle.Information,"MyQQ")ExitSubEndIfDimremoteEPAsNewIPEndPoint(Net.IPAddress.Parse("10.178.149.106"),11000)cliSocket=NewSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp)TrycliSocket.Connect(remoteEP)'ListBox1.Items.Add("连接服务端成功!")DimmsgAsByte()=Encoding.UTF8.GetBytes("|"&SelectIP&"|"&Trim(TextBox1.Text)&"|"&Now()&"|"&"<EOF>")DimbytesSentAsInteger=cliSocket.Send(msg)IfIsEnterSendData=TrueThenMe.RichTextBox1.Text=Me.RichTextBox1.Text&"本地消息:"&Now()&vbCrLf&""&Trim(TextBox1.Text)ElseMe.RichTextBox1.SelectionColor=Color.BlueMe.RichTextBox1.Text=Trim(Me.RichTextBox1.Text)&"本地消息:"&vbCrLf&""&Trim(TextBox1.Text)&Chr(13)+Chr(0)EndIfRichTextBox1.SelectionStart=RichTextBox1.TextLengthRichTextBox1.Focus()TextBox1.Focus()'ListBox1.Items.Add("本地信息:"+TextBox1.Text)'ListBox1.SelectedIndex=ListBox1.Items.Count-1TextBox1.Text=""'ListBox1.Items.Add(CStr(ListBox1.Items.Count+1))cliSocket.Shutdown(Net.Sockets.SocketShutdown.Both)'禁用某Socket上的发送和接收cliSocket.Close()'关闭socketCatchexAsExceptionMsgBox("无法连接到远程服务器由于目标机器积极拒绝，无法连接",MsgBoxStyle.Critical,"AGVExtend")EndTryEndSub'非UI线程调用窗体控件，保证线程安全。与聊天实现无关。SubAddInfo(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)'ListBox1.Items.Add("信息:"+sender.ToString)Me.RichTextBox1.Text=Me.RichTextBox1.Text&"信息:"+sender.ToString&vbCrLfEndSub'关闭窗口时发关退出信息并清理资源PrivateSubForm1_FormClosing(ByValsenderAsObject,ByValeAsSystem.Windows.Forms.FormClosingEventArgs)HandlesMe.FormClosingTryStopThread=TrueallDone.Set()myThread.Abort()CatchexAsExceptionMsgBox("错误",MsgBoxStyle.Information,"Form1_FormClosing")EndTryEndSubPrivateSubTextBox1_KeyPress(ByValsenderAsObject,ByValeAsSystem.Windows.Forms.KeyPressEventArgs)HandlesTextBox1.KeyPressIfe.KeyChar=Chr(13)ThenIsEnterSendData=TrueSendDataToServer()EndIfEndSubPrivateSubTextBox1_TextChanged(ByValsenderAsObject,ByValeAsSystem.EventArgs)HandlesTextBox1.TextChangedIfTextBox1.Text=""ThenbtnSend.Enabled=FalseElsebtnSend.Enabled=TrueEndIfEndSubPrivateSubToolStripButton1_Click(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)HandlesToolStripButton1.ClickForm2.ShowDialog()Me.XMLShow()EndSubPrivateSubListBox2_SelectedIndexChanged(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)HandlesListBox2.SelectedIndexChangedIfListBox2.SelectedItems.Count=0ThenExitSubDimxmlDocAsNewXmlDataDocumentxmlDoc.Load(Application.StartupPath&"UserDef.xml")DimxnlAsXmlNodeList=xmlDoc.SelectSingleNode("collect").ChildNodesDimxnAsXmlNodeForEachxnInxnlDimxeAsXmlElement=CType(xn,XmlElement)Ifxe.InnerText=ListBox2.SelectedItems(0)ThenSelectName=xe.InnerTextSelectIP=xe.GetAttribute("IP")Debug.Print(SelectName)Debug.Print(SelectIP)EndIfNextxnMe.Text="你正在与"&SelectName&"通讯"EndSubPrivateSubButton1_Click(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)HandlesButton1.ClickMe.Close()EndSubPrivateSub关于ToolStripMenuItem_Click(ByValsenderAsSystem.Object,ByValeAsSystem.EventArgs)Handles关于ToolStripMenuItem.ClickAboutBox1.ShowDialog()EndSubPrivateSubPlaySound()TryDimmyplayerAsNewSystem.Media.SoundPlayer()DimmyfilenameAsString=Application.StartupPath+"Soundmsg.wav"myplayer.SoundLocation=myfilenamemyplayer.LoadAsync()myplayer.Play()CatchexAsExceptionErr.Clear()EndTryEndSubEndClass
解决方案：
引用楼主cuihanfeng的回复:
这是服务器端代码，怎么修改成多客户端的服务器端代码，万分感谢!
直接说你调试出这段代码有什么问题吧！
解决方案：
線程吧！
解决方案：
解决方案：
为什么我看到VB的代码我就有一种想杀死人的冲动?