Bagaimana Melaksanakan Penghantaran Batch Asynchronous mesej SMS tanpa menjejaskan kelajuan tindak balas?

Penghantaran Batch Asynchronous yang cekap menghantar mesej SMS: Meningkatkan pengalaman pengguna dan kecekapan pemprosesan latar belakang

Dalam pembangunan aplikasi, menghantar SMS dalam kelompok adalah keperluan biasa. Untuk meningkatkan pengalaman pengguna, elakkan pengguna menunggu masa yang lama, dan pastikan pelaksanaan tugas latar belakang yang lancar, pemprosesan tak segerak adalah penyelesaian terbaik. Artikel ini akan menerangkan secara terperinci bagaimana untuk melaksanakan penghantaran batch asynchronous menghantar mesej SMS dan memberikan contoh kod.

Aliran pemprosesan asynchronous

Penyelesaian ini mengamalkan mekanisme pemprosesan tak segerak untuk memastikan meja depan bertindak balas dengan cepat, sementara meja belakang secara bebas mengendalikan tugas menghantar SMS. Langkah -langkah tertentu adalah seperti berikut:

1. Permintaan Ajax Front-end: Pengguna mengklik butang Hantar, mencetuskan permintaan Ajax, dan mengemukakan tugas menghantar SMS ke latar belakang. Latar belakang segera mengembalikan respons yang berjaya, memaklumkan permintaan bahawa ia telah diterima.
2. Penerimaan Tugas Latar Belakang dan Caching: Selepas latar belakang menerima permintaan, mesej kejayaan akan dikembalikan dengan segera. Kemudian, nombor telefon bimbit dan kandungan SMS diperoleh secara asynchronously dari pangkalan data dan data ditulis ke cache Redis. Redis adalah pangkalan data cache yang cekap yang dapat dengan cepat menyimpan dan membaca data.
3. Pelaksanaan Tugas Asynchronous: Latar belakang memulakan tugas asynchronous bebas, membaca data dari barisan Redis, dan memanggil SMS menghantar API untuk menghantar SMS. Sebarang pengecualian akan direkodkan dalam log untuk penyelesaian masalah yang lebih mudah.

Contoh kod (PHP Redis)

Contoh kod berikut menunjukkan cara melaksanakan proses di atas menggunakan PHP dan REDIS:

 // permintaan meja depan ajax permintaan (javascript)
$ .ajax ({
  URL: '/Send-SMS',
  Jenis: 'Post',
  Data: {Template_ID: 123, Mobiles: ['13800138000', '13800138001'], Kandungan: 'Ujian SMS'},
  Kejayaan: Fungsi (hasil) {
    Console.log ('SMS menghantar permintaan telah dikemukakan');
  }
});

// Pemprosesan Latar Belakang (PHP)
fungsi awam sendsms () {
  $ templateId = $ _post ['template_id'];
  $ mobiles = $ _post ['Mobiles'];
  $ content = $ _post ['content'];

  // mengembalikan respons yang berjaya dengan segera echo json_encode (['kejayaan' => benar, 'mesej' => 'permintaan diterima']);

  // Pemprosesan Tugas Asynchronous $ this-> DispatchSmedTask ($ templateId, $ mobiles, $ content);
}

// Hantar tugas SMS Hantar (PHP)
Fungsi Private DispatchSmsSendingTask ($ templateId, $ Mobiles, $ content) {
  $ redis = redis baru ();
  $ redis-> Connect ('127.0.0.1', 6379);
  $ redis-> auth ('redis_password'); // sila gantikannya dengan kata laluan redis anda $ data = ['template_id' => $ templateid, 'mobiles' => $ mobiles, 'content' => $ content];
  $ redis-> lpush ('sms_queue', json_encode ($ data))); // Tambahkan tugas ke redis giliran // memulakan tugas dengan mekanisme penjadualan tugas tak segerak yang sesuai, sebagai contoh:
  // Gunakan alat baris perintah: exec ('php'. __Dir__. '/Send_sms_worker.php>/dev/null 2> & 1 &');
  // Gunakan beratur mesej: contohnya rabbitmq, kafka, dan lain -lain}

// SMS Hantar Proses Pekerja (PHP - Send_SMS_Worker.php)
 Php
sementara (benar) {
  $ redis = redis baru ();
  $ redis-> Connect ('127.0.0.1', 6379);
  $ redis-> auth ('redis_password');

  $ datastr = $ redis-> rpop ('sms_queue');
  jika ($ datastr) {
    $ data = json_decode ($ datastr, true);
    // panggil SMS menghantar API
    $ result = SendSmsViaapi ($ data ['template_id'], $ data ['mobiles'], $ data ['content']);
    // log jika ($ hasil! == true) {
      error_log ("SMS gagal menghantar:". $ hasil);
    }
  }
  tidur (1); // Elakkan penggunaan CPU yang berlebihan}

// Simulasi SMS Hantar Panggilan API (PHP)
fungsi SendSmsViaapi ($ templateId, $ mobiles, $ kandungan) {
    // ini digantikan dengan sms sebenar hantar panggilan API // ...
    kembali benar; // hantar dengan jayanya}

Penyelesaian ini menggunakan Ajax untuk mencapai dekoupsi depan dan back-end, dan Redis Queue memastikan penyimpanan yang boleh dipercayai dan pemprosesan tugas yang teratur, meningkatkan kecekapan sistem dan pengalaman pengguna. Sila pilih mekanisme penjadualan tugas asynchronous yang sesuai berdasarkan persekitaran sebenar, seperti menggunakan beratur mesej atau alat pengurusan proses. Ingatlah untuk menggantikan kata laluan REDIS dan SMS menghantar API dalam kod.

Atas ialah kandungan terperinci Bagaimana Melaksanakan Penghantaran Batch Asynchronous mesej SMS tanpa menjejaskan kelajuan tindak balas?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!