C#的tcp ip简单例子

tcp server

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;

namespace tcpServer
{
public partial class Form1 : Form
{
public TcpListener myListener;
public TcpClient newClient;
public BinaryReader br;
public BinaryWriter bw;
public int i;
public Form1()
{
InitializeComponent();
}
/// <summary>
/// 等待客户端的连接并且创建与之通信的Socket
/// </summary>
Socket socketSend;
Socket socketWatch;
void Listen(object o)
{
try
{
//Socket socketWatch = o as Socket;
//while (true)
//{
socketSend = socketWatch.Accept();//等待接收客户端连接
ShowMsg(socketSend.RemoteEndPoint.ToString() + ":" + "连接成功!");
//开启一个新线程，执行接收消息方法
Thread r_thread = new Thread(Received);
r_thread.IsBackground = true;
r_thread.Start();
//}
}
catch { }
}
/// <summary>
/// 服务器端不停的接收客户端发来的消息
/// </summary>
/// <param name="o"></param>
void Received(object o)
{
try
{
//Socket socketSend = o as Socket;
while (true)
{
//客户端连接服务器成功后，服务器接收客户端发送的消息
byte[] buffer = new byte[1024 * 1024 * 3];
//实际接收到的有效字节数
int len = socketSend.Receive(buffer);
if (len == 0)
{
break;
}
string str = Encoding.UTF8.GetString(buffer, 0, len);
ShowMsg(socketSend.RemoteEndPoint + ":" + str);
if (str=="1")
{
i = i + 1;
textBox1.Text = i.ToString();
button3.PerformClick();
if(i>10){
i = 0;
}
}
}
}
catch { }
}
/// <summary>
/// 服务器向客户端发送消息
/// </summary>
/// <param name="str"></param>
void Send(string str)
{
byte[] buffer = Encoding.UTF8.GetBytes(str);
socketSend.Send(buffer);
}

void ShowMsg(string msg)
{
richTextBox1.AppendText(msg + "\r\n");
}
void ShowNotice(string str)
{
textBox3.AppendText(str + "\r\n");
}
private void button1_Click(object sender, EventArgs e)
{
try
{
//点击开始监听时在服务端创建一个负责监听IP和端口号的Socket
socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socketSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPAddress ip = IPAddress.Parse("127.0.0.1");//任意ip地址都可以
//创建对象端口
IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(textBox2.Text));
socketWatch.Bind(point);//绑定端口号
ShowNotice("监听成功!");
socketWatch.Listen(10);//设置监听

//创建监听线程
Thread thread = new Thread(Listen);
thread.IsBackground = true;
thread.Start();
}
catch { }

}

private void button2_Click(object sender, EventArgs e)
{
Send(richTextBox2.Text.Trim());
}

private void Form1_Load_1(object sender, EventArgs e)
{
Control.CheckForIllegalCrossThreadCalls = false;
}
}

}

tcp client

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using System.Windows;
using System.Collections;

namespace tcpClient
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
Socket socketSend;

/// <summary>
/// 向服务器发送消息
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>

private void Form1_Load(object sender, EventArgs e)
{
Control.CheckForIllegalCrossThreadCalls = false;

}

private void button2_Click(object sender, EventArgs e)
{
//MessageBox.Show(Environment.CurrentDirectory.ToString());
send(textBox3.Text.Trim());
}

private void button1_Click(object sender, EventArgs e)
{
try
{
//创建客户端Socket，获得远程ip和端口号
socketSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPAddress ip = IPAddress.Parse("127.0.0.1");
IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(textBox1.Text));
socketSend.Connect(point);
ShowNotice("连接成功!");
//开启新的线程，不停的接收服务器发来的消息
Thread c_thread = new Thread(Received);
c_thread.IsBackground = true;
c_thread.Start();
}
catch (Exception)
{
ShowNotice("IP或者端口号错误...");
}

}
void ShowMsg(string str)
{
richTextBox1.AppendText(str + "\r\n");
}
void ShowNotice(string str)
{
textBox4.AppendText(str + "\r\n");
}
void send(string msg)
{
try
{
byte[] buffer = new byte[1024 * 1024 * 3];
buffer = Encoding.UTF8.GetBytes(msg);
socketSend.Send(buffer);
}
catch { }
}
/// <summary>
/// 接收服务端返回的消息
/// </summary>
void Received()
{
while (true)
{
try
{
byte[] buffer = new byte[1024 * 1024 * 3];
//实际接收到的有效字节数
int len = socketSend.Receive(buffer);
if (len == 0)
{
break;
}
string str = Encoding.UTF8.GetString(buffer, 0, len);
ShowMsg(socketSend.RemoteEndPoint + ":" + str);
}
catch { }
}
}

private void button3_Click(object sender, EventArgs e)
{
int a=Convert.ToInt16(textBox2.Text);
if (a==-1)
{
MessageBox.Show(a.ToString());
}

}
}
}

C#的tcp ip简单例子

猜你喜欢