yanhongbin-aliIot-spring-boot-starter

KO | EN

gitlite — search

#javascript #python #hacktoberfest #react #ai #typescript #llm #go #golang #android #machine-learning #rust #deep-learning #linux

yanhongbin-aliIot-spring-boot-starter

★ 8 Open GitHub ↗

整理了下代码,对于阿里iot服务端订阅接入封装为spring boot starter

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

#快速接入阿里iot平台服务端订阅
以下自定义类需要配置为 Spring Bean 才能自动被使用
实现com.yanhongbin.aliiot.message.service.MessageProcessor接口，以自定义消息处理器

实现java.util.concurrent.ThreadFactory接口，可自定义线程池中的线程工厂

实现java.util.concurrent.RejectedExecutionHandler接口，可以自定义线程的拒绝策略，也可使用ThreadPoolExecutor自带的策略，配置为Spring Bean即可

##按照如下方式配置即可使用
```
spring:
  yanhongbin:
    ali:
      iot:
        config:
          # 阿里云物联平台账号信息
          accessKeyId: ****
          accessKeySecret: ****
          # 物联网平台对应地区
          regionId: SHANGHAI
          # 阿里云账号UID
          uid: ****
          # 物联平台产品key
          productKey: ****
          # 消息处理器beanID配置，使用Mns模式时必须，key为产品key，value为消息处理器的对应BeanName
          message-processor-bean-id:
            ****: defaultMessageProcessor
        # 连接相关配置
        connect:
          # 连接类型 支持 amqp，mns，http/2 （http/2 已被废弃）
          type: amqp
          # 服务端订阅开关，不配置默认不开启
          subscribe-switch: on
        # amqp连接信息配置，使用amqp模式时必须
        amqp:
          # 消费组id和对应的消息持利器BeanName配置
          consumer-group-message-config:
            - consumer-groupId: DEFAULT_GROUP
              message-processor-beanId: messageProcessor
          # 加密方法配置
          signMethod: hmacsha1
thread:
  pool:
    # 是否使用线程池处理消息，不使用则单线程阻塞处理
    thread-pool-switch: true
    # 以下相关配置均有默认值
    # 核心线程数
    core-pool-size: 4
    # 最大线程数
    maximum-pool-size: 4
    # 线程存活时间
    keep-alive-time: 0
    # 时间单位
    unit: milliseconds
    # 工作队列大小
    work-queue-size: 8
```

yanhongbin-aliIot-spring-boot-starter

Explore Similar Repositories

Was this content helpful?

Recent Feedback

Download README