feature: Optimized pubsub api demo (#594)

Author: codedededi

demo/pubsub/README.md

@@ -0,0 +1,20 @@
+You can run server/client demo with different component names.   
+It is worth noting that both server and client demo should set the same store name by param `-s`.  
+For example:   
+```shell
+cd ${project_path}/demo/pubsub/server/
+// 1. start subscriber
+go build -o subscriber
+/.subscriber -s pub_subs_demo
+
+// 2. start layotto
+cd ${project_path}/cmd/layotto
+go build -o layotto
+./layotto start -c ../../configs/config_in_memory.json
+
+// 3. start publisher
+ cd ${project_path}/demo/pubsub/client/
+go build -o publisher
+ ./publisher -s pub_subs_demo
+
+```

demo/pubsub/common/client/publish_client.go renamed to demo/pubsub/client/publish_client.go

@@ -34,6 +34,9 @@ func init() {
 
 func main() {
 	flag.Parse()
+	if storeName == "" {
+		panic("storeName is empty.")
+	}
 	// 1. construct client
 	cli, err := client.NewClient()
 	if err != nil {

demo/pubsub/in-memory/in-memory.go

@@ -39,6 +39,9 @@ func init() {
 
 func main() {
 	flag.Parse()
+	if storeName == "" {
+		panic("storeName is empty.")
+	}
 	// start a grpc server for callback
 	testSub()
 }

demo/pubsub/redis/client/publish_client.go

@@ -48,14 +48,14 @@ Parameter Description:
 Build:
 
 ```shell
- cd ${project_path}/demo/pubsub/redis/server/
+ cd ${project_path}/demo/pubsub/server/
  go build -o subscriber
  ```
 
 Start subscriber:
 
 ```shell @background
- ./subscriber
+ ./subscriber -s pub_subs_demo
 ```
 If the following information is printed out, it means the startup is successful:
 
@@ -98,9 +98,9 @@ After completion, the layotto file will be generated in the directory, run it:
 ### Step 4. Run the Publisher program and call Layotto to publish events
 
 ```shell
- cd ${project_path}/demo/pubsub/redis/client/
+ cd ${project_path}/demo/pubsub/client/
  go build -o publisher
- ./publisher
+ ./publisher -s pub_subs_demo
 ```
 
 If the following information is printed, the call is successful:

demo/pubsub/redis/server/subscribe_server.go

@@ -45,12 +45,12 @@ docker run -itd --name redis-test -p 6380:6379 redis
 
 ### 第二步：启动Subscriber程序,订阅事件
 ```shell
- cd ${project_path}/demo/pubsub/redis/server/
+ cd ${project_path}/demo/pubsub/server/
  go build -o subscriber
 ```
 
 ```shell @background
- ./subscriber
+ ./subscriber -s pub_subs_demo
 ```
 打印出如下信息则代表启动成功：
 
@@ -95,9 +95,9 @@ go build -o layotto
 ### 第四步：运行Publisher程序，调用Layotto发布事件
 
 ```shell
- cd ${project_path}/demo/pubsub/redis/client/
+ cd ${project_path}/demo/pubsub/client/
  go build -o publisher
- ./publisher
+ ./publisher -s pub_subs_demo
 ```
 
 打印出如下信息则代表调用成功：