Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Praktik terbaik Amazon MQ untuk ActiveMQ

Gunakan ini sebagai referensi untuk menemukan rekomendasi dengan cepat guna memaksimalkan performa dan meminimalkan biaya throughput saat bekerja dengan broker ActiveMQ di Amazon MQ.

Jangan Pernah Memodifikasi atau Menghapus Antarmuka Jaringan Elastis Amazon MQ

Ketika Anda pertama kali membuat broker Amazon MQ, Amazon MQ menyediakan antarmuka jaringan elastis pada Virtual Private Cloud (VPC) di bawah akun Anda dan memerlukan sejumlah izin EC2. Antarmuka jaringan memungkinkan klien Anda (produsen atau konsumen) berkomunikasi dengan broker Amazon MQ. Antarmuka jaringan dianggap berada dalam lingkup layanan Amazon MQ, meski merupakan bagian dari VPC akun Anda.

Selalu Gunakan Pooling Koneksi

Dalam skenario dengan produsen tunggal dan konsumen tunggal (seperti tutorial Memulai: Membuat dan menghubungkan ke broker ActiveMQ), Anda dapat menggunakan satu kelas ActiveMQConnectionFactory untuk setiap produsen dan konsumen. Untuk informasi lebih lanjut, lihat ActiveMQConnectionFactory di situs web javadoc.io. Contoh:

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Establish a connection for the consumer.
final Connection consumerConnection = connectionFactory.createConnection();
consumerConnection.start();

Namun, dalam skenario yang lebih realistis dengan beberapa produsen dan konsumen, membuat sejumlah besar koneksi untuk beberapa produsen dapat menghabiskan banyak biaya. Dalam skenario ini, Anda harus mengelompokkan beberapa permintaan produsen menggunakan kelas PooledConnectionFactory. Untuk informasi lebih lanjut, lihat PooledConnectionFactory di situs web javadoc.io. Contoh:

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Create a pooled connection factory.
final PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
pooledConnectionFactory.setConnectionFactory(connectionFactory);
pooledConnectionFactory.setMaxConnections(10);

// Establish a connection for the producer.
final Connection producerConnection = pooledConnectionFactory.createConnection();
producerConnection.start();

Selalu Gunakan Transportasi Failover untuk Terhubung ke Beberapa Titik Akhir Broker

Jika Anda memerlukan aplikasi untuk terhubung ke beberapa titik akhir broker—misalnya, saat Anda menggunakan mode active/standby penerapan atau saat Anda bermigrasi dari broker pesan lokal ke Amazon MQ — gunakan Failover Transport untuk memungkinkan konsumen terhubung secara acak ke salah satunya. Contoh:

failover:(ssl://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:61617,ssl://b-9876l5k4-32ji-109h-8gfe-7d65c4b132a1-2.mq.us-west-2.amazonaws.com:61617)?randomize=true

Hindari Penggunaan Penyeleksi Pesan

Anda dapat menggunakan penyeleksi JMS untuk melampirkan filter ke langganan topik (untuk merutekan pesan ke konsumen berdasarkan kontennya). Namun, penggunaan penyeleksi JMS memenuhi buffer filter broker Amazon MQ, mencegahnya memfilter pesan.

Secara umum, buat agar konsumen tidak dapat merutekan pesan karena, untuk pemisahan yang optimal antara konsumen dan produsen, baik konsumen dan produsen harus bersifat sementara.

Memilih Tujuan Virtual untuk Langganan Tahan Lama

Langganan tahan lama dapat membantu memastikan bahwa konsumen menerima semua pesan yang dipublikasikan ke topik, misalnya, setelah koneksi yang hilang dipulihkan. Namun, penggunaan langganan tahan lama juga menghalangi penggunaan konsumen yang bersaing dan mungkin memiliki masalah performa dalam skala besar. Pertimbangkan untuk menggunakan tujuan virtual.

Jika menggunakan peering Amazon VPC, hindari IP klien dalam kisaran CIDR 10.0.0. 0/16

Jika Anda menyiapkan peering Amazon VPC antara infrastruktur on-premise dan broker Amazon MQ Anda, Anda tidak boleh mengonfigurasi koneksi klien dengan IP dalam kisaran CIDR. 10.0.0.0/16

Menonaktifkan Penyimpanan dan Pengiriman Bersamaan untuk Antrean dengan Konsumen Lambat

Secara default, Amazon MQ mengoptimalkan antrean dengan konsumen cepat:

Untuk menginstruksikan Amazon MQ agar mengoptimalkan antrean dengan konsumen lambat, atur concurrentStoreAndDispatchQueues atribut ke false. Contoh konfigurasi, lihat concurrentStoreAndDispatchQueues.

Memilih Tipe Instans Broker yang Tepat untuk Throughput Terbaik

Throughput pesan dari tipe instans broker tergantung pada kasus penggunaan aplikasi Anda dan faktor berikut:

Memahami hubungan antara ukuran pesan, latensi, dan throughput

Tergantung pada kasus penggunaan Anda, tipe instans broker yang lebih besar mungkin tidak selalu meningkatkan throughput sistem. Ketika ActiveMQ menulis pesan ke penyimpanan tahan lama, ukuran pesan Anda menentukan faktor pembatas sistem:

Ketika Anda menggunakan ActiveMQ dalam mode tetap, menulis ke penyimpanan biasanya terjadi ketika ada beberapa konsumen atau ketika konsumen lambat. Dalam modus tidak tetap, menulis ke penyimpanan juga terjadi dengan konsumen lambat jika memori tumpukan instans broker penuh.

Untuk menentukan tipe instans broker terbaik bagi aplikasi Anda, kami merekomendasikan pengujian tipe instans broker yang berbeda. Untuk informasi selengkapnya, lihat Broker instance types dan juga Mengukur Throughput untuk Amazon MQ menggunakan Tolok Ukur JMS.

Kasus penggunaan untuk jenis instans broker yang lebih besar

Ada tiga kasus penggunaan umum ketika tipe instans broker yang lebih besar meningkatkan throughput:

Pilih jenis penyimpanan broker yang tepat untuk throughput terbaik

Untuk memanfaatkan daya tahan dan replikasi yang tinggi di beberapa Availability Zone, gunakan Amazon EFS. Untuk memanfaatkan latensi rendah dan throughput yang tinggi, gunakan Amazon EBS. Untuk informasi selengkapnya, lihat Storage.

Mengonfigurasi Jaringan Broker dengan Benar

Saat Anda membuat jaringan broker, konfigurasikan dengan benar untuk aplikasi Anda:

Hindari mulai ulang lambat dengan memulihkan transaksi XA yang disiapkan

ActiveMQ mendukung transaksi terdistribusi (XA). Mengetahui cara ActiveMQ memproses transaksi XA dapat membantu menghindari waktu pemulihan yang lambat untuk mulai ulang dan failover broker di Amazon MQ

Transaksi XA yang disiapkan dan belum terselesaikan akan diputar ulang pada setiap mulai ulang. Jika masih belum terselesaikan, jumlahnya akan bertambah dari waktu ke waktu, secara signifikan meningkatkan waktu yang dibutuhkan untuk memulai broker. Hal ini memengaruhi waktu mulai ulang dan failover. Anda harus menyelesaikan transaksi ini dengan commit() atau rollback() agar performa tidak menurun seiring waktu.

Untuk memantau transaksi XA siap yang belum terselesaikan, Anda dapat menggunakan JournalFilesForFastRecovery metrik di Amazon CloudWatch Logs. Jika jumlah ini meningkat, atau secara konsisten lebih tinggi dari 1, Anda harus memulihkan transaksi yang belum terselesaikan dengan kode yang serupa dengan contoh berikut. Untuk informasi selengkapnya, lihat Quotas in Amazon MQ.

Kode contoh berikut berjalan menelusuri transaksi XA yang disiapkan dan menutupnya dengan rollback().

import org.apache.activemq.ActiveMQXAConnectionFactory;

import javax.jms.XAConnection;
import javax.jms.XASession;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;

public class RecoverXaTransactions {
    private static final ActiveMQXAConnectionFactory ACTIVE_MQ_CONNECTION_FACTORY;
    final static String WIRE_LEVEL_ENDPOINT =
            "tcp://localhost:61616";;
    static {
        final String activeMqUsername = "MyUsername123";
        final String activeMqPassword = "MyPassword456";
        ACTIVE_MQ_CONNECTION_FACTORY = new ActiveMQXAConnectionFactory(activeMqUsername, activeMqPassword, WIRE_LEVEL_ENDPOINT);
        ACTIVE_MQ_CONNECTION_FACTORY.setUserName(activeMqUsername);
        ACTIVE_MQ_CONNECTION_FACTORY.setPassword(activeMqPassword);
    }

    public static void main(String[] args) {
        try {
            final XAConnection connection = ACTIVE_MQ_CONNECTION_FACTORY.createXAConnection();
            XASession xaSession = connection.createXASession();
            XAResource xaRes = xaSession.getXAResource();

            for (Xid id : xaRes.recover(XAResource.TMENDRSCAN)) {
                xaRes.rollback(id);
            }
            connection.close();

        } catch (Exception e) {          
        }
    }
}

Dalam skenario dunia nyata, Anda dapat memeriksa transaksi XA yang disiapkan pada Manajer Transaksi XA. Kemudian Anda dapat memutuskan apakah akan menangani setiap transaksi yang disiapkan dengan rollback() atau commit().

Selalu Verifikasi Sertifikat TLS Broker Terhadap Nama Alternatif Subjeknya

Broker Amazon MQ menyajikan sertifikat server yang mengidentifikasi broker dengan nama domain yang sepenuhnya memenuhi syarat (FQDN). Klien Anda bertanggung jawab untuk memverifikasi sertifikat ini saat membuat koneksi TLS.

Contoh FQDNS:

b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.ap-southeast-2.amazonaws.com
b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-2.mq.ap-southeast-2.amazonaws.com

Setiap instans broker Amazon MQ for ActiveMQ memiliki nama host sendiri, yang selalu membawa akhiran instance. Broker instans tunggal memiliki satu nama host, diakhiri dengan. -1 Penye active/standby baran memiliki dua, berakhir dengan -1 dan-2. Sertifikat broker mencakup kedua nama, sehingga klien yang terhubung melalui Failover Transport berhasil memverifikasi terhadap titik akhir mana pun yang digunakannya.

Gunakan nama host persis seperti yang diiklankan Amazon MQ, termasuk akhiran instans. Verifikasi setiap titik akhir di URI Transportasi Failover Anda terhadap nama host di titik akhir tersebut.

Kami menyarankan Anda mengonfigurasi klien Anda untuk memverifikasi sertifikat broker seperti yang dijelaskan dalam RFC 9525, Identitas Layanan di TLS. Ketika klien Anda terhubung ke broker Amazon MQ, ia harus melakukan hal berikut:

Untuk informasi selengkapnya tentang sertifikat broker Amazon MQ, termasuk jenis sertifikat yang dikeluarkan Amazon MQ dan contoh beranotasi masing-masing, lihat. Sertifikat TLS broker Amazon MQ