Usage Proxy

Refer to Deploy a cluster on bare metal (http://pulsar.apache.org/docs/en/deploy-bare-metal/)

1. Prepare zookeeper cluster (refer to cluster deploy doc)

2. Initialize cluster metadata (refer to cluster deploy doc)

3. Prepare bookkeeper cluster (refer to cluster deploy doc)

4. copy the pulsar-protocol-handler-amqp-${version}.nar to the $PULSAR_HOME/protocols directory

5. start broker

broker config

defaultNumberOfNamespaceBundles=1

messagingProtocols=amqpn
protocolHandlerDirectory=./protocols
brokerServicePort=6651
amqpListeners=amqp://127.0.0.1:5672

useProxy=true
amqpProxyPort=5682

6. reset the number of the namespace public/default to 1

$PULSAR_HOME/bin/pulsar-admin namespaces delete public/default
$PULSAR_HOME/bin/pulsar-admin namespaces create -b 1 public/default
$PULSAR_HOME/bin/pulsar-admin namespaces set-retention -s 100M -t 3d public/default

7. prepare exchange and qu for test

ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setVirtualHost("default");
connectionFactory.setHost("127.0.0.1");
connectionFactory.setPort(5681);
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
String ex = "ex-perf";
String qu = "qu-perf";
channel.exchangeDeclare(ex, BuiltinExchangeType.DIRECT, true);
channel.queueDeclare(qu, true, false, false, null);
channel.queueBind(qu, ex, qu);
channel.close();
connection.close();

7. download RabbitMQ perf tool and test

(https://bintray.com/rabbitmq/java-tools/download_file?file_path=perf-test%2F2.11.0%2Frabbitmq-perf-test-2.11.0-bin.tar.gz)

$RABBITMQ_PERF_TOOL_HOME/bin/runjava com.rabbitmq.perf.PerfTest -e ex-perf -u qu-perf -r 1000 -h amqp://127.0.0.1:5681 -p