Как отправить push-уведомление APNS (iOS) с С# без очереди

Кажется, все используют PushSharp для отправки push-уведомлений на устройства iOS с C#. Но у этой библиотеки есть очередь, которую она использует вместо отправки уведомления напрямую, что означает, что вам нужна служба Windows или что-то еще для ее правильного размещения (согласно ее собственной документации), что для меня излишне. У меня есть входящий веб-запрос к моей веб-службе ASP.NET, и в рамках его обработки я хочу немедленно отправить push-уведомление. Просто как тот.

Может ли кто-нибудь сказать мне, как использовать PushSharp для немедленной отправки (в обход механизма очереди) или как правильно отправить push-уведомление самостоятельно? У меня уже есть код, формирующий сообщение JSON, но я не знаю, как применить файл .p12 к запросу. Я не могу найти документацию Apple о том, как это сделать.


person Andrew Arnott    schedule 31.01.2014    source источник
comment
я бы тоже хотела узнать как это сделать   -  person MichaelMcCabe    schedule 04.02.2014
comment
Я нашел документацию от Apple, где говорится, что это двоичный канал TCP, который должен оставаться открытым в течение длительного времени, а не открываться только для одного сообщения. Поэтому я думаю, что очередь важна. Apple заявляет, что заблокирует вас как DoS-атаку, если вы этого не сделаете.   -  person Andrew Arnott    schedule 09.02.2014


Ответы (2)


Это старый вопрос, но ответ не полный.

Вот мой код:

// private fields
private static readonly string _apnsHostName = ConfigurationManager.AppSettings["APNS:HostName"];
private static readonly int _apnsPort = int.Parse(ConfigurationManager.AppSettings["APNS:Port"]);
private static readonly string _apnsCertPassword = ConfigurationManager.AppSettings["APNS:CertPassword"];
private static readonly string _apnsCertSubject = ConfigurationManager.AppSettings["APNS:CertSubject"];
private static readonly string _apnsCertPath = ConfigurationManager.AppSettings["APNS:CertPath"];

private readonly ILogger _log;

private X509Certificate2Collection _certificatesCollection;


ctor <TAB key>(ILogger log)
{
    _log = log ?? throw new ArgumentNullException(nameof(log));

    // load .p12 certificate in the collection
    var cert = new X509Certificate2(_apnsCertPath, _apnsCertPassword);
    _certificatesCollection = new X509Certificate2Collection(cert);
}

public async Task SendAppleNativeNotificationAsync(string payload, Registration registration)
{
    try
    {
        // handle is the iOS device Token
        var handle = registration.Handle;

        // instantiate new TcpClient with ApnsHostName and Port
        var client = new TcpClient(_apnsHostName, _apnsPort);

        // add fake validation
        var sslStream = new SslStream(client.GetStream(), false, new RemoteCertificateValidationCallback(ValidateServerCertificate), null);

        try
        {
            // authenticate ssl stream on ApnsHostName with your .p12 certificate
            sslStream.AuthenticateAsClient(_apnsHostName, _certificatesCollection, SslProtocols.Tls, false);
            var memoryStream = new MemoryStream();
            var writer = new BinaryWriter(memoryStream);
            // command
            writer.Write((byte)0);
            // first byte of the deviceId length (big-endian first byte)
            writer.Write((byte)0);
            // deviceId length (big-endian second byte)
            writer.Write((byte)32);
            // deviceId data (byte[])
            writer.Write(HexStringToByteArray(handle.ToUpper()));
            // first byte of payload length; (big-endian first byte)
            writer.Write((byte)0);
            // payload length (big-endian second byte)
            writer.Write((byte)Encoding.UTF8.GetByteCount(payload));
            byte[] b1 = Encoding.UTF8.GetBytes(payload);
            // payload data (byte[])
            writer.Write(b1);

            writer.Flush();
            byte[] array = memoryStream.ToArray();

            await sslStream.WriteAsync(array, 0, array.Length);

            // TIP: do not wait a response from APNS because APNS return a response only when an error occurs; 
            // so if you wait the response your code will remain stuck here.
            // await ReadTcpResponse();

            sslStream.Flush();

            // close client
            client.Close();
        }
        catch (AuthenticationException ex)
        {
            _log.Error($"Error sending APNS notification. Exception: {ex}");
            client.Close();
        }
        catch (Exception ex)
        {
            _log.Error($"Error sending APNS notification. Exception: {ex}");
            client.Close();
        }
    }
    catch (Exception ex)
    {
        _log.Error($"Error sending APNS notification. Exception: {ex}");
    }
}

private static byte[] HexStringToByteArray(string hex)
{
    if (hex == null)
    {
        return null;
    }

    // added for newest devices (>= iPhone 8)
    if (hex.Length % 2 == 1)
    {
        hex = '0' + hex;
    }

    return Enumerable.Range(0, hex.Length)
                     .Where(x => x % 2 == 0)
                     .Select(x => Convert.ToByte(hex.Substring(x, 2), 16))
                     .ToArray();
}

private static bool ValidateServerCertificate(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
{
    return true;
    //if (sslPolicyErrors == SslPolicyErrors.None)
    //    return true;

    //// do not allow this client to communicate with unauthenticated servers.
    //return false;
}

private async Task<byte[]> ReadTcpResponse(SslStream sslStream)
{
    MemoryStream ms = new MemoryStream();

    byte[] buffer = new byte[2048];

    int bytes = -1;
    do
    {
        bytes = await sslStream.ReadAsync(buffer, 0, buffer.Length);

        await ms.WriteAsync(buffer, 0, bytes);

    } while (bytes != 0);

    return ms.ToArray();
}

СОВЕТ: в iOS13 токен устройства принимается по-другому.

> iOS 12 (deviceToken as NSData).description -> "< your_token_here >"
> iOS 13 (deviceToken as NSData).description -> "{ length = 32, bytes = 0x321e1ba1c1ba...token_in_bytes }"

В iOS13 вы должны преобразовать токен в строку или пропустить метод HexStringToByteArray, потому что у вас уже есть byte[].

Если у вас есть вопрос, я рад ответить.

person SteeBono    schedule 15.10.2019

Я провел много часов, пытаясь найти способ отправки push-уведомлений, а затем нашел фрагмент кода, который сделал это за меня.

Прежде всего убедитесь, что вы правильно установили сертификаты, вот ссылка, которая вам поможет. https://arashnorouzi.wordpress.com/2011/04/13/sending-apple-push-notifications-in-asp-net-%E2%80%93-part-3-apns-certificates-регистрация-в-окнах/

Вот код, который я использовал для push-уведомлений:

public static bool ConnectToAPNS(string deviceId, string message)
    {
        X509Certificate2Collection certs = new X509Certificate2Collection();

        // Add the Apple cert to our collection
        certs.Add(getServerCert());

        // Apple development server address
        string apsHost;
        /*
        if (getServerCert().ToString().Contains("Production"))
            apsHost = "gateway.push.apple.com";
        else*/
        apsHost = "gateway.sandbox.push.apple.com";

        // Create a TCP socket connection to the Apple server on port 2195
        TcpClient tcpClient = new TcpClient(apsHost, 2195);

        // Create a new SSL stream over the connection
        SslStream sslStream1 = new SslStream(tcpClient.GetStream());

        // Authenticate using the Apple cert
        sslStream1.AuthenticateAsClient(apsHost, certs, SslProtocols.Default, false);

        PushMessage(deviceId, message, sslStream1);

        return true;
    }

private static X509Certificate getServerCert()
    {
        X509Certificate test = new X509Certificate();

        //Open the cert store on local machine
        X509Store store = new X509Store(StoreLocation.CurrentUser);

        if (store != null)
        {
            // store exists, so open it and search through the certs for the Apple Cert
            store.Open(OpenFlags.ReadOnly);
            X509Certificate2Collection certs = store.Certificates;

            if (certs.Count > 0)
            {
                int i;
                for (i = 0; i < certs.Count; i++)
                {
                    X509Certificate2 cert = certs[i];

                    if (cert.FriendlyName.Contains("Apple Development IOS Push Services"))
                    {
                        //Cert found, so return it.
                        Console.WriteLine("Found It!");
                        return certs[i];
                    }
                }
            }
            return test;
        }
        return test;
    }

private static byte[] HexToData(string hexString)
    {
        if (hexString == null)
            return null;

        if (hexString.Length % 2 == 1)
            hexString = '0' + hexString; // Up to you whether to pad the first or last byte

        byte[] data = new byte[hexString.Length / 2];

        for (int i = 0; i < data.Length; i++)
            data[i] = Convert.ToByte(hexString.Substring(i * 2, 2), 16);

        return data;
    }

Обратите внимание, что этот код предназначен для сертификатов разработки «Apple Development IOS Push Services».

person fahad    schedule 10.03.2016
comment
PushMessage является наиболее важным в этом случае! если здесь нет pushMessage, это будет какашка! - person Mahir Tayir; 22.03.2019