c# socket传输struct类型
2015-10-29 17:06
197 查看
data结构体类型
public struct datas
{
public string test1;
public string test2;
}
//socket服务器端
public void SocketServer()
{
Socket listener = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);
listener.Bind(new IPEndPoint(getLocalmachineIPAddress(), 2323));
listener.Listen(10);
while (true)
{
Socket socket = listener.Accept();
string receivedValue = string.Empty;
while (true)
{
byte[] receivedBytes = new byte[1024];
int numBytes = socket.Receive(receivedBytes);
Console.WriteLine("Receiving .");
receivedValue += Encoding.ASCII.GetString(receivedBytes,
0, numBytes);
if (receivedValue.IndexOf("[FINAL]") > -1)
{
break;
}
}
byte[] buffer = new byte[1024000];
if (receivedValue.Contains("get gateway rooms"))
{
MemoryStream mStream = new MemoryStream();
BinaryFormatter bf = new BinaryFormatter();
datas sendData;
sendData.m_DictRooms = FormMain.DictRooms;
sendData.m_DictRoomNameText = FormMain.DictRoomNameText;
bf.Serialize(mStream, sendData);
mStream.Flush();
mStream.Position = 0;
mStream.Read(buffer, 0, buffer.Length);
}
//string replyValue = "Message successfully received.";
//byte[] replyMessage = Encoding.ASCII.GetBytes(replyValue);
socket.Send(buffer);
socket.Shutdown(SocketShutdown.Both);
socket.Close();
}
listener.Close();
}
//socket客户端
private void socketClient(object sender, EventArgs e)
{
if (comboBoxGateway.SelectedItem != null)
{
byte[] receivedBytes = new byte[1024000];
IPHostEntry ipHost = Dns.Resolve(comboBoxGateway.SelectedItem.ToString());
IPAddress ipAddress = ipHost.AddressList[0];
IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, 2323);
Socket sk = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);
sk.Connect(ipEndPoint);
string sendingMessage = "get gateway rooms";
byte[] forwardMessage = Encoding.ASCII.GetBytes(sendingMessage
+ "[FINAL]");
sk.Send(forwardMessage);
int totalBytesReceived = sk.Receive(receivedBytes);
MemoryStream mStream = new MemoryStream();
//ReceiveDatas = bf.Deserialize(receivedBytes,mStream );
mStream.Write(receivedBytes, 0, receivedBytes.Length);
mStream.Flush();
mStream.Position = 0;
BinaryFormatter bf = new BinaryFormatter();
if (mStream.Capacity > 0)
{
datas receiveDatas = (datas)bf.Deserialize(mStream);
}
sk.Shutdown(SocketShutdown.Both);
sk.Close();
//加载新选择的网关房间
InitializeSelectRoomsTab();
}
}
public struct datas
{
public string test1;
public string test2;
}
//socket服务器端
public void SocketServer()
{
Socket listener = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);
listener.Bind(new IPEndPoint(getLocalmachineIPAddress(), 2323));
listener.Listen(10);
while (true)
{
Socket socket = listener.Accept();
string receivedValue = string.Empty;
while (true)
{
byte[] receivedBytes = new byte[1024];
int numBytes = socket.Receive(receivedBytes);
Console.WriteLine("Receiving .");
receivedValue += Encoding.ASCII.GetString(receivedBytes,
0, numBytes);
if (receivedValue.IndexOf("[FINAL]") > -1)
{
break;
}
}
byte[] buffer = new byte[1024000];
if (receivedValue.Contains("get gateway rooms"))
{
MemoryStream mStream = new MemoryStream();
BinaryFormatter bf = new BinaryFormatter();
datas sendData;
sendData.m_DictRooms = FormMain.DictRooms;
sendData.m_DictRoomNameText = FormMain.DictRoomNameText;
bf.Serialize(mStream, sendData);
mStream.Flush();
mStream.Position = 0;
mStream.Read(buffer, 0, buffer.Length);
}
//string replyValue = "Message successfully received.";
//byte[] replyMessage = Encoding.ASCII.GetBytes(replyValue);
socket.Send(buffer);
socket.Shutdown(SocketShutdown.Both);
socket.Close();
}
listener.Close();
}
//socket客户端
private void socketClient(object sender, EventArgs e)
{
if (comboBoxGateway.SelectedItem != null)
{
byte[] receivedBytes = new byte[1024000];
IPHostEntry ipHost = Dns.Resolve(comboBoxGateway.SelectedItem.ToString());
IPAddress ipAddress = ipHost.AddressList[0];
IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, 2323);
Socket sk = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);
sk.Connect(ipEndPoint);
string sendingMessage = "get gateway rooms";
byte[] forwardMessage = Encoding.ASCII.GetBytes(sendingMessage
+ "[FINAL]");
sk.Send(forwardMessage);
int totalBytesReceived = sk.Receive(receivedBytes);
MemoryStream mStream = new MemoryStream();
//ReceiveDatas = bf.Deserialize(receivedBytes,mStream );
mStream.Write(receivedBytes, 0, receivedBytes.Length);
mStream.Flush();
mStream.Position = 0;
BinaryFormatter bf = new BinaryFormatter();
if (mStream.Capacity > 0)
{
datas receiveDatas = (datas)bf.Deserialize(mStream);
}
sk.Shutdown(SocketShutdown.Both);
sk.Close();
//加载新选择的网关房间
InitializeSelectRoomsTab();
}
}
相关文章推荐
- C#删除WebBrowser控件Session
- C#语法之函数
- VS 通过 附加进程的方式来调试 C#服务程序
- c#语句
- c#正则表达式--环视
- C#实现图片文件到数据流再到图片文件的转换 --转
- C# 给PDF文件添加水印
- C#状态模式——解决方法过长问题
- 揭开你的面纱----C#.net初识
- C# ListBox 控件
- c# combobox属性dropdownlist赋值
- (转自博客园-雲霏霏)5天玩转C#并行和多线程编程 —— 第三天 认识和使用Task
- c# 开发CAD 只初始化窗口一次,并修改其内的数据
- C# ListView用法详解
- C# 之 DataReader 和 DataSet 的区别
- winform 自定义控件-按钮
- C#获取当前页面的url
- C# 检测程序是否已经运行
- C#实现Excel模板导出和从Excel导入数据
- C#中get和set