m

kuailedetanger · Sep 2, 2021 · e96c45c · e96c45c
1 parent 2071985
commit e96c45c
Show file tree

Hide file tree

Showing 47 changed files with 1,965 additions and 0 deletions.
diff --git a/mq_transaction/eureka/pom.xml b/mq_transaction/eureka/pom.xml
@@ -0,0 +1,66 @@
+<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.5.4</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>org.javaboy</groupId>
+    <artifactId>eureka</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>eureka</name>
+    <description>Demo project for Spring Boot</description>
+    <properties>
+        <java.version>11</java.version>
+        <spring-cloud.version>2020.0.3</spring-cloud.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-security</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.security</groupId>
+            <artifactId>spring-security-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>org.springframework.cloud</groupId>
+                <artifactId>spring-cloud-dependencies</artifactId>
+                <version>${spring-cloud.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/mq_transaction/eureka/src/main/java/org/javaboy/eureka/EurekaApplication.java b/mq_transaction/eureka/src/main/java/org/javaboy/eureka/EurekaApplication.java
@@ -0,0 +1,15 @@
+package org.javaboy.eureka;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
+
+@SpringBootApplication
+@EnableEurekaServer
+public class EurekaApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(EurekaApplication.class, args);
+    }
+
+}
diff --git a/mq_transaction/eureka/src/main/java/org/javaboy/eureka/SecurityConfig.java b/mq_transaction/eureka/src/main/java/org/javaboy/eureka/SecurityConfig.java
@@ -0,0 +1,26 @@
+package org.javaboy.eureka;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
+
+/**
+ * @author 江南一点雨
+ * @微信公众号 江南一点雨
+ * @网站 http://www.itboyhub.com
+ * @国际站 http://www.javaboy.org
+ * @微信 a_java_boy
+ * @GitHub https://github.com/lenve
+ * @Gitee https://gitee.com/lenve
+ */
+@Configuration
+public class SecurityConfig extends WebSecurityConfigurerAdapter {
+    @Override
+    protected void configure(HttpSecurity http) throws Exception {
+        http.authorizeRequests()
+                .anyRequest().authenticated()
+                .and()
+                .httpBasic()
+                .and().formLogin().and().csrf().disable();
+    }
+}
diff --git a/mq_transaction/eureka/src/main/resources/application.yml b/mq_transaction/eureka/src/main/resources/application.yml
@@ -0,0 +1,15 @@
+server:
+  port: 8761
+spring:
+  application:
+    name: eureka
+  security:
+    user:
+      name: javaboy
+      password: 123
+eureka:
+  client:
+    register-with-eureka: false
+    fetch-registry: false
+    serviceUrl:
+      defaultZone: http://javaboy:123@localhost:${server.port}/eureka/
diff --git a/mq_transaction/eureka/src/test/java/org/javaboy/eureka/EurekaApplicationTests.java b/mq_transaction/eureka/src/test/java/org/javaboy/eureka/EurekaApplicationTests.java
@@ -0,0 +1,13 @@
+package org.javaboy.eureka;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class EurekaApplicationTests {
+
+    @Test
+    void contextLoads() {
+    }
+
+}
diff --git a/mq_transaction/order/pom.xml b/mq_transaction/order/pom.xml
@@ -0,0 +1,80 @@
+<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.5.4</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>org.javaboy</groupId>
+    <artifactId>order</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>order</name>
+    <description>Demo project for Spring Boot</description>
+    <properties>
+        <java.version>11</java.version>
+        <spring-cloud.version>2020.0.3</spring-cloud.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <dependency>
+            <artifactId>service</artifactId>
+            <groupId>org.javaboy</groupId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.amqp</groupId>
+            <artifactId>spring-rabbit-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>org.springframework.cloud</groupId>
+                <artifactId>spring-cloud-dependencies</artifactId>
+                <version>${spring-cloud.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/mq_transaction/order/src/main/java/org/javaboy/order/OrderApplication.java b/mq_transaction/order/src/main/java/org/javaboy/order/OrderApplication.java
@@ -0,0 +1,13 @@
+package org.javaboy.order;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class OrderApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(OrderApplication.class, args);
+    }
+
+}
diff --git a/mq_transaction/order/src/main/java/org/javaboy/order/config/JmsConfig.java b/mq_transaction/order/src/main/java/org/javaboy/order/config/JmsConfig.java
@@ -0,0 +1,49 @@
+package org.javaboy.order.config;
+
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Created by mavlarn on 2018/3/17.
+ */
+@Configuration
+public class JmsConfig {
+
+//    @Bean
+//    public ConnectionFactory connectionFactory() {
+//        ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://localhost:61616");
+//        TransactionAwareConnectionFactoryProxy proxy = new TransactionAwareConnectionFactoryProxy();
+//        proxy.setTargetConnectionFactory(cf);
+//        proxy.setSynchedLocalTransactionAllowed(true);
+//        return proxy;
+//    }
+//
+//    @Bean
+//    public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory, MessageConverter jacksonJmsMessageConverter) {
+//        JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);
+//        jmsTemplate.setMessageConverter(jacksonJmsMessageConverter);
+//        jmsTemplate.setSessionTransacted(true);
+//        return jmsTemplate;
+//    }
+//
+//    @Bean
+//    public JmsListenerContainerFactory<?> msgFactory(ConnectionFactory cf,
+//                                                     PlatformTransactionManager transactionManager,
+//                                                     DefaultJmsListenerContainerFactoryConfigurer configurer) {
+//        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
+//        configurer.configure(factory, cf);
+//        factory.setReceiveTimeout(10000L);
+//        // FIXME: 使用非内置的activeMQ服务器，这个就不需要，
+////        factory.setCacheLevelName("CACHE_CONNECTION");
+//        factory.setTransactionManager(transactionManager);
+//        factory.setConcurrency("10");
+//        return factory;
+//    }
+//
+//    @Bean
+//    public MessageConverter jacksonJmsMessageConverter() {
+//        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
+//        converter.setTargetType(MessageType.TEXT);
+//        converter.setTypeIdPropertyName("_type");
+//        return converter;
+//    }
+}
diff --git a/mq_transaction/order/src/main/java/org/javaboy/order/config/RabbitConfig.java b/mq_transaction/order/src/main/java/org/javaboy/order/config/RabbitConfig.java
@@ -0,0 +1,48 @@
+package org.javaboy.order.config;
+
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RabbitConfig {
+
+    @Bean
+    Queue orderLockedQueue() {
+        return new Queue("order:locked");
+    }
+
+
+    @Bean
+    Queue orderFinishQueue() {
+        return new Queue("order:finish");
+    }
+
+
+    @Bean
+    Queue orderFailQueue() {
+        return new Queue("order:fail");
+    }
+
+
+    @Bean
+    Queue orderNewQueue() {
+        return new Queue("order:new");
+    }
+
+    @Bean
+    Queue orderTicketMoveQueue() {
+        return new Queue("order:ticket_move");
+    }
+
+    @Bean
+    Queue orderTicketErrorQueue() {
+        return new Queue("order:ticket_error");
+    }
+
+    @Bean
+    Queue orderPayQueue() {
+        return new Queue("order:pay");
+    }
+
+}
diff --git a/mq_transaction/order/src/main/java/org/javaboy/order/dao/OrderRepository.java b/mq_transaction/order/src/main/java/org/javaboy/order/dao/OrderRepository.java
@@ -0,0 +1,20 @@
+package org.javaboy.order.dao;
+
+
+import org.javaboy.order.domain.Order;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.time.ZonedDateTime;
+import java.util.List;
+
+/**
+ * Created by mavlarn on 2018/1/20.
+ */
+public interface OrderRepository extends JpaRepository<Order, Long> {
+
+    List<Order> findAllByCustomerId(Long customerId);
+
+    List<Order> findAllByStatusAndCreatedDateBefore(String status, ZonedDateTime checkTime);
+
+    Order findOneByUuid(String uuid);
+}