Gofer.NET

Gofer.net: Tugas/pekerjaan yang didistribusikan dengan mudah untuk .NET Core

Dokumentasi

Baca dokumen

Apa ini?

Ini adalah pelari kerja terdistribusi untuk aplikasi .NET Standard 2.0.

Terinspirasi oleh seledri untuk Python, ini memungkinkan Anda untuk dengan cepat mengantri eksekusi kode pada kumpulan pekerja.

• Gunakan sintaks ekspresi alami untuk mengantri pekerjaan untuk dieksekusi.

• Pekerjaan yang antri tetap ada, dan secara otomatis dijalankan oleh pekerja pertama yang tersedia.

• Skala kumpulan pekerja Anda hanya dengan menambahkan node baru.

• Didukung oleh Redis, semua tugas gigih.

Memulai

Instal Dotnet CLI.

Kami merekomendasikan menggunakan Dotnet CLI untuk memulai, tetapi itu bukan kebutuhan.

Dotnet CLI adalah bagian dari .NET Core SDK.

Mulai instance Redis.

Kami merekomendasikan menggunakan Docker untuk memulai instance Redis lokal untuk pengujian. Menyiapkan instance Redis tingkat produksi berada di luar ruang lingkup dokumentasi ini.

$ docker run -d -p 127.0.0.1:6379:6379 redis:4-alpine

Buat proyek.

Buka terminal dan buat proyek konsol baru untuk memulai.

$ mkdir myProject && cd myProject
$ dotnet new console

Tambahkan paket gofer.net nuget.

$ dotnet add package Gofer.NET --version 1.0.0- *

Mengantri beberapa pekerjaan.

Contoh Program.cs ini menunjukkan cara mengantri pekerjaan untuk diproses oleh pekerja, kemudian memulai pekerja untuk pergi dan menjalankannya.

Beberapa catatan penting:

• Pekerja biasanya akan menggunakan mesin terpisah dari kode yang mengantri pekerjaan, ini murni untuk memberikan contoh.

• Lebih banyak pekerja dapat ditambahkan kapan saja, dan akan segera mulai mengambil pekerjaan dari antrian.

 public class Program
{
    public static async Task Main ( string [ ] args )
    {
        var redisConnectionString = "127.0.0.1:6379" ;
        
        // Create a Task Client connected to Redis
        var taskClient = new TaskClient ( TaskQueue . Redis ( redisConnectionString ) ) ;
        
        // Queue up a Sample Job
        await taskClient . TaskQueue . Enqueue ( ( ) => SampleJobFunction ( "Hello World!" ) ) ;
        
        // Start the task listener, effectively turning this process into a worker.
        // NOTE: This will loop endlessly waiting for new tasks.
        await taskClient . Listen ( ) ;
    }
    
    private static void SampleJobFunction ( object value )
    {
        Console . WriteLine ( value . ToString ( ) ) ;
    }
}

Baca dokumen untuk lebih jelasnya.