不太清楚你的代码是怎样写的,所以只能从可能出现的问题上进行分析。
1、UDP丢包。使用UDP的时候经常会出现的问题,这个只能要求重发。
2、TCP粘包。如果你是新手这个问题是很容易出现的。你要知道,Socket.send并不是把数据发出去,而是把信息写入到了底层winsock的缓冲区,在有空的时候给他发出去。如果你数个SEND是连续执行的,就会出现粘包的问题。比如你要发送12345,67890这两条,接受方就可能收到1234567890这样的数据。如果你注意receive函数的返回值,就会发现你收到的大小是10而不是预先的5. 。
解决办法有三种
1、固定信息的长度,每次从接受缓冲区中读出一定的长度。发送时不足长度的补齐。当然,这会加大开销。
2、要求接收方回执,每次send后进入receive等待回执,避免连续Send。当然,这也会增加开销。通常这种做法只在接收方要进行信息的后续处理时采用。
3、用NetworkStream+分隔符的方法发送和接收。分隔符可以使用信息中不包含的字符来做。譬如如果信息中永远不包含换行符,那么可以在每条发送信息的结尾附加一个换行符,然后NetworkStream读取时以换行符作为分隔。每遇到换行符就作为一个数据包读出。
在运行中输入cmd ,然后用 netstat -an 看下有没有8888这个端口?至少可以看是不是被占用了。
是TCP协议吧,原因是服务器没有启动,或者启动了没有处于侦听状态。
是TCP协议,在实例化tcpclient = new TcpClient(remoteIpString, remotePort);的时候报错。
我想问一下,在同一个程序中怎么既充当服务器有充当客户端?
很有如果我用本机的ip做监听服务器地址,然后用127.0.0.1做客户机的ip地址可以嘛?
我想做的是P2P数据传送
这个8888应该是服务端的监听端口,如果netstat看不到的话肯定是会发生lz你所说的问题的。你应该还要启动这个服务端才对。
貌似不是在服务器端了,程序开始默认获取本机ip地址以及一个可用的端口,然后对这个端口进行监听。然后让你添加一个或多个好友ip地址及端口号。我是在添加好友的时候出现这个错误的。添加好友的ip我试过用127.0.0.1和本机ip,都报这个错。
网上那些“范例”很多都是所谓的单机demo,不要相信是产品的。回答你#4楼的问题。最起码的,通用服务器不是什么什么127.0.0.1进行bind操作的。比较正规的是IPAddress.Any,比较业余的也是从dns对象中遍历IPAddress集合,找出其中第一个符合ipv4模式的地址。你看到127.0.0.1的,直接把这个写“范例”的作者当作骗子好了。
大规模的测试,产品化的测试,这是必需的。不要相信仅仅是为了掩饰一个特别方法随便写的所谓范例。即使是msdn上的通讯范例,大多数也是非产品化的。因为它如果按照产品设计必须有的要素来设计,初学者反而会“看不懂”。这就是一个现实矛盾。
服务器应该害是启动了的,服务器的ip是本机ip,端口号时一个随机可用的值。这是我的理解。
我把监听的代码贴上来,在程序加载方法里调用。
ThreadStart myThreadStartDelegate = new ThreadStart(Listensing);。
//创建一个用于监听的线程对象,通过代理执行线程中的方法 myThread = new Thread(myThreadStartDelegate);。
//启动线程。
myThread.Start();。
一下是监听方法
private void Listensing()。
{
Socket socket = null;。
//获取本机上第一个可用的IP地址 myIPAddress = (IPAddress)Dns.GetHostAddresses(Dns.GetHostName()).GetValue(0);。
Random r = new Random();。
while (true) 。
{
try。
{。
//随机产生一个0~65535之间的端口号。
myPort = r.Next(65535);。
//myPort = 8888;。
//创建TcpListener对象,在本机的IP和Port端口监听连接到该IP和端口的请求。
tcpListener = new TcpListener(myIPAddress, myPort);。
//开始监听,如果不出现异常,则说明IP地址和端口号可用。
tcpListener.Start();。
//显示IP地址和端口。
ShowLocalIPAndPort();。
//在信息窗口显示成功信息。
ShowMyMessage(string.Format("尝试用端口{0}监听成功", myPort));。
ShowMyMessage(string.Format("<message>[{0}]{1:h点m分s秒}开始在端口{2}监听与本机的连接", myIPAddress, DateTime.Now, myPort));。
break;。
}。
catch 。
{。
//继续while循环,以便随机找下一个可用端口号,同时显示失败信息。
ShowMyMessage(string.Format("尝试用端口{0}监听失败", myPort));。
}。
}
while (true) 。
{
try。
{。
//使用阻塞方式接受客户端连接,根据连接信息创建Tcpclient对象。
//注意:AcceptSocket接受到新的连接请求才会继续执行其后的语句。
socket = tcpListener.AcceptSocket();。
//如果往下执行,说明已经根据客户端连接请求创建了套接字。
//使用创建的套接字接受客户端发送的信息。
NetworkStream stream = new NetworkStream(socket);。
StreamReader sr = new StreamReader(stream);。
string recieveMessage = sr.ReadLine();。
int i1 = recieveMessage.IndexOf(",");。
int i2 = recieveMessage.IndexOf(",", i1 + 1);。
int i3 = recieveMessage.IndexOf(",", i2 + 1);。
string ipString = recieveMessage.Substring(0, i1);。
string portString = recieveMessage.Substring(i1 + 1, i2 - i1 - 1);。
string messageTypeString = recieveMessage.Substring(i2 + 1, i3 - i2 - 1);。
string messageString = recieveMessage.Substring(i3 + 1);。
ShowMyMessage(ipString, portString, messageTypeString, messageString);。
}。
catch 。
{。
//通过停止TcpListener使AcceptSocket方法出现异常。
//在异常处理中关闭套接字并终止线程。
if (socket != null) 。
{。
if (socket.Connected) 。
{。
socket.Shutdown(SocketShutdown.Receive);。
}。
socket.Close();。
}。
myThread.Abort();。
}。
}
}
http://topic.csdn.net/u/20100506/18/19b27fcf-af70-4016-a30c-10de342c3214.html。
System.Net.WebException: 无法连接到远程服务器 ---> System.Net.Sockets.SocketException: 由于目标计算机积极拒绝,无法连接。 127.0.0.1:80。
在 System.Net.Sockets.Socket.DoConnect(EndPoint endPointSnapshot, SocketAddress socketAddress)。
在 System.Net.Sockets.Socket.InternalConnect(EndPoint remoteEP)。
在 System.Net.ServicePoint.ConnectSocketInternal(Boolean connectFailure, Socket s4, Socket s6, Socket& socket, IPAddress& address, ConnectSocketState state, IAsyncResult asyncResult, Int32 timeout, Exception& exception)。
--- 内部异常堆栈跟踪的结尾 ---。
在 System.Net.HttpWebRequest.GetRequestStream(TransportContext& context)。
在 System.Net.HttpWebRequest.GetRequestStream()。
在 System.Web.Services.Protocols.SoapHttpClientProtocol.Invoke(String methodName, Object[] parameters)。
TCP协议是TCP/IP协议簇中的传输层中的一个协议,也是TCP/IP协议簇最为重要的协议之一。在TCP/IP协议簇中,有一个协议和TCP协议非常类似,这就是UDP协议,网络上进行基于UDP协议的数据传送时,发送方只需知道接收方的IP地址(或主机名)和端口号就可以发送UDP数据包。而接收方只需知道发送方发送数据对应的端口号,就能够接收UDP数据包了。传送数据的双方并不需要进行连接就能够实现数据通讯,这样就导致基于UDP协议的网络应用程序,在传送数据时无法保证可靠性、完整性和安全性。
而TCP协议却与之相反,TCP协议是一种面向连接的,并提供可靠的、完整的、安全的数据传送的网络协议。它提供可靠字节服务的协议。在网络中通过TCP协议传送数据之前,发送方和接收方之间必须建立连接,这种连接就是所谓的"握手"。网络中TCP应用,如同日常生活中的打电话,在通话之前,首先要拨号、震铃(犹如发送方向接收方提出TCP连接申请,并等待TCP连接申请通过)。直到对方拿起电话时(发送方和接收方的TCP连接已经建立),就可以通话了(传送数据)。本文的主要内容就来介绍在Visual Basic .Net实现基于TCP协议网络数据传送的一种简单的方法。
一.简介本文在实现TCP协议网络应用时使用的类库:
.Net FrameWork SDK中提供了很多用以实现TCP协议或与之相关协议的类库,本文就选择五个比较典型,也是比较简单的类加以介绍,即:TcpListener类、TcpClient类、NetworkStream类、StreamReader类和StreamWriter类。TcpClient主要用以提出TCP连接申请。TcpListener主要用以侦听端口号,并接收远程主机的TCP连接申请。NetworkStream类是实现TCP数据传输的基础数据流,StreamReader类作用是通过操作NetworkStream,实现从网络接收数据。StreamWriter类作用是通过操作NetworkStream,实现向网络传输数据。
1. NetworkStream类:
NetworkStream类主要是提供用于网络访问的基础数据流。它主要是网络数据传输的载体,并提供同步、异步方式来访问网络数据流。虽然NetworkStream类有构造函数,但在实际情况中更多是通过TcpClient实例的GetStream方法来初始化NetworkStream实例。以下就是使用TcpClient实例的GetStream方法来初始化NetworkStream实例具体代码:
Dim tcpClient As TcpClient。
Dim nsStream As NetworkStream。
tcpClient = New TcpClient( "www.microsoft.com" , 8000)。
''对远程主机的8000端口提出TCP连接申请。
nsStream = tcpClient.GetStream ( )。
''TCP连接建立后,获得网络数据传输的基础数据流。
在下面介绍的程序示例中,就是利用NetworkStream作为传送和接收数据的载体。而操作这个载体的就是StreamWriter类和StreamReader类。表01和表02是NetworkStream类中一些常用的方法、属性及其说明。
方法 说明 BeginRead 开始异步读者基础数据流。 BeginWrite 开始异步写入基础数据流。 Close 关闭流并可选择关闭基础套接字。 EndRead 结束异步读取。 EndWrite 结束异步写入。 Flush 刷新流中的数据。 Read 从流中读取数据。 Seek 将流的当前位置设置为给定值。 SetLength 设置流的长度。 Write 将数据写入流。
表01:NetworkStream类中常用的方法及其说明。
其中"BeginRead"、"EndRead"和"BeginWrite"、"EndWrite"是二对异步方法,起作用分别相当于"Read"和"Write"方法。
属性 说明 CanRead 获取当前流是否支持读取。 CanSeek 获取流是否支持查找。该属性总是返回 false。 CanWrite 获取当前流是否支持写入。 DataAvailable 获取是否可以在流上读取数据。 Length 流上可用数据的长度。 Position 获取或设置流中的当前位置。
表02:NetworkStream类中属性及其说明。
2. StreamReader类:
StreamReader类能够实现对基础数据流的读操作,从而实现对经过基础数据流传送来的数据。表03是StreamReader类的常用的方法及其说明:
方法 说明 Close 关闭StreamReader并释放与阅读器关联的所有系统资源。 DiscardBufferedData 允许StreamReader丢弃其当前数据。 Peek 返回下一个可用的字符,但不使用它。 Read 读取输入流中的下一个字符或下一组字符。 ReadBlock 从当前流中读取最大数量的字符并从索引开始将该数据写入缓冲区。 ReadLine 从当前流中读取一行字符并将数据作为字符串返回。 ReadToEnd 从流的当前位置到末尾读取流。
表03:NetworkStream类中常用的方法及其说明。
3. StreamWriter类:
StreamWriter类能够实现对基础数据流的写操作,从而实现提供基础数据流来传送数据。表04是StreamWriter类的常用方法及其说明:
方法 说明 Close 关闭当前的StreamWriter和基础流。 Flush 清理当前编写器的所有缓冲区,并使所有缓冲数据写入基础流。 Write 写入基础数据流。 WriteLine 写入重载参数指定的某些数据,后跟行结束符。
表04:StreamWriter类的常用方法及其说明。
4.TcpClient 类:
TcpClient 类主要为TCP网络服务提供客户端连接。TcpClient是类基于Socket类构建,
它以更高的抽象程度提供TCP服务。TcpClient 提供了通过网络连接、发送和接收数据的简单方法。表05和表06分别是TcpClient类常用方法、属性及其说明。
方法 说明 Close 关闭 TCP 连接 Connect 使用指定的主机名和端口号将客户端连接到 TCP主机 GetStream 返回用于发送和接收数据的流。
表05:TcpClient类常用的方法。
属性 描述 LingerState 有关套接字逗留时间的信息 NoDelay 一个值,该值在发送或接收缓冲区未满时启用延迟 ReceiveBufferSize 接收缓冲区的大小 ReceiveTimeout TcpClient在启动后为接收数据而等待的时间长度 SendBufferSize 发送缓冲区的大小 SendTimeout 在您启动发送操作后TcpClient将为接收确认而等待的时间长度。
表06:TcpClient类常用的属性。
5.TcpListener 类:
TcpListener类的主要作用是从TCP网络客户端侦听连接,TcpListener类基于Socket 类。
提供更高理念级别的TCP服务。可以使用TcpListener从TCP客户端侦听连接。像 FTP 和 HTTP 这样的应用层协议是在 TcpListener 类的基础上建立的。表7和表8分别是TcpListener类常用方法、属性及其说明:
方法 说明 AcceptSocket 接受挂起的连接请求 AcceptTcpClient 接受挂起的连接请求 Pending 确定是否有挂起的连接请求 Start 开始侦听网络请求 Stop 关闭侦听器表7:TcpListener 类常用的方法。
属性 说明 LocalEndpoint 获取当前TcpListener的基础EndPoint Active 获取一个值,该值指示 TcpListener 是否正主动侦听客户端连接 Server 获取基础网络Socket。
表8:TcpListener 类常用的属性。
二.Visual Basic .Net实现基于TCP协议数据传送程序的体系结构:
在下面介绍的用Visual Basic .Net实现基于TCP协议的数据传送程序是由二个子程序组成的。也可以看成是服务器端程序和客户端程序,其中:服务器端程序的功能是侦听端口号,接收远程主要的TCP连接申请,并接收远程主机传送来的文字数据。另外一个子程序,也就是所谓的客户端程序,主要实现向网络的远程主机提出TCP连接申请,并在连接申请通过后,向远程主机传送文字数据。下面来详细介绍Visual Basic .Net实现TCP协议网络数据传送的服务器端程序和客户端程序的具体步骤。
三.服务器端程序的具体实现步骤:
服务器端程序的实现关键在于侦听端口号,接收远程主机的TCP连接申请,获得网络数据传输的基础数据流,并通过基础数据流接收数据。接收数据使用的是StreamReader中ReadLine方法,由于ReadLine方法是一个阻塞式的方法,所以在下面具体的实现步骤中,是接收数据是在创建的线程中完成的,具体可参阅下面实现步骤中的第十一和十二步。以下是Visual Basic .Net实现TCP协议客户端程序实现的具体步骤:
1. 启动Visual Studio .Net。
2. 选择菜单【文件】|【新建】|【项目】后,弹出【新建项目】对话框。
3. 将【项目类型】设置为【Visual Basic项目】。
4. 将【模板】设置为【Windows应用程序】。
5. 在【名称】文本框中输入【服务器端程序】。
6. 在【位置】的文本框中输入【E:\VS.NET项目】,然后单击【确定】按钮,这样在"E:\VS.NET项目"目录中就产生了名称为"服务器端程序"的文件夹,并在里面创建了名称为"服务器端程序"的项目文件。
7. 把Visual Studio .Net的当前窗口切换到【Form1.vb(设计)】窗口,并从【工具箱】中的【Windows窗体组件】选项卡中往Form1窗体中拖入下列组件,并执行相应的操作:
一个Label组件。
一个StatusBar组件。
一个ListBox组件。
一个Button组件,并在这个Button组件拖入Form1的设计窗体后,双击它,则系统会在Form1.vb文件分别产生这个组件的Click事件对应的处理代码。
8. 按照表05所示调整窗体中各组件属性的数值:
组件类型 组件名称 属性 设置结果 Form Form1 Text 服务器端程序 Form1 MaximizeBox False Form1 FormBorderStyle FixedSingle Button Button1 Text 启动服务 Button1 FlatStyle Flat Label Label1 Text 服务尚未启动 StatusBar StatusBar1 Text 无连接!表05:【服务器端程序】项目中组件设定数值表。
9. 把Visual Studio .Net的当前窗口切换到Form1.vb的代码编辑窗口,并在Form1.vb文件的最前面添加下列代码,下列代码在Form1.vb中导入程序中要使用的类所在的命名空间:
Imports System.Net.Sockets。
''使用到TcpListen类。
Imports System.Threading。
''使用到线程
Imports System.IO。
''使用到StreamReader类。
10. 在Form1.vb中创建各种可视组件的代码中添加下列代码,下列代码的作用是创建全局使用的实例和变量:
Private iPort As Integer = 8000。
''定义侦听端口号
Private thThreadRead As Thread。
''创建线程,用以侦听端口号,接收信息。
Private tlTcpListen As TcpListener。
''侦听端口号
Private blistener As Boolean = True。
''设定标示位,判断侦听状态
Private nsStream As NetworkStream。
''创建接收的基本数据流
Private srRead As StreamReader。
''从网络基础数据流中读取数据。
Private tcClient As TcpClient。
11. 在Form1.vb中的InitializeComponent过程之后添加下列代码,下列代码的作用是定义Listen过程,此过程的作用是侦听本地机的8000端口号,接受网络主机的TCP连接申请,并接收从建立申请的远程主机发送来的文本数据:
Private Sub Listen ( ) 。
Try
tlTcpListen = New TcpListener ( iPort ) 。
''以8000端口号来初始化TcpListener实例。
tlTcpListen.Start ( ) 。
''开始监听
StatusBar1.Text = "正在监听..."。
tcClient = tlTcpListen.AcceptTcpClient ( ) 。
''通过TCP连接请求
nsStream = tcClient.GetStream ( ) 。
''获取用以发送、接收数据的网络基础数据流。
srRead = New StreamReader ( nsStream ) 。
''以得到的网络基础数据流来初始化StreamReader实例。
StatusBar1.Text = "已经建立TCP连接!"。
''循环侦听
While blistener。
Dim sMessage As String = srRead.ReadLine ( ) 。
''从网络基础数据流中读取一行数据。
If ( sMessage = "STOP" ) Then。
tlTcpListen.Stop ( ) 。
''关闭侦听
nsStream.Close ( ) 。
srRead.Close ( ) 。
''释放资源
StatusBar1.Text = "无连接!"。
thThreadRead.Abort ( ) 。
''中止线程
Return
Else
''判断是否为断开TCP连接控制码。
Dim sTime As String = DateTime.Now.ToShortTimeString ( ) 。
''获取接收数据时的时间
ListBox1.Items.Add ( sTime + " " + sMessage ) 。
End If
End While
Catch ex As System.Security.SecurityException。
MessageBox.Show ( "侦听失败!" , "错误" ) 。
End Try
End Sub
12. 用下列代码替换Form1.vb中的Button1的Click事件对应的处理代码,下列代码功能是用上面定义的Listen过程来初始化并启动线程,接收建立TCP连接的远程主机发送来的文本数据:
Private Sub Button1_Click ( ByVal sender As System.Object , ByVal e As System.EventArgs ) Handles Button1.Click。
thThreadRead = New Thread ( New ThreadStart ( AddressOf Listen ) ) 。
''以Listen过程来初始化线程实例。
thThreadRead.Start ( ) 。
''启动线程
Button1.Enabled = False。
Label1.Text = "服务已经启动!"。
Label1.ForeColor = Color.Red。
End Sub
13. 用下列代码替换Form1.vb中的Dispose过程,下面代码的作用是重新定义Dispose过程,在Dispose过程手动清除使用的资源,回收垃圾:
Protected Overloads Overrides Sub Dispose ( ByVal disposing As Boolean ) 。
Try
thThreadRead.Abort ( ) ''中止线程。
tlTcpListen.Stop ( ) ''关闭侦听。
tcClient.Close ( ) 。
nsStream.Close ( ) 。
srRead.Close ( ) ''释放资源。
Catch
End Try
If disposing Then。
If Not ( components Is Nothing ) Then。
components.Dispose ( ) 。
End If
End If
MyBase.Dispose ( disposing ) 。
End Sub
14. 至此在上述步骤都正确执行后,【服务器端程序】项目的全部工作就完成了。编译、生成可执行文件后,接着介绍客户端程序的实现步骤。
四.客户端端程序的具体实现步骤:
客户端端序的实现关键在于向网络中的远程主机提出TCP连接申请,并在申请通过后,得到传输数据的基础数据流,并通过对基础数据流进行写操作向远程主机传送文本数据。由于在客户端程序中没有使用阻塞式的方法,所以程序中没有使用到线程。对远程主机提出TCP连接申请的具体实现方法请参阅以下第步;对基础数据流进行写操作,从而实现向远程主机传送文本数据的方法请参阅以下第步。下面客户端程序的具体实现步骤:
1. 启动Visual Studio .Net。
2. 选择菜单【文件】|【新建】|【项目】后,弹出【新建项目】对话框。
3. 将【项目类型】设置为【Visual Basic项目】。
4. 将【模板】设置为【Windows应用程序】。
5. 在【名称】文本框中输入【客户端程序】。
6. 在【位置】的文本框中输入【E:\VS.NET项目】,然后单击【确定】按钮,这样在"E:\VS.NET项目"目录中就产生了名称为"客户端程序"的文件夹,并在里面创建了名称为"客户端程序"的项目文件。
7. 把Visual Studio .Net的当前窗口切换到【Form1.vb(设计)】窗口,并从【工具箱】中的【Windows窗体组件】选项卡中往Form1窗体中拖入下列组件,并执行相应的操作:
二个Label组件。
二个TextBox组件。
一个StatusBar组件。
二个Button组件,并在这二个Button组件拖入Form1的设计窗体后,双击它们,则系统会在Form1.vb文件分别产生这二个组件的Click事件对应的处理代码。
8. 按照表01所示调整窗体中各组件属性的数值:
组件类型 组件名称 属性 设置结果 Form Form1 Text 客户端程序 Form1 MaximizeBox False Form1 FormBorderStyle FixedSingle Button Button1 Text 连接 Button1 FlatStyle Flat Button2 Text 发送 Button2 FlatStyle Flat Label Label1 Text 服务器IP地址: Label2 Text 信息: StatusBar StatusBar1 Text 无连接! TextBox TextBox1 Text "" TextBox1 BorderStyle FixedSingle TextBox2 Text "" TextBox2 BorderStyle FixedSingle。
表06:【客户端程序】项目中组件设定数值表。
有任何疑问请追问,满意请采纳,谢谢。
服务端:
class mTcpServer。
class server。
{
/// <summary>。
/// 应用程序的主入口点。
/// </summary>。
[STAThread]。
static void Main(string[] args)。
{
Thread newThread;。
try。
{ 。
serverTcpListener = new TcpListener(localAddr, port);。
serverTcpListener.Start();。
while (true)。
{。
Console.Write("Waiting for a connection... ");。
client = serverTcpListener.AcceptTcpClient();。
Console.WriteLine("Connected!");。
newThread = new Thread(new ThreadStart(newScream));。
newThread.Start();。
}。
}
catch (SocketException e)。
{
Console.WriteLine("SocketException: {0}", e);。
}
finally。
{
// Stop listening for new clients.。
Console.WriteLine("Stop listening for new clients");。
serverTcpListener.Stop();。
}
Console.WriteLine("\nHit enter to continue...");。
Console.Read();。
}
static Int32 port = 9050;。
static IPAddress localAddr = IPAddress.Parse("127.0.0.1");。
static TcpListener serverTcpListener = null;。
static Byte[] bytes = new Byte[256];。
static String data = null;。
static TcpClient client;。
static void newScream()。
{
data = null;。
NetworkStream stream = client.GetStream();。
stream.Write(Encoding.ASCII.GetBytes("Connected!"), 0, 10);。
int i;。
while ((i = stream.Read(bytes, 0, bytes.Length)) != 0)。
{
data = System.Text.Encoding.ASCII.GetString(bytes, 0, i);。
Console.WriteLine("Received: {0}", data);。
data = data.ToUpper();。
byte[] msg = System.Text.Encoding.ASCII.GetBytes(data);。
stream.Write(msg, 0, msg.Length);。
Console.WriteLine("Sent: {0}", data);。
}
}
}
客户端:
using System;
using System.Net;。
using System.Net.Sockets;。
using System.Text;。
namespace mTcpClint。
/// <summary>。
/// Class1 的摘要说明。
/// </summary>。
class client。
{
/// <summary>。
/// 应用程序的主入口点。
/// </summary>。
[STAThread]。
static void Main(string[] args)。
{
//
// TODO: 在此处添加代码以启动应用程序。
//
byte[] data = new byte[1024];。
//Socket newclient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);。
Console.Write("please input the server ip:");。
string ipadd = Console.ReadLine();。
Console.WriteLine();。
Console.Write("please input the server port:");。
int port = Convert.ToInt32(Console.ReadLine());。
IPEndPoint ie = new IPEndPoint(IPAddress.Parse(ipadd), port);//服务器的IP和端口。
TcpClient newclient;。
newclient = new TcpClient();。
newclient.Connect(ipadd, port);。
int recv = newclient.Client.Receive(data);。
string stringdata = Encoding.ASCII.GetString(data, 0, recv);。
Console.WriteLine(stringdata);。
while (true)。
{
string input = Console.ReadLine();。
if (input == "exit") break;。
newclient.Client.Send(Encoding.ASCII.GetBytes(input));。
data = new byte[1024];。
recv = newclient.Client.Receive(data);。
stringdata = Encoding.ASCII.GetString(data, 0, recv);。
Console.WriteLine(stringdata);。
}
Console.WriteLine("disconnect from server");。
newclient.Client.Shutdown(SocketShutdown.Both);。
newclient.Close();。
}
}
这是我以前在学校的时候做的一个c/s系统里面的类似qq聊天工具。
你看看。。
这是客服端的代码:
using System;
using System.Collections.Generic;。
using System.ComponentModel;。
using System.Data;。
using System.Drawing;。
using System.Linq;。
using System.Text;。
using System.Windows.Forms;。
using System.Threading;。
using System.Net;。
using System.Net.Sockets;。
namespace demo2。
public partial class frmTouchWe : Form。
{
Thread a;。
//发送IP跟端口。
private UdpClient udp = new UdpClient("127.0.0.1",9000);。
//接收端口
private UdpClient udpSend = new UdpClient(8000);。
private IPEndPoint ip = new IPEndPoint(IPAddress.Any,0);。
public frmTouchWe()。
{
InitializeComponent();。
Form.CheckForIllegalCrossThreadCalls = false;。
}
private void frmTouchWe_Load(object sender, EventArgs e)。
{ //定义线程开始。
a = new Thread(new ThreadStart(Run));。
a.Start(); }。
private void linkLabel1_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)。
{
//客服接收信息。弹出窗体。
frmAnswerInfo answerInfo = new frmAnswerInfo();。
answerInfo.Show(); }。
private void button1_Click(object sender, EventArgs e)。
{
//在自己的信息栏中显示自己的信息。
lsbInfo.Items.Add(txtInfo.Text);。
//用户信息内容。
string Mes = txtInfo.Text;。
//用户信息。
string mes = "用户:"+Program.user.id+"("+Program.user.name+")"+" " + time;。
//转换成字节。
byte[] b = UTF8Encoding.UTF8.GetBytes(Mes);。
byte[] bb = UTF32Encoding.UTF8.GetBytes(mes);。
//发送信息。
udp.Send(bb, bb.Length);。
udp.Send(b, b.Length);。
txtInfo.Text = "";。
}
//循环接受客服发来的信息。
private void Run()。
{
while (true)。
{
byte[] b = udpSend.Receive(ref ip);。
string mes = UTF8Encoding.UTF8.GetString(b);。
lsbInfo.Items.Add(mes);。
}
}
private void button2_Click(object sender, EventArgs e)。
{
this.Close();。
}
private void button3_Click_1(object sender, EventArgs e)。
{
//清空所有项。
lsbInfo.Items.Clear();。
}
}
下面是服务器端的代码
using System;
using System.Collections.Generic;。
using System.ComponentModel;。
using System.Data;。
using System.Drawing;。
using System.Linq;。
using System.Text;。
using System.Windows.Forms;。
using System.Threading;。
using System.Net;。
using System.Net.Sockets;。
namespace demo2。
public partial class frmAnswerInfo : Form。
{
//定义一条线程,用来循环接收客户发来的信息。
Thread a;。
//定义另一条线程,用来升起窗体。
Thread b;。
//发送到信息的地址。
private UdpClient udpSend = new UdpClient("127.0.0.1",8000);。
//接收端口
private UdpClient udp = new UdpClient(9000);。
private IPEndPoint ip = new IPEndPoint(IPAddress.Any,0);。
public frmAnswerInfo()。
{
InitializeComponent();。
Form.CheckForIllegalCrossThreadCalls = false;。
}
//循环接收信息。
private void Run()。
{
while (true)。
{
byte[] b = udp.Receive(ref ip);。
string mes = UTF8Encoding.UTF8.GetString(b);。
lsbInfo.Items.Add(mes);。
}
}
private void frmAnswerInfo_Load(object sender, EventArgs e)。
{
//设置窗体的位置属性(窗体加载时候慢慢从右下角升上来~类似qq广告~~)。
this.Top = Screen.PrimaryScreen.WorkingArea.Height;。
this.Left = Screen.PrimaryScreen.WorkingArea.Width - this.Width;。
//设置窗体的名字 。
a = new Thread(new ThreadStart(Run));。
b = new Thread(new ThreadStart(run));。
//开始线程。
a.Start();。
b.Start();。
}
//用户点击谈话时显示该窗体。
private void run()。
{
while (true)。
{
this.Top = this.Top - 10;。
Thread.Sleep(100);。
if (Screen.PrimaryScreen.WorkingArea.Height - this.Height >= this.Top)。
{。
break;。
}。
}
}
//发送按钮编码。
private void button1_Click(object sender, EventArgs e)。
{
//获取当前时间。
DateTime time = DateTime.Now;。
//在自己的信息栏中显示自己发出去的信息。
lsbInfo.Items.Add("在线客服:"+time);。
lsbInfo.Items.Add(txtInfo.Text);。
//在客户端显示自己的信息标题。
string mes = "在线客服:"+time;。
//信息内容。
string Mes = txtInfo.Text;。
//发送信息标题。
byte[] b = UTF8Encoding.UTF8.GetBytes(mes);。
//发送信息内容。
byte[] bb = UTF8Encoding.UTF8.GetBytes(Mes);。
udpSend.Send(b, b.Length);。
udpSend.Send(bb,bb.Length);。
txtInfo.Text = "";。
}
private void button2_Click(object sender, EventArgs e)。
{
this.Close();。
}
private void button3_Click(object sender, EventArgs e)。
{
//清除所有项。
lsbInfo.Items.Clear();。
}
}
这个可以跑的。。我以前就用过的。