using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
namespace NBC.Test.ObjectModel
{
///
/// 组播通信类
///
public class SocketUDP
{
///
/// 组播模式发送信息
///
///
public void SendMessage(object obj)
{
//定义消息格式
//日期_/时间_/活动时长_/指标_/出课教师_/班级_/学科_/课题_/ClassID
ActivityObject mess &＃61; ((OperateObject)obj).AcObject;//此代码是我自定义的消息对象&＃xff0c;使用时可按照自己需求从新定义
IPAddress GroupAddress &＃61; IPAddress.Parse("234.168.100.2"); //此IP值为固定区间 详情请查询msdn
int GroupPort &＃61; 11000;
UdpClient sender &＃61; new UdpClient();
IPEndPoint groupEP &＃61; new IPEndPoint(GroupAddress, GroupPort);
sender.EnableBroadcast &＃61; true;
try
{
byte[] bytes &＃61; UTF8Encoding.UTF8.GetBytes(mess.Date &＃43; "_/" &＃43; mess.Time &＃43; "_/" &＃43; mess.ActivityLength &＃43; "_/" &＃43; mess.Index &＃43; "_/" &＃43; mess.Techer &＃43; "_/" &＃43; mess.Grade &＃43; "_/" &＃43; mess.Subject &＃43; "_/" &＃43; mess.Project &＃43; "_/" &＃43; mess.ClassID);
sender.Send(bytes, bytes.Length, groupEP);
//sender.Close();
}
catch
{
}
}
//创建一个UdpClient实例
private Socket udpReceive;
///
/// 接收组播信息
///
private void ReceiveMessage()
{
try
{
string maddress &＃61; "234.168.100.2";
int listenport &＃61; 11000;
string localip &＃61; getIPAddress();
IPEndPoint ipe &＃61; new IPEndPoint(IPAddress.Parse(localip), listenport);
udpReceive &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
EndPoint ep &＃61; (EndPoint)ipe;
udpReceive.Bind(ipe);
udpReceive.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(IPAddress.Parse(maddress)));
while (true)
{
byte[] b &＃61; new byte[1024];
udpReceive.ReceiveFrom(b, ref ep);
string str &＃61; UTF8Encoding.UTF8.GetString(b);
string message &＃61; "来自" &＃43; ep.ToString() &＃43; "消息";
//DialogResult res &＃61; MessageBox.Show(str, message);
}
}
catch (Exception ex)
{
}
}
///
/// 获取本地IP
///
///
private string getIPAddress()
{
// 获得本机局域网IP地址
IPAddress[] AddressList &＃61; Dns.GetHostByName(Dns.GetHostName()).AddressList;
if (AddressList.Length <1)
{
return "";
}
return AddressList[0].ToString();
}
}
}
京公网安备 11010802041100号