C# Winform 实现TCP发消息

当前位置:

首页 > temp > C#教程 >

C# Winform 实现TCP发消息

这篇文章主要介绍了C# Winform 实现TCP发消息的示例，帮助大家更好的理解和学习使用c#技术，感兴趣的朋友可以了解下

服务端：

窗体

代码：

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

using System;

using System.Collections.Generic;

using System.IO;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

using System.Windows.Forms;

namespace SocketStudy

{

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

}

/// <summary>

/// 负责通信的socket

/// </summary>

Socket socketSend;

/// <summary>

/// 负责监听Socket

/// </summary>

Socket socket;

/// <summary>

/// 存放连接的socket

/// </summary>

Dictionary<string, Socket> dictionary = new Dictionary<string, Socket>();

/// <summary>

/// 开始监听

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void button1_Click(object sender, EventArgs e)

{

//创建监听的socket,

//SocketType.Stream 流式对应tcp协议

//Dgram,数据报对应UDP协议

socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

//创建IP地址和端口号

IPAddress ip = IPAddress.Any;//IPAddress.Parse(textServerIP.Text);

int port = Convert.ToInt32(textServerPort.Text);

IPEndPoint iPEndPoint = new IPEndPoint(ip, port);

//让负责监听的Socket绑定ip和端口号

socket.Bind(iPEndPoint);

ShowLog("监听成功！" + ip + "\t" + port);//打印日志

//设置监听队列

socket.Listen(10);//一段时间内可以连接到的服务器的最大数量

Thread thread = new Thread(Listen);

thread.IsBackground = true;

thread.Start(socket);

}

/// <summary>

/// 使用线程来接收数据

/// </summary>

/// <param name="o"></param>

private void Listen(object o)

{

Socket socket = o as Socket;

while(true){

//负责监听的socket是用来接收客户端连接

//创建负责通信的socket

socketSend = socket.Accept();

dictionary.Add(socketSend.RemoteEndPoint.ToString(), socketSend);

clientCombo.Items.Add(socketSend.RemoteEndPoint.ToString());

ShowLog(socketSend.RemoteEndPoint.ToString() + "已连接");

//开启新线程，接收客户端发来的信息

Thread th = new Thread(receive);

th.IsBackground = true;

th.Start(socketSend);

}

//服务器接收客户端传来的消息

private void receive(object o)

{

Socket socketSend = o as Socket;

while (true)

{

try

{

//客户端连接成功后，服务器接收客户端发来的消息

byte[] buffer = new byte[1024 * 1024 * 2];//2M大小

//接收到的有效字节数

int length = socketSend.Receive(buffer);

if (length == 0)

{

ShowLog(socketSend.RemoteEndPoint.ToString() + "下线了。");

dictionary[socketSend.RemoteEndPoint.ToString()].Shutdown(SocketShutdown.Both);

dictionary[socketSend.RemoteEndPoint.ToString()].Disconnect(false);

dictionary[socketSend.RemoteEndPoint.ToString()].Close();

break;

}

string str = Encoding.ASCII.GetString(buffer, 0, length);

ShowLog(socketSend.RemoteEndPoint.ToString() + "\n\t" + str);

}

catch (Exception ex)

{

Console.WriteLine(ex.Message);

}

/// <summary>

/// 日志打印

/// </summary>

/// <param name="str"></param>

private void ShowLog(string str)

{

textLog.AppendText(str + "\r\n");

}

private void Form1_Load(object sender, EventArgs e)

{

//取消对跨线程调用而产生的错误

Control.CheckForIllegalCrossThreadCalls = false;

}

private void sendMsgBtn_Click(object sender, EventArgs e)

{

string txt = textMsg.Text;

byte[] buffer = Encoding.UTF8.GetBytes(txt);

List<byte> list = new List<byte>();

list.Add(0); // 0 为发消息

list.AddRange(buffer);

byte[] newBuffer = list.ToArray();

//socketSend.Send(buffer);

string ip = clientCombo.SelectedItem.ToString();//获取选中的ip地址

Socket socketsend=dictionary[ip];

socketsend.Send(newBuffer);

}

private void selectBtn_Click(object sender, EventArgs e)

{

OpenFileDialog fileDialog = new OpenFileDialog();

fileDialog.InitialDirectory=@"D:";

fileDialog.Title="选择文件";

fileDialog.Filter = "所有文件|*.*";

fileDialog.ShowDialog();

pathTxt.Text = fileDialog.FileName;

}

/// <summary>

/// 发文件，

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void sendFileBtn_Click(object sender, EventArgs e)

{

string path = pathTxt.Text;

FileStream fileStream = new FileStream(path,FileMode.Open,FileAccess.Read);

byte[] buffer = new byte[1024*1024*3];

buffer[0] = 1;// 1 为发文件的标志位

int length = fileStream.Read(buffer, 1, buffer.Length-1);

fileStream.Close();

string ip = clientCombo.SelectedItem.ToString();//获取选中的ip地址

Socket socketsend = dictionary[ip];

socketsend.Send(buffer,0, length+1, SocketFlags.None);

}

/// <summary>

/// 抖一抖

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void shockBtn_Click(object sender, EventArgs e)

{

byte[] buffer = new byte[1];

buffer[0] = 2;// 2 为抖一抖

string ip = clientCombo.SelectedItem.ToString();//获取选中的ip地址

Socket socketsend = dictionary[ip];

socketsend.Send(buffer);

}

/// <summary>

/// 关闭前关闭socket

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void Form1_FormClosing(object sender, FormClosingEventArgs e)

{

try

{

socket.Shutdown(SocketShutdown.Both);

socket.Disconnect(false);

socket.Close();

}

catch

{

socket.Close();

}

客户端：

窗体

代码

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

using System;

using System.Collections.Generic;

using System.IO;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

using System.Windows.Forms;

namespace Client

{

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

}

Socket socket;<br>　　　　　　//连接

private void connectBtn_Click(object sender, EventArgs e)

{

try

{

//创建负责通信的socket

socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

//地址、端口

IPAddress ip = IPAddress.Parse(ipText.Text);

int serverPort = Convert.ToInt32(portText.Text);

IPEndPoint port = new IPEndPoint(ip, serverPort);

//连接到服务器

socket.Connect(port);

ShowLog("已连接");

//启动接收数据线程

Thread th = new Thread(receive);

th.IsBackground = true;

th.Start();

}

catch { }

}<br>　　　　//日志

private void ShowLog(string str)

{

textLog.AppendText(str + "\r\n");

}

/// <summary>

/// 发消息

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void sendMsgBtn_Click(object sender, EventArgs e)

{

try

{

string txt = sendMsg.Text;

byte[] buffer = Encoding.ASCII.GetBytes(txt);//ascii编码

socket.Send(buffer);

}

catch { }

}

　　　　<br>　　　　//接收消息<br>

private void receive()

{

while (true)

{

try

{

byte[] buffer = new byte[1024 * 1024 * 2];

int length = socket.Receive(buffer);

if (length == 0)

{

break;

}

if (buffer[0] == 0)

{

string txt = Encoding.UTF8.GetString(buffer, 1, length-1);

ShowLog(socket.RemoteEndPoint + ":\r\t" + txt);

}else if (buffer[0] == 1)

{

SaveFileDialog saveFileDialog = new SaveFileDialog();

saveFileDialog.InitialDirectory = @"E:\";

saveFileDialog.Title = "饿了吃什么";

saveFileDialog.Filter = "所有文件 | *.*";

saveFileDialog.ShowDialog(this);

string path = saveFileDialog.FileName;

FileStream fileStreamWrite = new FileStream(path, FileMode.OpenOrCreate, FileAccess.Write);

fileStreamWrite.Write(buffer,1,length-1);

fileStreamWrite.Close();

MessageBox.Show("保存成功");

}else if (buffer[0] == 2)

{

ZD();

}

catch { }

}

　　　　　　//震动

private void ZD()

{

for(int i=0;i<20;i++){

if (i%2==0)

{

this.Location = new System.Drawing.Point(500, 500);

}

else

{

this.Location = new System.Drawing.Point(530, 530);

}

Thread.Sleep(20);

}

　　　　//取消跨线程检查

private void Form1_Load(object sender, EventArgs e)

{

Control.CheckForIllegalCrossThreadCalls = false;

}

　　　　//关闭前关掉socket

private void Form1_FormClosing(object sender, FormClosingEventArgs e)

{

socket.Disconnect(false);

socket.Close();

}

　　　　　　//断开连接

private void button1_Click(object sender, EventArgs e)

{

if (socket !=null)

{

socket.Disconnect(false);

}

运行结果：

以上就是C# Winform 实现TCP发消息的详细内容

原文链接：https://www.cnblogs.com/FlyonGrass/p/14068311.html

栏目列表