.NET Core 2.1 Apple推送通知 [英] .NET Core 2.1 Apple Push Notifications

问题描述

我必须使用.Net Core WebAPI将推送通知发送到特定的iOS设备，该通知将在Windows 2008 Server R2上执行.服务器本身不应该成为问题，因为它正在使用node.js库.但是我希望它可以与ASP.Net Core 2.1中的WepAPI一起使用，该API由内置的Kestrel Server自托管.也许您已经知道如何解决此问题.

I have to send push notifications to specific iOS devices with my .Net Core WebAPI that will be executed on a Windows 2008 Server R2. The server itself should not be the problem because it is working with a node.js library. But I want it to work with an WepAPI in ASP .Net Core 2.1 which is self hosted with the inbuilt Kestrel Server. Maybe you've got an idea how to solve this problem.

我的代码:

// This will encode the jason web token apns needs for the authorization
// get the base64 private key of the .p8 file from apple
string p8File = System.IO.File.ReadAllText(Settings.Apn.PrivateKey);
p8File = p8File.Replace("-----BEGIN PRIVATE KEY-----", string.Empty);
p8File = p8File.Replace("-----END PRIVATE KEY-----", string.Empty);
p8File = p8File.Replace(" ", string.Empty);

byte[] keyData = Convert.FromBase64String(p8File);
ECDsa key = new ECDsaCng(CngKey.Import(keyData, CngKeyBlobFormat.Pkcs8PrivateBlob));

ECDsaSecurityKey securityKey = new ECDsaSecurityKey(key) { KeyId = Settings.Apn.KeyId };
SigningCredentials credentials = new SigningCredentials(securityKey, "ES256");

SecurityTokenDescriptor descriptor =
    new SecurityTokenDescriptor
        {
            IssuedAt = DateTime.Now,
            Issuer = Settings.Apn.TeamId,
            SigningCredentials = credentials
        };

JwtSecurityTokenHandler jwtHandler = new JwtSecurityTokenHandler();
string encodedToken = jwtHandler.CreateEncodedJwt(descriptor);
this.log?.LogInformation($"Created JWT: {encodedToken}");

// The hostname is: https://api.development.push.apple.com:443
HttpClient client = new HttpClient { BaseAddress = new Uri(Settings.Apn.Hostname) };
client.DefaultRequestHeaders.Clear();
client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
this.log?.LogInformation("Initialized new HttpClient.");

// payload content for the apns
JObject payloadData = new JObject
                          {
                              new JProperty("alert", data.Message),
                              new JProperty("badge", 2),
                              new JProperty("sound", "default")
                          };
JObject payload = new JObject
                       {
                           new JProperty("aps", payloadData)
                       };
this.log?.LogInformation($"Setup payload: {payload}");

// HttpRequestMessage that should be send
HttpRequestMessage request = new HttpRequestMessage(
                                 HttpMethod.Post,
                                 $"{Settings.Apn.Hostname}/3/device/{data.DeviceId}")
                                 {
                                     Content = new StringContent(JsonConvert.SerializeObject(payload), Encoding.UTF8, "application/json")
                                 };
this.log?.LogInformation("Setup HttpRequestMessage.");

// Setup the header
request.Headers.Add("Authorization", $"Bearer {encodedToken}");
request.Headers.Add("apns-id", Guid.NewGuid().ToString());
request.Headers.Add("apns-expiration", DateTime.Now.AddDays(1).ToString(CultureInfo.InvariantCulture));
request.Headers.Add("apns-priority", "10");
request.Headers.Add("apns-topic", "de.gefasoft-engineering.FabChat");

// Debug logging
this.log.LogDebug(request.ToString());
this.log.LogDebug(await request.Content.ReadAsStringAsync());
this.log.LogDebug(request.RequestUri.Host + request.RequestUri.Port);

// Send request
var result = await client.SendAsync(request);
this.log?.LogInformation("Sent request.");
this.log?.LogInformation(await result.Content.ReadAsStringAsync());

我总是收到以下抛出的异常:

I always get following Exception thrown:

System.Net.Http.HttpRequestException:无法建立SSL连接 建立，请参阅内部异常. ---> System.Security.Authentication.AuthenticationException:身份验证 失败，请参阅内部异常. ---> System.ComponentModel.Win32Exception:收到的消息为 意外或格式错误-内部异常堆栈结束 跟踪---

System.Net.Http.HttpRequestException: The SSL connection could not be established, see inner exception. ---> System.Security.Authentication.AuthenticationException: Authentication failed, see inner exception. ---> System.ComponentModel.Win32Exception: The message received was unexpected or badly formatted --- End of inner exception stack trace ---

推荐答案

我已经对@civilator的答案发表了评论.但是我认为，有些人阅读了它，因此我将其再次发布. 这是对我有用的代码.抱歉，答案迟到了！

I've already commented on the answer from @civilator. But I think, that some people read over it, so I'm posting it again. This is the code that worked for me. Sorry for the late answer!

private readonly string hostname = "gateway.sandbox.push.apple.com";
private readonly int port = 2195;

public async Task<RestResult<JObject>> SendPushNotification(string deviceToken, string message)
    {
        this.log?.LogInformation("Trying to send push notification.");
        X509Certificate2Collection certificatesCollection;

        // Setup and read the certificate
        // NOTE: You should get the certificate from your apple developer account.
        try
        {
            string certificatePath = Settings.Apn.Certificate;
            X509Certificate2 clientCertificate = new X509Certificate2(
                File.ReadAllBytes(certificatePath),
                Settings.Apn.Password);
            certificatesCollection = new X509Certificate2Collection(clientCertificate);
            this.log?.LogInformation("Setup certificates.");
        }
        catch (Exception e)
        {
            this.log?.LogError(e.ToString());
            return new RestResult<JObject> { Result = "exception", Message = "Failed to setup certificates." };
        }

        // Setup a tcp connection to the apns
        TcpClient client = new TcpClient(AddressFamily.InterNetwork);
        this.log?.LogInformation("Created new TcpClient.");
        try
        {
            IPHostEntry host = Dns.GetHostEntry(this.hostname);
            await client.ConnectAsync(host.AddressList[0], this.port);
            this.log?.LogInformation($"Opened connection to {this.hostname}:{this.port}.");
        }
        catch (Exception e)
        {
            this.log?.LogError("Failed to open tcp connection to the apns.");
            this.log?.LogError(e.ToString());
        }

        // Validate the Certificate you get from the APN (for more information read the documentation:
        // https://developer.apple.com/library/archive/documentation/NetworkingInternet/Conceptual/RemoteNotificationsPG/APNSOverview.html#//apple_ref/doc/uid/TP40008194-CH8-SW1).
        SslStream sslStream = new SslStream(
            client.GetStream(),
            false,
            new RemoteCertificateValidationCallback(this.ValidateServerCertificate),
            null);

        try
        {
            await sslStream.AuthenticateAsClientAsync(this.hostname, certificatesCollection, SslProtocols.Tls, false);
            MemoryStream memoryStream = new MemoryStream();
            BinaryWriter writer = new BinaryWriter(memoryStream);
            writer.Write((byte)0);
            writer.Write((byte)0);
            writer.Write((byte)32);

            writer.Write(HexStringToByteArray(deviceToken.ToUpper()));

            // Creating an payload object to send key values to the apns
            JObject aps = new JObject
                              {
                                  new JProperty("alert", message),
                                  new JProperty("badge", 0),
                                  new JProperty("sound", "default")
                              };

            JObject payload = new JObject
                                  {
                                    new JProperty("aps", aps)
                                  };

            string payloadString = JsonConvert.SerializeObject(payload);
            writer.Write((byte)0);
            writer.Write((byte)payloadString.Length);

            byte[] b1 = System.Text.Encoding.UTF8.GetBytes(payloadString);
            writer.Write(b1);
            writer.Flush();

            byte[] array = memoryStream.ToArray();
            sslStream.Write(array);
            sslStream.Flush();
            client.Dispose();
        }
        catch (AuthenticationException ex)
        {
            this.log?.LogError(ex.ToString());
            client.Dispose();
            return new RestResult<JObject> { Result = "exception", Message = "Authentication Exception." };
        }
        catch (Exception e)
        {
            this.log?.LogError(e.ToString());
            client.Dispose();
            return new RestResult<JObject> { Result = "exception", Message = "Exception was thrown." };
        }

        this.log?.LogInformation("Notification sent.");
        return new RestResult<JObject> { Result = "success", Message = "Notification sent. Check your device." };
    }

    #region Helper methods

    private static byte[] HexStringToByteArray(string hex)
    {
        return Enumerable.Range(0, hex.Length)
            .Where(x => x % 2 == 0)
            .Select(x => Convert.ToByte(hex.Substring(x, 2), 16))
            .ToArray();
    }

    // The following method is invoked by the RemoteCertificateValidationDelegate.
    private bool ValidateServerCertificate(
        object sender,
        X509Certificate certificate,
        X509Chain chain,
        SslPolicyErrors sslPolicyErrors)
    {
        if (sslPolicyErrors == SslPolicyErrors.None)
        {
            this.log?.LogInformation("Server Certificate validated.");
            return true;
        }

        this.log?.LogError($"Server Certificate error: {sslPolicyErrors}");

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

    #endregion

这篇关于.NET Core 2.1 Apple推送通知的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！