0

我想通过调用另一种方法向订阅者（订阅者 ip 地址在服务器端的数据库中）发送通知（比如字符串）。每当我调用该方法时，输出都会出错。

[WebMethod]
public string GetGroupPath(string emailAddress, string password, string ipAddress)
{
    //SqlDataAdapter dbadapter = null;
    DataSet returnDS = new DataSet();
    string groupName = null;
    string groupPath = null;

    SqlConnection dbconn = new SqlConnection("Server = localhost;Database=server;User ID = admin;Password = password;Trusted_Connection=false;");

    dbconn.Open();

    SqlCommand cmd = new SqlCommand();
    string getGroupName = "select users.groupname from users where emailaddress = "+"'"+ emailAddress+"'"+ " and "+ "users.password = " + "'" +password+"'";
    cmd.CommandText = getGroupName;
    cmd.Connection = dbconn;
    SqlDataReader reader = null;
    try
    {
        reader = cmd.ExecuteReader();
        while (reader.Read())
        {
            groupName = reader["groupname"].ToString();
        }
    }
    catch (Exception)
    {
        groupPath = "Invalied";
    }


    dbconn.Close();
    dbconn.Open();

    if (groupName != null)
    {
        string getPath = "select groups.grouppath from groups where groupname = " + "'" + groupName + "'";
        cmd.CommandText = getPath;
        cmd.Connection = dbconn;

        try
        {
            reader = cmd.ExecuteReader();
            while (reader.Read())
            {
                groupPath = reader["grouppath"].ToString();
            }
        }
        catch
        {
            groupPath = "Invalied";
        }
    }
    else
        groupPath = "Invalied";
    dbconn.Close();


    if (groupPath != "Invalied") 
    {
        dbconn.Open();
        string getPath = "update users set users.ipaddress = "+"'"+ipAddress+"'"+" where users.emailaddress = " + "'" + emailAddress + "'";
        cmd.CommandText = getPath;
        cmd.Connection = dbconn; 
        cmd.ExecuteNonQuery();
        dbconn.Close();

    }

    NotifyUsers();
    //NotifyUsers nu = new NotifyUsers();
    //List<string> ipList = new List<string>();
    //ipList.Add("192.168.56.1");

    //nu.Notify();

    return groupPath;
}

private void NotifyUsers() 
{
    Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
    byte[] ipb = Encoding.ASCII.GetBytes("255.255.255.255");
    IPAddress ipAddress = new IPAddress(ipb);

    IPEndPoint endPoint = new IPEndPoint(ipAddress, 15000);
    string notification = "new_update";
    byte[] sendBuffer = Encoding.ASCII.GetBytes(notification);
    sock.SendTo(sendBuffer, endPoint);
    sock.Close();  
}

这是基本上必须要做的。在服务器端，我有一个监听线程，当服务器发送数据时它会收到通知（假设现在数据库包含客户端 IP 地址）。然后我调用 web 方法，它给出了一个错误“invalid IPAddress”atline

byte[] ipb = Encoding.ASCII.GetBytes("255.255.255.255");

谢谢 :) 因为这是我的第一篇文章，请善意地给我一个更好的反馈 :) 谢谢

4

2 回答 2

1

在通知中尝试以下代码，然后禁用防火墙设置...

try
{
    // Establish the remote endpoint for the socket.

    // This example uses port 11000 on the local computer.
    IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName())

    Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);

    IPAddress ipAddress = ipHostInfo.AddressList[0];
    IPEndPoint remoteEP = new IPEndPoint(ipAddress,15000);
    string notification = "new_update";
    byte[] sendBuffer = Encoding.ASCII.GetBytes(notification);
    sock.SendTo(sendBuffer, remoteEP );
    sock.Close();  
}
catch() {}

希望这能解决问题。

于 2012-05-31T10:32:40.977 回答
1

只是想补充一下

byte[] ipb = Encoding.ASCII.GetBytes("255.255.255.255");
IPAddress ipAddress = new IPAddress(ipb);

可以简化为

IPAddress.Broadcast

或者，如果你想使用另一个 IP 地址，你也可以使用 .Parse()

var ip = IPAddress.Parse("192.168.1.1");

更新：

实际上Encoding.ASCII.GetBytes("255.255.255.255");会给你一个完全不同的结果。

var bytes = Encoding.ASCII.GetBytes("255.255.255.255");

// bytes returns something like
// new byte[] { 50, 53, 53, 46... }

// what you want is
var bytes = new byte[] { 255, 255, 255, 255 };
于 2012-05-31T10:47:20.187 回答