Bagaimana untuk melaksanakan fungsi penjadualan tugas tak segerak yang mudah menggunakan MySQL dan Ruby

Cara menggunakan MySQL dan Ruby untuk melaksanakan fungsi penjadualan tugas tak segerak yang mudah

Aplikasi web sebelum ini kebanyakannya menggunakan kaedah segerak untuk memproses permintaan, iaitu selepas pengguna menghantar permintaan, pelayan akan segera memproses permintaan dan pulangkan hasilnya. Walau bagaimanapun, apabila kerumitan aplikasi meningkat, kecekapan pemprosesan kaedah segerak secara beransur-ansur menjadi tidak cekap, jadi penjadualan tugas tak segerak telah menjadi keperluan biasa dalam aplikasi web moden.

Artikel ini akan memperkenalkan cara menggunakan MySQL dan Ruby untuk melaksanakan fungsi penjadualan tugas tak segerak yang mudah, termasuk penciptaan tugas, penjadualan dan langkah pelaksanaan. Kami akan menggunakan contoh perangkak tapak web untuk menggambarkan proses pelaksanaan fungsi ini.

1. Buat jadual pangkalan data MySQL

Pertama, kita perlu mencipta jadual dalam MySQL untuk menyimpan maklumat tugas. Anda boleh menggunakan pernyataan SQL berikut untuk membuat jadual:

CREATE TABLE tasks (
  id INT(11) PRIMARY KEY AUTO_INCREMENT,
  url VARCHAR(255) NOT NULL,
  status ENUM('pending', 'completed') DEFAULT 'pending',
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

Jadual ini mengandungi medan seperti ID tugas, URL, status dan masa penciptaan.

2. Menyambung ke MySQL menggunakan Ruby

Dalam kod Ruby, kita perlu menggunakan perpustakaan yang sesuai untuk menyambung ke pangkalan data MySQL. Di sini kami menggunakan permata "mysql2" untuk menyelesaikan kerja sambungan. Pustaka boleh dipasang melalui arahan berikut:

gem install mysql2

Dalam kod, kita perlu mengimport perpustakaan dahulu dan mewujudkan sambungan pangkalan data:

require 'mysql2'
client = Mysql2::Client.new(host: 'localhost', username: 'root', password: 'password', database: 'task_scheduler')

Tetapkan sambungan dengan menghantar alamat hos, nama pengguna, kata laluan dan nama pangkalan data yang sepadan .

3. Buat Tugasan

Langkah seterusnya ialah mencipta tugasan. Kita boleh menggunakan kod berikut untuk membuat tugasan:

def create_task(url)
  sql = "INSERT INTO tasks (url) VALUES ('#{url}')"
  client.query(sql)
  puts "Task created successfully."
end

create_task('http://example.com')

Fungsi ini menerima parameter URL dan memasukkannya ke dalam jadual tugas. Status tugas akan ditetapkan kepada "belum selesai" secara lalai.

4. Penjadualan tugas

Penjadualan tugas melibatkan pertanyaan tugasan yang belum selesai dan menghantarnya ke pemproses tak segerak. Tugasan boleh dijadualkan menggunakan kod berikut:

def schedule_tasks
  sql = "SELECT * FROM tasks WHERE status = 'pending'"
  tasks = client.query(sql)

  tasks.each do |task|
    handle_task_async(task)
  end

  puts "Tasks scheduled successfully."
end

def handle_task_async(task)
  # 执行异步任务处理逻辑
end

schedule_tasks

Dalam contoh ini, kami mula-mula menanyakan tugasan yang belum selesai, kemudian mengulangi setiap tugasan dan memanggil fungsi handle_task_async untuk memproses tugasan. Logik pemprosesan tugas sebenar hendaklah ditulis mengikut keperluan permohonan.

5. Laksanakan tugas

Pelaksanaan tugas melibatkan mengalih keluar tugas daripada baris gilir tugas dan melaksanakan logik pemprosesan yang sepadan. Kod berikut boleh digunakan untuk melaksanakan tugas:

def execute_tasks
  # 从任务队列中获取任务
  # 执行相应的处理逻辑
end

execute_tasks

Dalam aplikasi praktikal, kaedah lain (seperti baris gilir mesej) boleh digunakan untuk melaksanakan baris gilir tugas, dan kemudian dapatkan tugas daripada baris gilir dan laksanakannya. Ini hanyalah contoh ringkas.

Melalui langkah di atas, kami telah melaksanakan fungsi penjadualan tugas tak segerak yang mudah. Apabila tugasan dibuat, kami memasukkannya ke dalam jadual pangkalan data MySQL. Kemudian, melalui penjadual tugas, kita boleh bertanya dan menjadualkan tugas yang belum selesai dan menghantarnya kepada pemproses tak segerak untuk dilaksanakan. Pendekatan ini boleh meningkatkan prestasi aplikasi dan kebolehskalaan.

Kod sampel di atas hanyalah demonstrasi, dan pelaksanaan sebenar mungkin melibatkan butiran lanjut dan logik pemprosesan. Tetapi saya berharap melalui contoh ini, pembaca dapat memahami cara menggunakan MySQL dan Ruby untuk melaksanakan fungsi penjadualan tugas tak segerak yang mudah, dan boleh mengembangkan dan mengoptimumkannya dalam aplikasi praktikal.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan fungsi penjadualan tugas tak segerak yang mudah menggunakan MySQL dan Ruby. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!