Add redis_queue_v7 to support redis server 7.x. (#15)

Author: zhoufeng1989

cloud/common.go

@@ -13,11 +13,13 @@ import (
 type Provider string
 
 const (
-	AWSProvider             Provider = "aws"
-	TencentCloudProvider    Provider = "tencentcloud"
-	StandaloneRedisProvider Provider = "standalone_redis"
-	ClusterRedisProvider    Provider = "cluster_redis"
-	AliCloudStorageProvider Provider = "alicloud_storage"
+	AWSProvider               Provider = "aws"
+	TencentCloudProvider      Provider = "tencentcloud"
+	StandaloneRedisProvider   Provider = "standalone_redis"
+	ClusterRedisProvider      Provider = "cluster_redis"
+	StandaloneRedisProviderV7 Provider = "standalone_redis_v7"
+	ClusterRedisProviderV7    Provider = "cluster_redis_v7"
+	AliCloudStorageProvider   Provider = "alicloud_storage"
 )
 
 var (

cloud/examples/queue/queue.go

@@ -55,6 +55,21 @@ func main() {
 		Region:    "aws_region_xxx",
 	}
 	queue_examples("aws_queue_name", optionForAWS)
+
+	dialTimeout := 5 * time.Second
+	clusterRedisQueueOptionV7 := queue.ClusterRedisQueueOptionV7{
+		ClusterRedisQueueOption: queue.ClusterRedisQueueOption{
+			Addrs: []string{
+				"localhost:30001",
+				"localhost:30002",
+				"localhost:30003",
+			},
+			ConsumerGroup: "save_task_consumer_group_2",
+			DialTimeout:   &dialTimeout,
+			Idle:          10,
+		},
+	}
+	queue_examples("redis_cluster_queue_v7", clusterRedisQueueOptionV7)
 }
 
 func queue_examples(queueOrTopicName string, option cloud.Option) {
@@ -64,6 +79,7 @@ func queue_examples(queueOrTopicName string, option cloud.Option) {
 		return
 	}
 	defer service.Close()
+	fmt.Printf("get service %+v\n", service)
 
 	producer, err := service.CreateProducer()
 	if err != nil {

cloud/queue/queue.go

@@ -36,6 +36,10 @@ func GetQueueService(queueOrTopicSubName string, option cloud.Option) (QueueServ
 		return GetStandaloneRedisQueueService(queueOrTopicSubName, option)
 	} else if option.GetProvider() == cloud.ClusterRedisProvider {
 		return GetClusterRedisQueueService(queueOrTopicSubName, option)
+	} else if option.GetProvider() == cloud.StandaloneRedisProviderV7 {
+		return getStandaloneRedisQueueServiceForV7(queueOrTopicSubName, option)
+	} else if option.GetProvider() == cloud.ClusterRedisProviderV7 {
+		return getClusterRedisQueueServiceV7(queueOrTopicSubName, option)
 	}
 	return nil, cloud.ErrUnsupportedCloudProvider
 }