Gunakan RocksMQ sebagai Antrian Pesan Milvus
RocksMQ adalah antrian pesan tertanam (WAL) yang disertakan dalam Milvus, dan hanya tersedia untuk Milvus Standalone. Antrian pesan ini merupakan antrian pesan bawaan untuk Milvus Standalone pada versi Milvus sebelumnya; pada Milvus 3.x, Milvus Standalone menggunakan Woodpecker tertanam sebagai antrian pesan bawaan.
Kompatibilitas versi
- Hanya untuk Standalone — RocksMQ tidak didukung di Milvus Distributed (kluster). Lihat matriks dukungan antrian pesan.
- RocksMQ sudah disertakan dalam Milvus, sehingga tidak perlu menginstal versi terpisah.
- Ini adalah antrian pesan standalone default pada versi Milvus sebelumnya, dan telah digantikan oleh Woodpecker tertanam di Milvus 3.x.
Deploy Milvus Standalone dengan RocksMQ menggunakan Docker
Instal
Ikuti panduan "Run Milvus in Docker". Pada Milvus 3.x, antrian pesan standalone default adalah Woodpecker, jadi ubah jenis antrian pesan menjadi RocksMQ secara eksplisit. Skrip bootstrap akan menulis file ` user.yaml ` baru pada saat pertama kali dijalankan ( start), jadi atur jenisnya setelah proses startup pertama, lalu jalankan ` restart ` untuk menerapkan perubahan (perintah ` restart ` akan mempertahankan ` user.yaml`):
mkdir milvus-rocksmq && cd milvus-rocksmq
curl -sfL https://raw.githubusercontent.com/milvus-io/milvus/master/scripts/standalone_embed.sh -o standalone_embed.sh
# 1. First start — boots the container and writes a default user.yaml
bash standalone_embed.sh start
# 2. Set the message queue to RocksMQ
cat > user.yaml <<'EOF'
mq:
type: rocksmq
EOF
# 3. Restart to apply the change
bash standalone_embed.sh restart
mq.type dengan cara ini ditujukan untuk instance yang benar-benar baru (belum ada koleksi). Untuk mengubah antrian pesan pada instance yang sudah menyimpan data, ikuti prosedur peralihan sebagai gantinya.
Konfigurasi
Untuk mengoptimalkan RocksMQ, tambahkan bagian ` rocksmq ` ke berkas ` user.yaml ` dan mulai ulang layanan:
mq:
type: rocksmq
rocksmq:
path: /var/lib/milvus/rdb_data # where messages are stored
lrucacheratio: 0.06 # rocksdb cache memory ratio
rocksmqPageSize: 67108864 # 64 MB, size of each message page
retentionTimeInMinutes: 4320 # 3 days
retentionSizeInMB: 8192 # 8 GB
compactionInterval: 86400 # 1 day, trigger rocksdb compaction
compressionTypes: [0, 0, 7, 7, 7]
bash standalone_embed.sh restart
Hapus Instalasi
bash standalone_embed.sh stop
bash standalone_embed.sh delete
Catatan
- Peningkatan dari 2.5.x ke 2.6.x: Batasan Antrian Pesan: Saat meningkatkan ke Milvus v3.0.0, Anda harus mempertahankan pilihan antrian pesan saat ini. Beralih antara sistem antrian pesan yang berbeda selama proses peningkatan tidak didukung. Dukungan untuk mengubah sistem antrian pesan akan tersedia di versi mendatang.
Karena versi 2.6.x mengubah pengaturan default standalone menjadi Woodpecker, tetapkan
mq.type: rocksmqdi berkasuser.yamlAnda sebelum melakukan pembaruan jika Anda ingin tetap menggunakan RocksMQ. - Untuk mengubah antrian pesan pada instance yang sedang berjalan, lihat Beralih dari RocksMQ ke Woodpecker.