Skip to content

Latest commit

 

History

History
49 lines (42 loc) · 2.51 KB

README.md

File metadata and controls

49 lines (42 loc) · 2.51 KB
Raw

hello-perf

High performance client that can be used as a skeleton to create the Microservices. It produces a series of messages and publishes to a topic, consumes the same from a persistent queue, and then sends the response to another topic.

The number of messages, message size and the steps in the pipeline (publish/consume/respond) are configurable. By default the three steps run in the same JVM, but it can be started separately as well.

How to run the client

Clone the repository and use gradle to build and run it. The program uses command line arguments

usage: App
 -c,--msgcount <arg>           number of messages to publish per thread
 -cc,--consume                 enable consume step
 -cq,--consumequeue <arg>      consume queue
 -ctc,--consumethreads <arg>   consume thread count
 -h,--hostname <arg>           hostname of the Solace pubsub+
 -p,--password <arg>           password
 -pm,--publishmode <arg>       publish mode: direct or persistent
 -pp,--publish                 enable publish step
 -pt,--publishtopic <arg>      publish topic
 -ptc,--publishthreads <arg>   publish thread count
 -rm,--respondmode <arg>       respond mode: direct or persistent
 -rr,--respond                 enable respond step
 -rt,--respondtopic <arg>      respond topic
 -rtc,--respondthreads <arg>   publish thread count
 -u,--username <arg>           username
 -v,--vpn <arg>                vpn name
 -z,--messagesize <arg>        message size in bytes

Sample command line

Publishing mode:
./gradlew run --args="-h='localhost:55555' -u=default -p=default -v=VPN2 -msgcount 10000 -pt a/b -cq a/b -rt a/b -pm persistent -pp"

Consumer Mode:
./gradlew run --args="-h='localhost:55555' -u=default -p=default -v=VPN2 -msgcount 10 -pt a/b -cq Test -rt a/b -cc"

Task :run 01:31:32 INFO c.e.s.h.App(23) - App Starting [main] Mar 05, 2019 1:31:32 AM com.solacesystems.jcsmp.protocol.impl.TcpClientChannel call INFO: Connecting to host 'orig=192.168.1.55:55555, host=192.168.1.55, port=55555' (host 1 of 1, smfclient 2, attempt 1 of 1, this_host_attempt: 1 of 1) Mar 05, 2019 1:31:32 AM com.solacesystems.jcsmp.protocol.impl.TcpClientChannel call INFO: Connected to host 'orig=192.168.1.55:55555, host=192.168.1.55, port=55555' (smfclient 2) 01:31:32 INFO c.e.s.h.PublishThread(65) - publish-thread - Started. [publish-thread] 01:31:33 INFO c.e.s.h.PublishThread(69) - Processing Time:Stopwatch:Publish 20000 messages:655.0ms [publish-thread] 01:31:33 INFO c.e.s.h.PublishThread(70) - publish-thread - Terminated. [publish-thread]