2. 程式人生 > >RabbitMQ訊息可靠性投遞解決方案 - 基於SpringBoot實現

RabbitMQ訊息可靠性投遞解決方案 - 基於SpringBoot實現

阿新 • • 發佈：2018-12-25

https://www.imooc.com/article/49814

參考地址：

https://www.imooc.com/t/2726237

談到訊息的可靠性投遞，無法避免的，在實際的工作中會經常碰到，比如一些核心業務需要保障訊息不丟失，接下來我們看一個可靠性投遞的流程圖，說明可靠性投遞的概念：

https://img2.mukewang.com/5b65729e0001439310630624.jpg

  • Step 1： 首先把訊息資訊(業務資料）儲存到資料庫中，緊接著，我們再把這個訊息記錄也儲存到一張訊息記錄表裡（或者另外一個同源資料庫的訊息記錄表）

  • Step 2：傳送訊息到MQ Broker節點（採用confirm方式傳送，會有非同步的返回結果）

  • Step 3、4：生產者端接受MQ Broker節點返回的Confirm確認訊息結果，然後進行更新訊息記錄表裡的訊息狀態。比如預設Status = 0 當收到訊息確認成功後，更新為1即可！

  • Step 5：但是在訊息確認這個過程中可能由於網路閃斷、MQ Broker端異常等原因導致 回送訊息失敗或者異常。這個時候就需要傳送方（生產者）對訊息進行可靠性投遞了，保障訊息不丟失，100%的投遞成功！（有一種極限情況是閃斷，Broker返回的成功確認訊息，但是生產端由於網路閃斷沒收到，這個時候重新投遞可能會造成訊息重複，需要消費端去做冪等處理）所以我們需要有一個定時任務，（比如每5分鐘拉取一下處於中間狀態的訊息，當然這個訊息可以設定一個超時時間，比如超過1分鐘 Status = 0 ，也就說明了1分鐘這個時間視窗內，我們的訊息沒有被確認，那麼會被定時任務拉取出來）

  • Step 6：接下來我們把中間狀態的訊息進行重新投遞 retry send，繼續傳送訊息到MQ ，當然也可能有多種原因導致傳送失敗

  • Step 7：我們可以採用設定最大努力嘗試次數，比如投遞了3次，還是失敗，那麼我們可以將最終狀態設定為Status = 2 ，最後 交由人工解決處理此類問題（或者把訊息轉儲到失敗表中）。

接下來，我們使用SpringBoot2.x 實現這一可靠性投遞策略：

廢話不多說，直接上程式碼：

  • 資料庫庫表結構：訂單表和訊息記錄表

-- 表 order 訂單結構
CREATE TABLE IF NOT EXISTS `t_order` (
  `id` varchar(128) NOT NULL, -- 訂單ID
  `name` varchar(128), -- 訂單名稱 其他業務熟悉忽略
  `message_id` varchar(128) NOT NULL, -- 訊息唯一ID
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- 表 broker_message_log 訊息記錄結構
CREATE TABLE IF NOT EXISTS `broker_message_log` (
  `message_id` varchar(128) NOT NULL, -- 訊息唯一ID
  `message` varchar(4000) DEFAULT NULL, -- 訊息內容
  `try_count` int(4) DEFAULT '0', -- 重試次數
  `status` varchar(10) DEFAULT '', -- 訊息投遞狀態  0 投遞中 1 投遞成功   2 投遞失敗
  `next_retry` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  -- 下一次重試時間 或 超時時間
  `create_time` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00', -- 建立時間
  `update_time` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00', -- 更新時間
  PRIMARY KEY (`message_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

  • 整合SpringBoot 實現生產端程式碼如下：pom.xml配置

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

<?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.bfxy</groupId>

    <artifactId>rabbitmq-springboot-producer</artifactId>

    <version>0.0.1-SNAPSHOT</version>

    <packaging>jar</packaging>

 

    <name>rabbitmq-springboot-producer</name>

    <description>rabbitmq-springboot-producer</description>

 

    <parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>2.0.2.RELEASE</version>

        <relativePath/> <!-- lookup parent from repository -->

    </parent>

 

    <properties>

        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

        <java.version>1.8</java.version>

    </properties>

 

    <dependencies>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency> 

 

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-test</artifactId>

            <scope>test</scope>

        </dependency>

 

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-amqp</artifactId>

        </dependency>        

 

        <!-- 新增JDBC jar --> 

        <dependency>

          <groupId>org.mybatis.spring.boot</groupId>

          <artifactId>mybatis-spring-boot-starter</artifactId>

          <version>1.1.1</version>

        </dependency>

        <dependency>

          <groupId>tk.mybatis</groupId>

          <artifactId>mapper-spring-boot-starter</artifactId>

          <version>1.1.0</version>

        </dependency>    

        <dependency>

            <groupId>com.alibaba</groupId>

            <artifactId>druid</artifactId>

            <version>1.0.24</version>

        </dependency>

        <dependency>

            <groupId>mysql</groupId>

            <artifactId>mysql-connector-java</artifactId>

        </dependency>

        <!-- mybatis分頁外掛 -->

        <dependency>  

            <groupId>com.github.miemiedev</groupId>  

            <artifactId>mybatis-paginator</artifactId>  

            <version>1.2.17</version>  

            <exclusions>

                <exclusion>

                     <groupId>org.mybatis</groupId>

                    <artifactId>mybatis</artifactId>

                </exclusion>

            </exclusions>            

        </dependency>                    

        <dependency>

            <groupId>org.apache.commons</groupId>

            <artifactId>commons-lang3</artifactId>

        </dependency>

        <dependency>

            <groupId>commons-io</groupId>

            <artifactId>commons-io</artifactId>

            <version>2.4</version>

        </dependency>

        <dependency>

            <groupId>com.alibaba</groupId>

            <artifactId>fastjson</artifactId>

            <version>1.1.26</version>

        </dependency>    

        <dependency>

            <groupId>javax.servlet</groupId>

            <artifactId>javax.servlet-api</artifactId>

            <scope>provided</scope>    

        </dependency>  

                <dependency>

                    <groupId>log4j</groupId>

                    <artifactId>log4j</artifactId>

                    <version>1.2.17</version>

                </dependency>              

    </dependencies>

 

    <build>

        <plugins>

            <plugin>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-maven-plugin</artifactId>

            </plugin>

        </plugins>

    </build>

 

 

</project>

  • application.properties配置：

  • 1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    12

    13

    14

    15

    16

    17

    18

    19

    20

    21

    22

    23

    24

    25

    26

    27

    28

    spring.rabbitmq.addresses=192.168.11.76:5672

    spring.rabbitmq.username=guest

    spring.rabbitmq.password=guest

    spring.rabbitmq.virtual-host=/

    spring.rabbitmq.connection-timeout=15000

     

    spring.rabbitmq.publisher-confirms=true

    spring.rabbitmq.publisher-returns=true

    spring.rabbitmq.template.mandatory=true

     

    server.servlet.context-path=/

    server.port=8001

     

    spring.http.encoding.charset=UTF-8

    spring.jackson.date-format=yyyy-MM-dd HH:mm:ss

    spring.jackson.time-zone=GMT+8

    spring.jackson.default-property-inclusion=NON_NULL

     

    spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

    spring.datasource.url=jdbc:mysql://localhost:3306/test?characterEncoding=UTF-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&useUnicode=true

    spring.datasource.driver-class-name=com.mysql.jdbc.Driver

    spring.datasource.username=root

    spring.datasource.password=root

     

    mybatis.type-aliases-package=com.bfxy.springboot

    mybatis.mapper-locations=classpath:com/bfxy/springboot/mapping/*.xml

     

    logging.level.tk.mybatis=TRACE

  • 資料來源druid.properties配置

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

##下面為連線池的補充設定，應用到上面所有資料來源中

#初始化大小，最小，最大

druid.initialSize=5

druid.minIdle=10

druid.maxActive=300

#配置獲取連線等待超時的時間

druid.maxWait=60000

#配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒 

druid.timeBetweenEvictionRunsMillis=60000

#配置一個連線在池中最小生存的時間，單位是毫秒

druid.minEvictableIdleTimeMillis=300000

druid.validationQuery=SELECT 1 FROM DUAL

druid.testWhileIdle=true

druid.testOnBorrow=false

druid.testOnReturn=false

#開啟PSCache，並且指定每個連線上PSCache的大小

druid.poolPreparedStatements=true

druid.maxPoolPreparedStatementPerConnectionSize=20

#配置監控統計攔截的filters，去掉後監控介面sql無法統計，'wall'用於防火牆 

druid.filters=stat,wall,log4j

#通過connectProperties屬性來開啟mergeSql功能；慢SQL記錄

druid.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000

#合併多個DruidDataSource的監控資料

druid.useGlobalDataSourceStat=true

  • 實體物件：

  • 1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    12

    13

    14

    15

    16

    17

    18

    19

    20

    21

    22

    23

    24

    25

    26

    27

    28

    29

    30

    31

    32

    33

    34

    35

    36

    37

    38

    package com.bfxy.springboot.entity;

     

    import java.io.Serializable;

     

    public class Order implements Serializable {

     

        private static final long serialVersionUID = 9111357402963030257L;

     

        private String id;

     

        private String name;

     

        private String messageId;

     

        public String getId() {

            return id;

        }

     

        public void setId(String id) {

            this.id = id == null ? null : id.trim();

        }

     

        public String getName() {

            return name;

        }

     

        public void setName(String name) {

            this.name = name == null ? null : name.trim();

        }

     

        public String getMessageId() {

            return messageId;

        }

     

        public void setMessageId(String messageId) {

            this.messageId = messageId == null ? null : messageId.trim();

        }

    }

  • 1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    12

    13

    14

    15

    16

    17

    18

    19

    20

    21

    22

    23

    24

    25

    26

    27

    28

    29

    30

    31

    32

    33

    34

    35

    36

    37

    38

    39

    40

    41

    42

    43

    44

    45

    46

    47

    48

    49

    50

    51

    52

    53

    54

    55

    56

    57

    58

    59

    60

    61

    62

    63

    64

    65

    66

    67

    68

    69

    70

    71

    72

    73

    74

    75

    package com.bfxy.springboot.entity;

     

    import java.util.Date;

     

    public class BrokerMessageLog {

        private String messageId;

     

        private String message;

     

        private Integer tryCount;

     

        private String status;

     

        private Date nextRetry;

     

        private Date createTime;

     

        private Date updateTime;

     

        public String getMessageId() {

            return messageId;

        }

     

        public void setMessageId(String messageId) {

            this.messageId = messageId == null ? null : messageId.trim();

        }

     

        public String getMessage() {

            return message;

        }

     

        public void setMessage(String message) {

            this.message = message == null ? null : message.trim();

        }

     

        public Integer getTryCount() {

            return tryCount;

        }

     

        public void setTryCount(Integer tryCount) {

            this.tryCount = tryCount;

        }

     

        public String getStatus() {

            return status;

        }

     

        public void setStatus(String status) {

            this.status = status == null ? null : status.trim();

        }

     

        public Date getNextRetry() {

            return nextRetry;

        }

     

        public void setNextRetry(Date nextRetry) {

            this.nextRetry = nextRetry;

        }

     

        public Date getCreateTime() {

            return createTime;

        }

     

        public void setCreateTime(Date createTime) {

            this.createTime = createTime;

        }

     

        public Date getUpdateTime() {

            return updateTime;

        }

     

        public void setUpdateTime(Date updateTime) {

            this.updateTime = updateTime;

        }

    }

  • 資料庫連線池程式碼：

  • 1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    12

    13

    14

    15

    16

    17

    18

    19

    20

    21

    22

    23

    24

    25

    26

    27

    28

    29

    30

    31

    32

    33

    34

    35

    36

    37

    38

    39

    40

    41

    42

    43

    44

    45

    46

    47

    48

    49

    50

    51

    52

    53

    54

    55

    56

    57

    58

    59

    60

    61

    62

    63

    64

    65

    66

    67

    68

    package com.bfxy.springboot.config.database;

     

     

    import java.sql.SQLException;

     

    import javax.sql.DataSource;

     

    import org.slf4j.Logger;

    import org.slf4j.LoggerFactory;

    import org.springframework.beans.factory.annotation.Autowired;

    import org.springframework.context.annotation.Bean;

    import org.springframework.context.annotation.Configuration;

    import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;

    import org.springframework.jdbc.datasource.DataSourceTransactionManager;

    import org.springframework.transaction.PlatformTransactionManager;

    import org.springframework.transaction.annotation.EnableTransactionManagement;

     

    import com.alibaba.druid.pool.DruidDataSource; 

     

    @Configuration

    @EnableTransactionManagement

    public class DruidDataSourceConfig {

         

        private static Logger logger = LoggerFactory.getLogger(DruidDataSourceConfig.class);

         

        @Autowired

        private DruidDataSourceSettings druidSettings;

         

        public static String DRIVER_CLASSNAME ;

         

        @Bean

        public static PropertySourcesPlaceholderConfigurer propertyConfigure(){

            return new PropertySourcesPlaceholderConfigurer();

        }    

         

        @Bean

        public DataSource dataSource() throws SQLException {

            DruidDataSource ds = new DruidDataSource();

            ds.setDriverClassName(druidSettings.getDriverClassName());

            DRIVER_CLASSNAME = druidSettings.getDriverClassName();

            ds.setUrl(druidSettings.getUrl());

            ds.setUsername(druidSettings.getUsername());

            ds.setPassword(druidSettings.getPassword());

            ds.setInitialSize(druidSettings.getInitialSize());

            ds.setMinIdle(druidSettings.getMinIdle());

            ds.setMaxActive(druidSettings.getMaxActive());

            ds.setTimeBetweenEvictionRunsMillis(druidSettings.getTimeBetweenEvictionRunsMillis());

            ds.setMinEvictableIdleTimeMillis(druidSettings.getMinEvictableIdleTimeMillis());

            ds.setValidationQuery(druidSettings.getValidationQuery());

            ds.setTestWhileIdle(druidSettings.isTestWhileIdle());

            ds.setTestOnBorrow(druidSettings.isTestOnBorrow());

            ds.setTestOnReturn(druidSettings.isTestOnReturn());

            ds.setPoolPreparedStatements(druidSettings.isPoolPreparedStatements());

            ds.setMaxPoolPreparedStatementPerConnectionSize(druidSettings.getMaxPoolPreparedStatementPerConnectionSize());

            ds.setFilters(druidSettings.getFilters());

            ds.setConnectionProperties(druidSettings.getConnectionProperties());

            logger.info(" druid datasource config : {} ", ds);

            return ds;

        }

     

        @Bean

        public PlatformTransactionManager transactionManager() throws Exception {

            DataSourceTransactionManager txManager = new DataSourceTransactionManager();

            txManager.setDataSource(dataSource());

            return txManager;

        }

         

    }

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

package com.bfxy.springboot.config.database;

 

import org.springframework.beans.factory.annotation.Value;

import org.springframework.boot.context.properties.ConfigurationProperties;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.PropertySource;

import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;

import org.springframework.stereotype.Component;

 

@Component

@ConfigurationProperties(prefix="spring.datasource") 

@PropertySource("classpath:druid.properties")

public class DruidDataSourceSettings {

 

    private String driverClassName;

    private String url;

    private String username;

    private String password;

     

    @Value("${druid.initialSize}")

    private int initialSize;

     

    @Value("${druid.minIdle}")

    private int minIdle;

     

    @Value("${druid.maxActive}")

    private int maxActive;

     

    @Value("${druid.timeBetweenEvictionRunsMillis}")

    private long timeBetweenEvictionRunsMillis;

     

    @Value("${druid.minEvictableIdleTimeMillis}")

    private long minEvictableIdleTimeMillis;

     

    @Value("${druid.validationQuery}")

    private String validationQuery;

     

    @Value("${druid.testWhileIdle}")

    private boolean testWhileIdle;

     

    @Value("${druid.testOnBorrow}")

    private boolean testOnBorrow;

     

    @Value("${druid.testOnReturn}")

    private boolean testOnReturn;

     

    @Value("${druid.poolPreparedStatements}")

    private boolean poolPreparedStatements;

     

    @Value("${druid.maxPoolPreparedStatementPerConnectionSize}")

    private int maxPoolPreparedStatementPerConnectionSize;

     

    @Value("${druid.filters}")

    private String filters;

     

    @Value("${druid.connectionProperties}")

    private String connectionProperties;

     

    @Bean

    public static PropertySourcesPlaceholderConfigurer properdtyConfigure(){

        return new PropertySourcesPlaceholderConfigurer();

    }

     

    public String getDriverClassName() {

        return driverClassName;

    }

    public void setDriverClassName(String driverClassName) {

        this.driverClassName = driverClassName;

    }

    public String getUrl() {

        return url;

    }

    public void setUrl(String url) {

        this.url = url;

    }

    public String getUsername() {

        return username;

    }

    public void setUsername(String username) {

        this.username = username;

    }

    public String getPassword() {

        return password;

    }

    public void setPassword(String password) {

        this.password = password;

    }

    public int getInitialSize() {

        return initialSize;

    }

    public void setInitialSize(int initialSize) {

        this.initialSize = initialSize;

    }

    public int getMinIdle() {

        return minIdle;

    }

    public void setMinIdle(int minIdle) {

        this.minIdle = minIdle;

    }

    public int getMaxActive() {

        return maxActive;

    }

    public void setMaxActive(int maxActive) {

        this.maxActive = maxActive;

    }

    public long getTimeBetweenEvictionRunsMillis() {

        return timeBetweenEvictionRunsMillis;

    }

    public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) {

        this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;

    }

    public long getMinEvictableIdleTimeMillis() {

        return minEvictableIdleTimeMillis;

    }

    public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) {

        this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;

    }

    public String getValidationQuery() {

        return validationQuery;

    }

    public void setValidationQuery(String validationQuery) {

        this.validationQuery = validationQuery;

    }

    public boolean isTestWhileIdle() {

        return testWhileIdle;

    }

    public void setTestWhileIdle(boolean testWhileIdle) {

        this.testWhileIdle = testWhileIdle;

    }

    public boolean isTestOnBorrow() {

        return testOnBorrow;

    }

    public void setTestOnBorrow(boolean testOnBorrow) {

        this.testOnBorrow = testOnBorrow;

    }

    public boolean isTestOnReturn() {

        return testOnReturn;

    }

    public void setTestOnReturn(boolean testOnReturn) {

        this.testOnReturn = testOnReturn;

    }

    public boolean isPoolPreparedStatements() {

        return poolPreparedStatements;

    }

    public void setPoolPreparedStatements(boolean poolPreparedStatements) {

        this.poolPreparedStatements = poolPreparedStatements;

    }

    public int getMaxPoolPreparedStatementPerConnectionSize() {

        return maxPoolPreparedStatementPerConnectionSize;

    }

    public void setMaxPoolPreparedStatementPerConnectionSize(

            int maxPoolPreparedStatementPerConnectionSize) {

        this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;

    }

    public String getFilters() {

        return filters;

    }

    public void setFilters(String filters) {

       &nb

相關推薦

RabbitMQ訊息可靠性投遞解決方案 - 基於SpringBoot實現

https://www.imooc.com/article/49814 參考地址： https://www.imooc.com/t/2726237 談到訊息的可靠性投遞，無法避免的，在實際的工作中會經常碰到，比如一些核心業務需要保障訊息不丟失，接下來我們看一個可靠性投遞的流程圖，說明可靠

五、RabbitMQ-訊息可靠性傳遞實現方案

一、實現方案圖解 第一步 將要傳送的資訊進行對應資料庫的錄入，並且將傳送資訊的操作作為一條操作日誌錄入資料庫中設定狀態欄位status為0(傳送中)。 第二步 生產端將訊息傳送到RabbitMQ服務上。 第三步 RabbitMQ接收到訊息後，進行迴

併發解決方案-基於redis的訊息佇列

上一篇教大家用spring-data-redis來實現redis的訊息佇列：https://blog.csdn.net/u011870280/article/details/80012732現在接著來做一個測試，試試redis佇列在併發場景下的效能。首先來一個沒佇列的場景，比

SpringBoot-檔案線上預覽解決方案-基於OpenOffice及jacob

專案中有一個需求：實現檔案（主要是Office檔案）的線上預覽，根據前端需求，Office檔案需要轉換成pdf或者html方可在瀏覽器中開啟預覽，那麼後端需要將檔案轉為pdf/格式返回地址給前端。目前，瞭解到的解決方案大概有兩種，一種是基於Apache組織下的開源專案：OpenOffice，一種是使用jaco

新手搭建 WordPress 網站終極解決方案 基於 Bitnami 堆棧快速搭建完美個人博客（Blog）

分享 成了 rdp 網上 特色 雲服務 nco BE tro 為了搭建一個自己的博客，對於沒有相關知識的我來說，真的時相當不容易，經過很長時間的摸索研究，總算是搭起了這個博客（Blog），那麽第一篇文章就是來記錄一下，經過反復的折騰後感覺最適合我自己的一個方法，文章包含很多

Jmeter+jenkins如何快速搭建介面和效能測試持續整合解決方案-[基於windows篇]

  Jenkins + Jmeter 構建介面、效能測試持續整合解決方案 　　Jenkins + Jmeter 可以很輕鬆的進行打包釋出程式後自動進行介面冒煙測試，或者定時效能測試。以下是詳盡的Jenkins + Jmeter

Jmeter+jenkins如何快速搭建接口和性能測試持續集成解決方案-[基於windows篇]

pau 解決 fill containe lec 配置環境變量 java_home 保存 man 最近在用Jmeter本來想寫一個詳細的使用教程，突然看到有前輩已經寫好了不錯的教程，特此"借花獻佛"整理出來分享給大家! Jenkins + Jmete

訊息中介軟體解決方案-JMS-ActiveMQ

一、JMS入門 　　1.1 JMS簡介 　　JMS是Java平臺上有關面向訊息中介軟體的技術規範，它本身只定義了一系列的介面規範，是一種與廠商無關的API，用來訪問訊息收發系統。訊息是JMS中的一種型別物件，由兩部分組成：報頭和訊息主體。報頭由路由資訊以及有關該訊息的元資料組成。訊息主體則攜帶者應用程式的

【轉】手機鎖屏收不到訊息推送解決方案

問題描述 部分 Android 手機系統在黑屏待機後自動清理後臺執行的軟體，這樣影響了應用正常接收新的訊息，需要將應用設定為後臺執行應用。各類機型的設定說明如下： 華為 Mate9 手機設定說明 華為榮耀 6Plus 手機設定說明 華為麥芒手機設定說明 OPPO 手機設

rabbitMQ報錯；解決方案Error: unable to connect to node
rabbitMQ報錯；解決方案Error: unable to connect to node
openfire因為網路不穩定而造成訊息丟失的解決方案

       1               2 C1 ------- S ------- C2 訊息丟失 狀態：C1線上，但C2因為網路問題，或是程序被殺死，並且此時伺服器還沒及時傳送ping 進行判斷C2是否線上。 第一種情況： 此時，當C1向C2傳送訊息時，步驟1可

分散式事務（1）訊息傳送一致性解決方案

訊息傳送一致性 是指產生訊息的業務動作與訊息傳送的一致。（如果業務操作成功，那麼由這個業務操作所產生的訊息一定要成功投遞出去，否則就丟訊息） 訊息傳送一致性如何保障： 場景： 1.業務處理成功，執行傳送訊息的時候 應用故障，導致沒有傳送訊息（後續服務沒有收到訊息處理業務

電商專案day13(訊息中介軟體解決方案 JMS&ActiveMQ)

今日目標: 配置nginx反向代理 jms入門 spring整合jms ActiveMQ應用到專案實現上下架同時更改索引庫以及靜態頁面 一.nginx配置專案的反向代理 nginx是什麼? Nginx (engine x) 是一個高效能的HTTP和反向代理服

RabbitMQ訊息可靠性分析

Introduction 有很多人問過我這麼一類問題：RabbitMQ如何確保訊息可靠？很多時候，筆者的回答都是：說來話長的事情何來長話短說。的確，要確保訊息可靠不只是單單幾句就能夠敘述明白的，包括Kafka也是如此。可靠並不是一個絕對的概念，曾經有人也留言說

前端跨域問題解決方案(基於node與nginx)

1.跨域是什麼   跨域是指去向一個為非本origin(協議、域名、埠任意一個不同)的目標地址傳送請求的過程，這樣之所以會產生問題是因為瀏覽器的同源策略限制。看起來同源策略影響了我們開發的順暢性.實則不然,同源策略存在的必要性之一是為了隔離攻擊。 同源策略限制了從同一個源載入的文件或指令碼如何與來自

Amazon SQS 訊息佇列服務_訊息佇列mq解決方案

Amazon Simple Queue Service (SQS) 是一種完全託管的訊息佇列服務，可讓您分離和擴充套件微服務、分散式系統和無伺服器應用程式。SQS 消除了與管理和運營訊息型中介軟體相關的複雜性和開銷，並使開發人員能夠專注於重要工作。藉助 SQS，您可以在軟體元件之間傳送、儲

RabbitMQ資料同步一致性解決方案

1.概述 我們知道在使用RabbitMQ時，生產者將訊息釋出出去之後，訊息是否順利到達broker代理伺服器呢？預設情況下發布操作沒有任何資訊返回給生產者，也就是生產者是不知道訊息有沒有順利到達broker。如果在訊息到達broker之前已經丟失了，那釋出的訊

粘包處理現象及其解決方案——基於NewLife.Net網路庫的管道式幀長粘包處理方法

目錄1.粘包現象2.粘包原因2.1. 同一客戶端連續傳送2.2. 網路擁塞造成粘包2.3. 服務端卡死了3. 粘包的危害3.1. 無法正確解析資料包3.2. 錯誤資料包被錯誤解析3.3. 進入死迴圈4. 粘包的邏輯處理方式4.1. 根據包尾特徵引數進行區分4.2. 根據包頭包尾特徵引數進行區分4.3. 根據報

（轉）Spring事務處理時自我調用的解決方案及一些實現方式的風險

上下 喜歡 wire print type service() str bug 銷毀 轉：http://www.iteye.com/topic/1122740 預備知識 測試代碼準備 問題 解決方案 1通過ThreadLocal暴露Aop代理對象 2通過初始化方法在目標對