Hướng dẫn deploy rabbit đối với Module: InnoMKTAuto
1) Giới Thiệu
RabbitMQ là một hệ thống xử lý thông điệp mã nguồn mở (open-source message broker) được sử dụng để truyền và xử lý thông điệp giữa các ứng dụng và dịch vụ. Đây là một giải pháp mạnh mẽ cho việc xây dựng các hệ thống phân tán, các ứng dụng liên quan đến xử lý thông điệp và nhiều tình huống khác.
Trong tài liệu này, chúng ta sẽ hướng dẫn cách triển khai RabbitMQ trên môi trường máy chủ Linux sử dụng gói cài đặt chính thống và tích hợp cơ bản với PHP
2) Triển khai RabbitMQ
2.1) Cài đặt RabbitMQ trên CentOS sử dụng yum
Bước 1: Cài đặt EPEL Repository
EPEL (Extra Packages for Enterprise Linux) là một kho lưu trữ chứa các gói bổ sung cho hệ điều hành dựa trên RHEL (Red Hat Enterprise Linux) như CentOS.
sudo yum install epel-release
Bước 2: Cài đặt Erlang
RabbitMQ yêu cầu Erlang để hoạt động, vì vậy bạn cần cài đặt Erlang trước.
sudo yum install erlang
Bước 3: Cài đặt RabbitMQ
Cài đặt RabbitMQ bằng yum:
sudo yum install rabbitmq-server
Bước 4: Khởi động và kích hoạt rabbitMQ
Thêm người dùng mới:
Gán quyền cho người dùng:
Gán quyền cho người dùng trên virtual host cụ thể :
Bước 5: Tích hợp thư viện PHP amqp trên CentOS
2.2) Cài đặt RabbitMQ trên Ubutu
Bước 1: Cập nhật hệ thống:
Bước 2: Cài đặt Erlang
RabbitMQ chạy trên nền tảng Erlang, do đó bạn cần cài đặt Erlang trước.
Bước 3: Cài đặt RabbitMQ
Bước 4: Quản lý RabbitMQ
Dưới đây là một số lệnh quản lý cơ bản:
Khởi động rabbitmq:
Dừng rabbitmq:
Khởi động cùng hệ thống:
2.3) Cấu hình trên Server Tùy Chỉnh (Ví dụ: Server 214)
Bước 1: Chuẩn bị môi trường
Cài đặt Web Server và PHP
Hệ điều hành: CentOS
Cài đặt Apache và PHP:
sudo yum install httpd php
Bước 2: Cài đặt MySQL Server:
Chạy lệnh sau để cài đặt MySQL Server trên CentOS:
Bước 3: Khởi động và Kích hoạt dịch vụ MySQL
Sau khi khởi động dịch vụ, hãy chạy lệnh bảo mật để đặt mật khẩu cho tài khoản root của MySQL:
Bước 4: Tạo cơ sở dữ liệu và người dùng
Đăng nhập vào MySQL với tài khoản root:
Tạo cơ sở dữ liệu:
Tạo người dùng và cấp quyền cho cơ sở dữ liệu:
Sử dụng mysqli_connect trong PHP
Tạo tệp config.php hoặc tệp cấu hình tương tự để cấu hình kết nối đến cơ sở dữ liệu:
Sử dụng Kết nối trong ứng dụng PHP
Sau khi đã cấu hình config.php và kết nối MySQL trong tệp cấu hình, bạn có thể sử dụng biến $conn để thực hiện các truy vấn và thao tác với cơ sở dữ liệu.
Tạo index.php
Để tạo một cơ sở dữ liệu và bảng trong MySQL
Tạo 1 file demo.php
Ứng dụng Navicat
Navicat là một ứng dụng quản lý và quản lý cơ sở dữ liệu rất phổ biến.
Mở Navicat.
Chọn "Connection" hoặc "Kết nối" từ thanh công cụ hoặc trong menu "File".
Điền các thông tin kết nối như tên miền hoặc địa chỉ IP của máy chủ cơ sở dữ liệu, cổng, tên người dùng và mật khẩu.
Chọn "Test Connection" hoặc "Kiểm tra kết nối" để kiểm tra xem kết nối có thành công hay không.
Sau khi kết nối thành công, đặt tên cho kết nối và nhấn OK.
Query (Truy vấn) dữ liệu Navicat:
Trong cửa sổ chính của Navicat, chọn "Query" hoặc "Truy vấn" từ thanh công cụ hoặc trong menu "Database".
Viết truy vấn SQL vào khung trống.
Nhấn nút "Execute" hoặc "Thực hiện" để thực thi truy vấn và xem kết quả.
Query SQL nhiều bảng và nhiều cột:
Sau khi chạy xong SQL ở trên ( chạy trong ứng dụng Navicat ) thì kết quả như hình dưới
Bước 6: Chạy thực nghiệm RabbitMQ ( Cả 2 server )
Tạo một tập tin PHP mới:
Tạo một tập tin PHP mới trong project, ví dụ index.php.
Thêm phần thư viện AMQP vào composer.json
Mở tệp composer.json bằng trình chỉnh sửa văn bản và thêm phần "require" với thư viện php-amqp:
Mở terminal chạy lệnh:
composer update
Demo code:
2.4) Chạy thực nghiệm RabbitMQ đối với nhiều khách hàng
A) Ở server 212
Mở terminal chạy lệnh:
php modules/InnoMKTAuto/cron/rabbitmq/portal_data.php 3vgLMFtlivmpAnEIfsmOgPvtZ2nI287ttc67iphH database_demo
Trong đó
unique_com_id tương ứng với mỗi khách hàng khác nhau
Ví dụ:vgLMFtlivmpAnEIfsmOgPvtZ2nI287ttc67iphH
Tên database cần truyền vào ở server 212:
database_demo
B) Ở server 214:
Mở terminal chạy lệnh:
CREATE USER 'your_db_user'@'localhost' IDENTIFIED BY 'your_db_password';
GRANT ALL PRIVILEGES ON your_db_name.* TO 'your_db_user'@'localhost';
FLUSH PRIVILEGES;
<?php
// Include tệp cấu hình
require_once('config.php');
$conn = mysqli_connect(DB_HOST, DB_USER, DB_PASSWORD, DB_NAME);
if (!$conn) {
die("Kết nối thất bại: " . mysqli_connect_error());
}
// Thực hiện truy vấn
$sql = "SELECT * FROM abmsco_innomktauto";
$result = mysqli_query($conn, $sql);
// Kiểm tra và xử lý kết quả
if (mysqli_num_rows($result) > 0) {
while ($row = mysqli_fetch_assoc($result)) {
echo "ID: " . $row['innomktautoid'] . " - Tên: " . $row['mkt_status'] . "<br>";
}
} else {
echo "Không có dữ liệu.";
}
// Đóng kết nối
mysqli_close($conn);
?>
<?php
require_once('config.php');
$conn = mysqli_connect(DB_HOST, DB_USER, DB_PASSWORD, DB_NAME);
if (!$conn) {
die("Kết nối thất bại: " . mysqli_connect_error());
}
// Bắt đầu giao dịch
mysqli_begin_transaction($conn);
// Tạo cơ sở dữ liệu
$createDbQuery = "CREATE DATABASE IF NOT EXISTS your_database_name";
if (!mysqli_query($conn, $createDbQuery)) {
mysqli_rollback($conn);
echo "Lỗi trong quá trình tạo cơ sở dữ liệu: " . mysqli_error($conn);
exit;
}
// Chọn cơ sở dữ liệu để sử dụng
mysqli_select_db($conn, 'your_database_name');
// Tạo bảng trong cơ sở dữ liệu
$createTableQuery = "CREATE TABLE IF NOT EXISTS `your_table_name` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`column1` varchar(255) DEFAULT NULL,
`column2` text,
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8";
if (!mysqli_query($conn, $createTableQuery)) {
mysqli_rollback($conn);
echo "Lỗi trong quá trình tạo bảng: " . mysqli_error($conn);
exit;
}
// Nếu tất cả các truy vấn thành công, thực hiện giao dịch
mysqli_commit($conn);
echo "Tạo cơ sở dữ liệu và bảng thành công.";
mysqli_close($conn);
?>
