Three_Group
/
OperationPlatform
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat:运营平台

master
Yunfei Du 2024-05-31 22:08:45 +08:00
commit 9fd3eceaec
17 changed files with 624 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
.gitignore vendored 100644
View File

@ -0,0 +1,38 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

8
.idea/.gitignore vendored 100644
View File

@ -0,0 +1,8 @@
# 默认忽略的文件
/shelf/
/workspace.xml
# 基于编辑器的 HTTP 客户端请求
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml

8
.idea/encodings.xml 100644
View File

@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding" defaultCharsetForPropertiesFiles="UTF-8">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
<file url="PROJECT" charset="UTF-8" />
</component>
</project>

5
.idea/inspectionProfiles/Project_Default.xml 100644
View File

@ -0,0 +1,5 @@
<component name="InspectionProjectProfileManager">
<profile version="1.0">
<option name="myName" value="Project Default" />
</profile>
</component>

14
.idea/misc.xml 100644
View File

@ -0,0 +1,14 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/out" />
</component>
</project>

6
.idea/vcs.xml 100644
View File

@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="" vcs="Git" />
</component>
</project>

111
pom.xml 100644
View File

@ -0,0 +1,111 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.load</groupId>
<artifactId>operation-platform</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<spring-boot.version>2.6.13</spring-boot.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- MQTT-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.32</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
<version>1.2.5</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.12.0</version>
</dependency>
<!-- redis-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<exclusions>
<exclusion>
<groupId>io.lettuce</groupId>
<artifactId>lettuce-core</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- mq-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
<configuration>
<source>17</source>
<target>17</target>
<encoding>UTF-8</encoding>
</configuration>
</plugin>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring-boot.version}</version>
<configuration>
<mainClass>com.load.MqttApplication</mainClass>
<skip>true</skip>
</configuration>
<executions>
<execution>
<id>repackage</id>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

17
src/main/java/com/load/MqttApplication.java 100644
View File

@ -0,0 +1,17 @@
package com.load;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @ClassName MqttApplication
* @Description 描述
* @Author YunFei.Du
* @Date 2024/5/30 9:19
*/
@SpringBootApplication
public class MqttApplication {
public static void main(String[] args) {
SpringApplication.run ( MqttApplication.class ,args);
}
}

86
src/main/java/com/load/SubscribeSample.java 100644
View File

@ -0,0 +1,86 @@
package com.load;
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
/**
* 订阅 MQTT 主题
*/
public class SubscribeSample {
/**
* 主程序入口。
* 创建一个MQTT客户端，并连接到指定的代理服务器，订阅特定的主题，并处理接收到的消息。
*
*/
public static void main(String[] args) {
/**
* 代理地址
*/
String broker = "tcp://47.92.127.83:1883";
/**
* 主题
*/
String topic = "mqtt/test";
String username = "emqx";
String password = "public";
/**
* 客户端ID(随机)
*/
String clientid = "protocol-parsing";
int qos = 0;
try {
// 创建MqttClient实例
MqttClient client = new MqttClient(broker, clientid, new MemoryPersistence());
// 设置连接选项
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName(username);
options.setPassword(password.toCharArray());
options.setConnectionTimeout(60);
// 堵塞60S
options.setKeepAliveInterval(60);
// 设置MQTT消息回调处理
client.setCallback(new MqttCallback() {
/**
* 连接丢失时的处理逻辑。
*
* @param cause 引发连接丢失的异常对象
*/
public void connectionLost(Throwable cause) {
System.out.println("connectionLost: " + cause.getMessage());
}
/**
* 当接收到消息时的处理逻辑。
*
* @param topic 接收到消息的主题
* @param message 接收到的消息对象
*/
public void messageArrived(String topic, MqttMessage message) {
System.out.println("topic: " + topic);
System.out.println("Qos: " + message.getQos());
System.out.println("message content: " + new String(message.getPayload()));
}
/**
* 消息成功发送完成的处理逻辑。
*
* @param token 表示消息发送过程的令牌
*/
public void deliveryComplete(IMqttDeliveryToken token) {
System.out.println("deliveryComplete---------" + token.isComplete());
}
});
// 连接到MQTT代理
client.connect(options);
// 订阅主题
client.subscribe(topic, qos);
} catch (Exception e) {
e.printStackTrace();
}
}
}

54
src/main/java/com/load/config/RabbitmqConfig.java 100644
View File

@ -0,0 +1,54 @@
package com.load.config;
import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* rabbitMq配置类
*
* @author YunFei·Du
* @ClassName: RabbitmqConfig
* @Description: rabbitMq配置类
* @CreateTime: 2024/5/27 16:56
*/
@Configuration
public class RabbitmqConfig {
public static final String QUEUE_INFORM_EMAIL = "queue_inform_email";
public static final String QUEUE_INFORM_SMS = "disconnect_connect";
public static final String EXCHANGE_TOPICS_INFORM="exchange_topics_inform";
public static final String ROUTINGKEY_EMAIL="inform.#.email.#";
public static final String ROUTINGKEY_SMS="inform.#.sms.#";
@Bean(EXCHANGE_TOPICS_INFORM)
public Exchange EXCHANGE_TOPICS_INFORM(){
//durable(true) 持久化，mq重启之后交换机还在
return ExchangeBuilder.topicExchange(EXCHANGE_TOPICS_INFORM).durable(true).build();
}
//声明QUEUE_INFORM_EMAIL队列
@Bean(QUEUE_INFORM_EMAIL)
public Queue QUEUE_INFORM_EMAIL(){
return new Queue(QUEUE_INFORM_EMAIL);
}
//声明QUEUE_INFORM_SMS队列
@Bean(QUEUE_INFORM_SMS)
public Queue QUEUE_INFORM_SMS(){
return new Queue(QUEUE_INFORM_SMS);
}
//ROUTINGKEY_EMAIL队列绑定交换机，指定routingKey
@Bean
public Binding BINDING_QUEUE_INFORM_EMAIL(@Qualifier(QUEUE_INFORM_EMAIL) Queue queue,
@Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){
return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_EMAIL).noargs();
}
//ROUTINGKEY_SMS队列绑定交换机，指定routingKey
@Bean
public Binding BINDING_ROUTINGKEY_SMS(@Qualifier(QUEUE_INFORM_SMS) Queue queue,
@Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange){
return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY_SMS).noargs();
}
}

33
src/main/java/com/load/config/RestTemplateConfig.java 100644
View File

@ -0,0 +1,33 @@
package com.load.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;
/**
* rest配置类
*
* @author YunFei·Du
* @ClassName: RestTemplateConfig
* @Description: rest配置类
* @CreateTime: 2024/5/27 10:01
*/
@Configuration
public class RestTemplateConfig {
@Bean
public RestTemplate restTemplate(ClientHttpRequestFactory factory) {
return new RestTemplate(factory);
}
@Bean
public ClientHttpRequestFactory simpleClientHttpRequestFactory() {
SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
//超时设置
factory.setReadTimeout(5000);//ms
factory.setConnectTimeout(15000);//ms
return factory;
}
}

42
src/main/java/com/load/mqtt/MessageCallbackService.java 100644
View File

@ -0,0 +1,42 @@
package com.load.mqtt;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.stereotype.Service;
/**
* 消息回调服务 (回执消息类)
* @author YunFei.Du
* @date 22:37 2024/5/30
*/
@Service
public class MessageCallbackService implements MqttCallback {
@Override
public void connectionLost(Throwable cause) {
System.out.println("connectionLost: " + cause.getMessage());
}
/**
* 接收消息
* @param topic
* @param message
*/
@Override
public void messageArrived(String topic, MqttMessage message) {
System.out.println("topic: " + topic);
System.out.println("Qos: " + message.getQos());
System.out.println("message content: " + new String(message.getPayload()));
}
//
/**
* 发送消息
* @param token
*/
@Override
public void deliveryComplete(IMqttDeliveryToken token) {
System.out.println("deliveryComplete---------" + token.isComplete());
}
}

58
src/main/java/com/load/mqtt/MqttFactory.java 100644
View File

@ -0,0 +1,58 @@
package com.load.mqtt;
import lombok.AllArgsConstructor;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.stereotype.Service;
/**
* Mqtt工厂
* @author YunFei.Du
* @date 22:38 2024/5/30
*/
@Service
@AllArgsConstructor
public class MqttFactory {
private final MessageCallbackService messageCallbackService;
// 连接参数
/**
* 创建Mqtt 客户端
* @param mqttProperties
* @return
*/
public MqttClient createClient(MqttProperties mqttProperties){
MqttClient mqttClient =null;
try {
mqttClient=new MqttClient ( mqttProperties.getBroker() , mqttProperties.getClientId() , new MemoryPersistence() );
MqttConnectOptions options = new MqttConnectOptions ( );
//都不为空
if (mqttProperties.isLogin()){
options.setUserName ( mqttProperties.getUsername() );
options.setPassword ( mqttProperties.getPassword().toCharArray() );
}
options.setConnectionTimeout(60);
options.setKeepAliveInterval(60);
mqttClient.connect ( options );
//监听
mqttClient.setCallback ( messageCallbackService );
mqttClient.subscribe ( mqttProperties.getTopic(),0 );
} catch (MqttException e) {
throw new RuntimeException ( e );
}
// try {
//
// } catch (MqttException e) {
// throw new RuntimeException ( e );
// }
return mqttClient;
}
}

51
src/main/java/com/load/mqtt/MqttProperties.java 100644
View File

@ -0,0 +1,51 @@
package com.load.mqtt;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.commons.lang3.StringUtils;
/**
* 配置中心
* @author YunFei.Du
* @date 8:53 2024/5/30
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class MqttProperties {
private String broker;
private String topic;
private String username;
private String password;
private String clientId;
/**
* 构建mqtt配置
* @param ip
* @param topic
* @return
*/
public static MqttProperties configBuild(String ip, String topic){
return MqttProperties.builder()
.broker("tcp://"+ip+":1883")
.topic(topic)
.username("admin")
.password("public")
.clientId("protocol-parsing") //协议解析 定值 --> 配置
.build();
}
/**
* 判断是否可以登录
* @return
*/
public boolean isLogin(){
// commons-lang3
return StringUtils.isBlank ( username ) && !StringUtils.isBlank ( password );
}
}

33
src/main/java/com/load/rebbitmq/MsgHandle.java 100644
View File

@ -0,0 +1,33 @@
package com.load.rebbitmq;
import com.load.mqtt.MqttFactory;
import com.load.mqtt.MqttProperties;
import lombok.extern.log4j.Log4j2;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* 信息处理器
* @author YunFei.Du
* @date 9:21 2024/5/30
*/
@Component
@Log4j2
public class MsgHandle {
@Autowired
private MqttFactory mqttFactory;
@RabbitListener(queues = {"create.topic"})
private void msg(String msg){
log.info ( "接收到消息：{}" , msg );
MqttProperties mqttProperties = MqttProperties.configBuild ( "47.92.127.83", "mqtt/test" );
log.info ( "接收信息初始化程序:{}" , mqttProperties);
MqttClient client = mqttFactory.createClient ( mqttProperties );
log.info ( "client创建成功:{}", client.getClientId () );
}
}

50
src/main/java/com/load/rebbitmq/RabbitConfig.java 100644
View File

@ -0,0 +1,50 @@
package com.load.rebbitmq;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* rabbit 配置类
* @author YunFei.Du
* @date 8:39 2024/5/31
*/
@Configuration
public class RabbitConfig {
/**
* 创建队列
* @return
*/
@Bean
public Queue initQueue() {
return new Queue ("create.topic", true); // true-->队列持久
}
/**
* 创建direct交换机
* @return
*/
@Bean
public DirectExchange direct(){
return new DirectExchange ("topic.direct");
}
/**
* 绑定队列和交换机
* @param direct
* @param initQueue
* @return
*/
@Bean
public Binding binding1a(DirectExchange direct, Queue initQueue){
return BindingBuilder.bind(initQueue)
.to(direct)
.with("protocol-parsing");
}
}

10
src/main/resources/application.yml 100644
View File

@ -0,0 +1,10 @@
server:
port: 83
spring:
application:
# 协议解析
name: protocol-parsing
rabbitmq:
host: 111.229.102.61
port: 5672