Я пытаюсь отправить уведомление в приложение ios, используя c #.Первоначально я получал сообщение об ошибке " Учетные данные, предоставленные для пакета, не были распознаны ".
Поэтому я проверил эту проблему и обнаружил, что большинство людей смогли решить эту проблему, только экспортировавзакрытый ключ в файле p12 и не экспортирующий сертификат с ним.
После попытки описанного выше метода мое исключение пропало, и с сервера отправляются уведомления, но оно никогда не достигает устройства.
Кроме того, я использую один и тот же код в другом приложении с такими же разрешениямик файлу p12, и он прекрасно работает.
Пожалуйста, найдите ниже код, который я использовал.
public Int64 PushNotificationToAppleCRON(string messageObject, string devicetoken, string check, ref string ErrorMessage)
{
Int64 result = 0;
try
{
var regionId = ConfigurationManager.AppSettings["regionid"];
var pfxpath = ConfigurationManager.AppSettings["pfxfilepath"];
var pushNotificationToAppleUseSandBox = Convert.ToBoolean(ConfigurationManager.AppSettings["PushNotificationToAppleUseSandBox"]);
string strDeviceToken = devicetoken;
string strPushMessage = messageObject;
var payload1 = new NotificationPayload(strDeviceToken, strPushMessage, 1, "default");
payload1.AddCustom("RegionID", regionId);
payload1.AddCustom("Check", check);
var p = new List<NotificationPayload> { payload1 };
string certificatePath = Directory.GetParent(Directory.GetParent(System.Environment.CurrentDirectory.ToString()).ToString()) + pfxpath; //HttpContext.Current.Server.MapPath(pfxpath);
var push = new PushNotification(pushNotificationToAppleUseSandBox, certificatePath, "COPD1234");
string strfilename = push.P12File;
var message1 = push.SendToApple(p);
result = 1;
}
catch (Exception ex)
{
ErrorMessage = ex.Message;
}
return result;
}
public class PushNotification
{
private TcpClient _apnsClient;
private SslStream _apnsStream;
private X509Certificate _certificate;
private X509CertificateCollection _certificates;
public string P12File { get; set; }
public string P12FilePassword { get; set; }
// Default configurations for APNS
private const string ProductionHost = "gateway.push.apple.com";
private const string SandboxHost = "gateway.sandbox.push.apple.com";
private const int NotificationPort = 2195;
// Default configurations for Feedback Service
private const string ProductionFeedbackHost = "feedback.push.apple.com";
private const string SandboxFeedbackHost = "feedback.sandbox.push.apple.com";
private const int FeedbackPort = 2196;
private bool _conected = false;
private readonly string _host;
private readonly string _feedbackHost;
private List<NotificationPayload> _notifications = new List<NotificationPayload>();
private List<string> _rejected = new List<string>();
private Dictionary<int, string> _errorList = new Dictionary<int, string>();
public PushNotification(bool useSandbox, string p12File, string p12FilePassword)
{
if (useSandbox)
{
_host = SandboxHost;
_feedbackHost = SandboxFeedbackHost;
}
else
{
_host = ProductionHost;
_feedbackHost = ProductionFeedbackHost;
}
//Load Certificates in to collection.
_certificate = string.IsNullOrEmpty(p12FilePassword) ? new X509Certificate2(File.ReadAllBytes(p12File)) : new X509Certificate2(File.ReadAllBytes(p12File), p12FilePassword, X509KeyStorageFlags.MachineKeySet);
_certificates = new X509CertificateCollection { _certificate };
// Loading Apple error response list.
_errorList.Add(0, "No errors encountered");
_errorList.Add(1, "Processing error");
_errorList.Add(2, "Missing device token");
_errorList.Add(3, "Missing topic");
_errorList.Add(4, "Missing payload");
_errorList.Add(5, "Invalid token size");
_errorList.Add(6, "Invalid topic size");
_errorList.Add(7, "Invalid payload size");
_errorList.Add(8, "Invalid token");
_errorList.Add(255, "None (unknown)");
}
public List<string> SendToApple(List<NotificationPayload> queue)
{
_notifications = queue;
if (queue.Count < 8999)
{
SendQueueToapple(_notifications);
}
else
{
const int pageSize = 8999;
int numberOfPages = (queue.Count / pageSize) + (queue.Count % pageSize == 0 ? 0 : 1);
int currentPage = 0;
while (currentPage < numberOfPages)
{
_notifications = (queue.Skip(currentPage * pageSize).Take(pageSize)).ToList();
SendQueueToapple(_notifications);
currentPage++;
}
}
//Close the connection
Disconnect();
return _rejected;
}
private void SendQueueToapple(IEnumerable<NotificationPayload> queue)
{
int i = 1000;
foreach (var item in queue)
{
if (!_conected)
{
Connect(_host, NotificationPort, _certificates);
var response = new byte[6];
_apnsStream.BeginRead(response, 0, 6, ReadResponse, new MyAsyncInfo(response, _apnsStream));
}
try
{
if (item.DeviceToken.Length == 64) //check lenght of device token, if its shorter or longer stop generating Payload.
{
item.PayloadId = i;
byte[] payload = GeneratePayload(item);
_apnsStream.Write(payload);
Thread.Sleep(1000); //Wait to get the response from apple.
}
}
catch (Exception ex)
{
_conected = false;
}
i++;
}
}
private void ReadResponse(IAsyncResult ar)
{
if (!_conected)
return;
string payLoadId = "";
int payLoadIndex = 0;
try
{
var info = ar.AsyncState as MyAsyncInfo;
info.MyStream.ReadTimeout = 100;
if (_apnsStream.CanRead)
{
var command = Convert.ToInt16(info.ByteArray[0]);
var status = Convert.ToInt16(info.ByteArray[1]);
var ID = new byte[4];
Array.Copy(info.ByteArray, 2, ID, 0, 4);
payLoadId = Encoding.Default.GetString(ID);
payLoadIndex = ((int.Parse(payLoadId)) - 1000);
_rejected.Add(_notifications[payLoadIndex].DeviceToken);
_conected = false;
}
}
catch (Exception ex)
{
}
}
private void Connect(string host, int port, X509CertificateCollection certificates)
{
//Logger.Info("Connecting to apple server.");
try
{
_apnsClient = new TcpClient();
_apnsClient.Connect(host, port);
}
catch (SocketException ex)
{
//Logger.Error("An error occurred while connecting to APNS servers - " + ex.Message);
}
var sslOpened = OpenSslStream(host, certificates);
if (sslOpened)
{
_conected = true;
//Logger.Info("Conected.");
}
}
private void Disconnect()
{
try
{
Thread.Sleep(500);
_apnsClient.Close();
_apnsStream.Close();
_apnsStream.Dispose();
_apnsStream = null;
_conected = false;
//Logger.Info("Disconnected.");
}
catch (Exception ex)
{
// Logger.Error("An error occurred while disconnecting. - " + ex.Message);
}
}
private bool OpenSslStream(string host, X509CertificateCollection certificates)
{
// Logger.Info("Creating SSL connection.");
_apnsStream = new SslStream(_apnsClient.GetStream(), false, validateServerCertificate, SelectLocalCertificate);
try
{
_apnsStream.AuthenticateAsClient(host, certificates, System.Security.Authentication.SslProtocols.Default, false);
}
catch (System.Security.Authentication.AuthenticationException ex)
{
// Logger.Error(ex.Message);
return false;
}
if (!_apnsStream.IsMutuallyAuthenticated)
{
//Logger.Error("SSL Stream Failed to Authenticate");
return false;
}
if (!_apnsStream.CanWrite)
{
//Logger.Error("SSL Stream is not Writable");
return false;
}
return true;
}
private bool validateServerCertificate(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
{
return true; // Dont care about server's cert
}
private X509Certificate SelectLocalCertificate(object sender, string targetHost, X509CertificateCollection localCertificates, X509Certificate remoteCertificate, string[] acceptableIssuers)
{
return _certificate;
}
private static byte[] GeneratePayload(NotificationPayload payload)
{
try
{
//convert Devide token to HEX value.
byte[] deviceToken = new byte[payload.DeviceToken.Length / 2];
for (int i = 0; i < deviceToken.Length; i++)
deviceToken[i] = byte.Parse(payload.DeviceToken.Substring(i * 2, 2), System.Globalization.NumberStyles.HexNumber);
var memoryStream = new MemoryStream();
// Command
memoryStream.WriteByte(1); // Changed command Type
//Adding ID to Payload
memoryStream.Write(Encoding.ASCII.GetBytes(payload.PayloadId.ToString()), 0, payload.PayloadId.ToString().Length);
//Adding ExpiryDate to Payload
int epoch = (int)(DateTime.UtcNow.AddMinutes(300) - new DateTime(1970, 1, 1)).TotalSeconds;
byte[] timeStamp = BitConverter.GetBytes(epoch);
memoryStream.Write(timeStamp, 0, timeStamp.Length);
byte[] tokenLength = BitConverter.GetBytes((Int16)32);
Array.Reverse(tokenLength);
// device token length
memoryStream.Write(tokenLength, 0, 2);
// Token
memoryStream.Write(deviceToken, 0, 32);
// String length
string apnMessage = payload.ToJson();
//Logger.Info("Payload generated for " + payload.DeviceToken + " : " + apnMessage);
byte[] apnMessageLength = BitConverter.GetBytes((Int16)apnMessage.Length);
Array.Reverse(apnMessageLength);
// message length
memoryStream.Write(apnMessageLength, 0, 2);
// Write the message
memoryStream.Write(Encoding.ASCII.GetBytes(apnMessage), 0, apnMessage.Length);
return memoryStream.ToArray();
}
catch (Exception ex)
{
// Logger.Error("Unable to generate payload - " + ex.Message);
return null;
}
}
public List<Feedback> GetFeedBack()
{
try
{
var feedbacks = new List<Feedback>();
// Logger.Info("Connecting to feedback service.");
if (!_conected)
Connect(_feedbackHost, FeedbackPort, _certificates);
if (_conected)
{
//Set up
byte[] buffer = new byte[38];
int recd = 0;
DateTime minTimestamp = DateTime.Now.AddYears(-1);
//Get the first feedback
recd = _apnsStream.Read(buffer, 0, buffer.Length);
// Logger.Info("Feedback response received.");
if (recd == 0)
// Logger.Info("Feedback response is empty.");
//Continue while we have results and are not disposing
while (recd > 0)
{
// Logger.Info("processing feedback response");
var fb = new Feedback();
//Get our seconds since 1970 ?
byte[] bSeconds = new byte[4];
byte[] bDeviceToken = new byte[32];
Array.Copy(buffer, 0, bSeconds, 0, 4);
//Check endianness
if (BitConverter.IsLittleEndian)
Array.Reverse(bSeconds);
int tSeconds = BitConverter.ToInt32(bSeconds, 0);
//Add seconds since 1970 to that date, in UTC and then get it locally
fb.Timestamp = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc).AddSeconds(tSeconds).ToLocalTime();
//Now copy out the device token
Array.Copy(buffer, 6, bDeviceToken, 0, 32);
fb.DeviceToken = BitConverter.ToString(bDeviceToken).Replace("-", "").ToLower().Trim();
//Make sure we have a good feedback tuple
if (fb.DeviceToken.Length == 64 && fb.Timestamp > minTimestamp)
{
//Raise event
//this.Feedback(this, fb);
feedbacks.Add(fb);
}
//Clear our array to reuse it
Array.Clear(buffer, 0, buffer.Length);
//Read the next feedback
recd = _apnsStream.Read(buffer, 0, buffer.Length);
}
//clode the connection here !
Disconnect();
if (feedbacks.Count > 0)
//Logger.Info("Total {0} feedbacks received.", feedbacks.Count);
return feedbacks;
}
}
catch (Exception ex)
{
//Logger.Error("Error occurred on receiving feed back. - " + ex.Message);
return null;
}
return null;
}
}
Хотя я не думаю, что есть какие-либо проблемы с кодом, потому что тот же кодработает для одного другого приложения.
Любая помощь или предложение будет заметно.Thankyou