直接上例子，学习资料来自NET之美。服务端创建Listener对象，客户端创建Client对象，服务端首先开始对本地端口监听，客户端发送连接请求。当需要传输字符串时，两者均需要创建Stream对象，将想说的话，写在这片小红叶上，小红叶就飞到对方哪里了。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
using System.Net;
using System.Net.Sockets;
using System.IO;
namespace ConsoleTest
{
class Server
{
static void Main(string [] args)
{
Console.WriteLine("Server is running");
const int buffersize =6;
IPAddress ip = IPAddress.Parse("127.0.0.1");
//IPAddress ip = Dns.GetHostEntry(Dns.GetHostName()).AddressList[0];
TcpListener listener = new TcpListener(ip,8500);
listener.Start();
TcpClient remoteclient = listener.AcceptTcpClient();//同步方法，读取同意客户端多个信息
Console.WriteLine("Client{0} connects to--->Server{1}", remoteclient.Client.RemoteEndPoint, remoteclient.Client.LocalEndPoint);
NetworkStream streamToClient = remoteclient.GetStream();
do
{ //read data
try {//防止客户端阻塞在read()方法处，要把命令写在try catch中
byte[] buffer = new byte[buffersize];
MemoryStream ms = new MemoryStream();
int byteread;
byteread = streamToClient.Read(buffer, 0, buffersize);
if (byteread == 0)//客户端调用Close()和Dispose()方法时，服务端的Read()方法会持续返回0
{ Console.WriteLine("Client Offline"); break; }
string msg = Encoding.Unicode.GetString(buffer, 0, buffersize);
Console.WriteLine("Recieve:{0}[{1}Bytes]", msg, byteread);
//send data
msg = msg.ToUpper();
Console.WriteLine("send:{0}", msg);
buffer = Encoding.Unicode.GetBytes(msg);
streamToClient.Write(buffer, 0, buffer.Length);}
catch (Exception ex)
{
Console.WriteLine(ex.Message);break;
}
} while (true);
streamToClient.Dispose();
remoteclient.Close();
//按Q退出
ConsoleKey key;
do
{
key = Console.ReadKey(true).Key;
} while (key != ConsoleKey.Q);
}
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
namespace Client
{
class Client
{
static void Main(string[] args)
{
Console.WriteLine("Client is running");
const int buffersize = 6;
TcpClient client;
try {
client = new TcpClient();
IPAddress ip = IPAddress.Parse("127.0.0.1");
//IPAddress ip = Dns.GetHostEntry(Dns.GetHostName()).AddressList[0];
client.Connect(ip,8500);
}
catch(Exception ex) { Console.WriteLine(ex.Message);
return;
}
Console.WriteLine("Client{0} connects to--->Server{1}", client.Client.RemoteEndPoint, client.Client.LocalEndPoint);
NetworkStream streamToServer = client.GetStream();
string msg;
do
{ //read data from screen
Console.WriteLine("Sent:");
msg= Console.ReadLine();
if(!string.IsNullOrEmpty(msg)&& msg != "Q")
{
byte[] buffer = Encoding.Unicode.GetBytes(msg);
try
{
streamToServer.Write(buffer, 0,buffer.Length);//send
int bytesread;
buffer = new byte[buffersize];
//recieve
bytesread=streamToServer.Read(buffer, 0, buffersize);
if (bytesread == 0) { Console.WriteLine("Server is offline");break; }
msg = Encoding.Unicode.GetString(buffer,0, bytesread);
Console.WriteLine("Recieved:{0} [{1}]",msg,bytesread);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message); break;
}
}
} while (msg != "Q");
streamToServer.Dispose();
client.Close();
}
}
}