文章目錄

小程式編譯運行-效果預覽
準備作業
- 技術
- 流程圖
- 介面檔案
業務開發
- pom依賴
- 公共類
- 工具類
- 配置類conf
- 資源類resouce
- 組態檔yml
- 寫業務
- 檢驗
Kafka Producer集成單例
Https
- 解決本地443埠號沖突
- 解決
- 待解決
- 將windows檔案壓縮tgz
- linux檔案上傳
- linux修改專案配置
- 解決centos7埠443占用
- 驗證https線上運行成功
- 啟動腳本
- 解決：Linux下-bash: nohup: command not found或者bash: nohup: 未找到命令的問題
- 解決安全組443
小程式上傳
- 開發工具
- 微信公眾平臺
- 配置小程式檔案
- 小程式編譯運行-效果預覽
- centos的kafka環境配置
- 解決物理記憶體不足 JVM調優

小程式編譯運行-效果預覽

在這里插入圖片描述

準備作業

技術

在這里插入圖片描述

流程圖

在這里插入圖片描述

介面檔案

問題選項、回傳結果、結果匯總報告

業務開發

pom依賴

<!--        fastjson 盡量保持更新，預防bug-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.74</version>
        </dependency>
<!--        guava支持-->
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>29.0-jre</version>
        </dependency>
        <!--        代碼生成lombok，需要配合idea插件-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.16</version>
            <scope>provided</scope>
        </dependency>

公共類

封裝統一回傳，泛型
跨域問題

com.bennyrhys.kafka_study1.wechat.common.BaseResponseVO

package com.bennyrhys.kafka_study1.wechat.common;

import java.util.UUID;
import lombok.Data;

/**
 * @author : bennyrhys
 * @description : 公共回傳物件
 **/
@Data
public class BaseResponseVO<M> {

  private String requestId;
  private M result;

  public static<M> BaseResponseVO success(){
    BaseResponseVO baseResponseVO = new BaseResponseVO();
    baseResponseVO.setRequestId(genRequestId());

    return baseResponseVO;
  }

  public static<M> BaseResponseVO success(M result){
    BaseResponseVO baseResponseVO = new BaseResponseVO();
    baseResponseVO.setRequestId(genRequestId());
    baseResponseVO.setResult(result);

    return baseResponseVO;
  }

  private static String genRequestId(){
    return UUID.randomUUID().toString();
  }

}

com.bennyrhys.kafka_study1.wechat.common.CorsFilter

package com.bennyrhys.kafka_study1.wechat.common;

import java.io.IOException;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletResponse;
import org.springframework.context.annotation.Configuration;

/**
 * @author : bennyryhs
 * @description : 跨域問題解決
 **/
@WebFilter(filterName = "CorsFilter")
@Configuration
public class CorsFilter implements Filter {
  @Override
  public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException, ServletException {
    HttpServletResponse response = (HttpServletResponse) res;
    response.setHeader("Access-Control-Allow-Origin","*");
    response.setHeader("Access-Control-Allow-Credentials", "true");
    response.setHeader("Access-Control-Allow-Methods", "POST, GET, PATCH, DELETE, PUT");
    response.setHeader("Access-Control-Max-Age", "3600");
    response.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept");
    chain.doFilter(req, res);
  }
}

工具類

json檔案讀取（object、array）型別

com.bennyrhys.kafka_study1.wechat.utils.FileUtils

package com.bennyrhys.kafka_study1.wechat.utils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.Reader;
import java.util.Optional;
import lombok.Cleanup;
import lombok.extern.slf4j.Slf4j;

/**
 * @author : bennyrhys
 * @description : 檔案工具類
 **/
@Slf4j
public class FileUtils {

  public static String readFile(String filePath) throws IOException {
    @Cleanup
    BufferedReader reader = new BufferedReader(
        new FileReader(new File(filePath))
    );

    String lineStr = "";
    StringBuffer stringBuffer = new StringBuffer();
    while ((lineStr = reader.readLine()) != null) {
      stringBuffer.append(lineStr);
    }

    return stringBuffer.toString();
  }


  public static Optional<JSONObject> readFile2JsonObject(String filePath){
    try {
      String fileContent = readFile(filePath);
      log.info("readFile2Json fileContent: [{}]" , fileContent);
      return Optional.ofNullable(JSON.parseObject(fileContent));
    } catch (IOException e) {
      e.printStackTrace();
    }
    return Optional.empty();
  }

  public static Optional<JSONArray> readFile2JsonArray(String filePath){
    try {
      String fileContent = readFile(filePath);
      log.info("readFile2JsonArray fileContent: [{}]" , fileContent);
      return Optional.ofNullable(JSON.parseArray(fileContent));
    } catch (IOException e) {
      e.printStackTrace();
    }
    return Optional.empty();
  }

}

配置類conf

物體類
com.bennyrhys.kafka_study1.wechat.conf.WeChatTemplateProperties

package com.bennyrhys.kafka_study1.wechat.conf;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

import java.util.List;

@Data
@Configuration
@ConfigurationProperties(prefix = "template")
/**
 * 存盤模板調查結果
 */
public class WeChatTemplateProperties {

    private List<WechatTemplate> templates;
    private int templateResultType; // 結果型別 0-檔案 1-資料庫 2-es
    private String templateResultFilePath; // 結果檔案路徑

    /**
     * 存盤模板
     */
    @Data
    public static class WechatTemplate {
        private String templateId;
        private String templateFilePath;
        private boolean active;
    }
}

資源類resouce

template

[{
  "questionId": "1",
  "question": "今天幾號",
  "answer": "",
  "options": [
    {"label": "1號", "value": "A"},
    {"label": "2號", "value": "B"},
    {"label": "3號", "value": "C"},
    {"label": "4號", "value": "D"}
  ]},
  {
    "questionId": "2",
    "question": "你喜愛的顏色",
    "answer": "",
    "options": [
      {"label": "紅色", "value": "A"},
      {"label": "黃色", "value": "B"},
      {"label": "綠色", "value": "C"},
      {"label": "紫色", "value": "D"}
    ]}
]

kafka_study1/src/main/resources/templates/templateResult.json

{
  "templateId": "001",
  "totalNumber": "102",
  "statistics": [
    {
      "questionId": "1",
      "question": "今天幾號",
      "answers": [
        {"label": "A", "value": 10},
        {"label": "B", "value": 50},
        {"label": "C", "value": 12},
        {"label": "D", "value": 17}
      ]
    },
    {
      "questionId": "2",
      "question": "你喜愛的顏色",
      "answers": [
        {"label": "A", "value": 12},
        {"label": "B", "value": 52},
        {"label": "C", "value": 17},
        {"label": "D", "value": 17}
      ]
    }
  ]
}

組態檔yml

application.yml

server:
  port: 8080

template:
  templates:
    - {"templateId":"1", "templateFilePath":"E:/JAVA/kafka_study1/src/main/resources/templates/template.json", "active":true}
    - {"templateId":"2", "templateFilePath":"E:/JAVA/kafka_study1/src/main/resources/templates/template.json", "active":false}
  template-result-type: 0  # 結果型別 0-檔案 1-資料庫 2-es(注意駝峰命名改橫線小寫鏈接)
  template-result-file-path: "E:/JAVA/kafka_study1/src/main/resources/templates/templateResult.json"

寫業務

https://github.com/bennyrhys/kafka_study.git

檢驗

查詢模板資訊
http://localhost:8080/v1/template
在這里插入圖片描述

查詢模板統計結果
http://localhost:8080/v1/template/result
在這里插入圖片描述
提交調查問卷結果
windows通過gitbash模擬linux環境 post
回傳結果
requestId":“0725ef59-52fb-432c-aef5-4276cc25ae37”,“result”:null}

在這里插入圖片描述

-- 查詢模板資訊
curl -XGET http://localhost:8080/v1/template


-- 查詢模板統計結果
curl -XGET http://localhost:8080/v1/template/result

-- 傳入調查問卷結果
curl -XPOST -H "Content-Type:application/json; charset=UTF-8" http://localhost:8080/v1/template/report -d \
'{
	templateId:"001",
	result:[
		{"questionId":"1","question":"今天幾號","answer":"A"},
		{"questionId":"2","question":"你喜愛的顏色","answer":"B"}
	]
}'


netstat -ano | findstr 443

Kafka Producer集成單例

kafka的Producer是執行緒安全的，實際生成環境不建議Producer創建多回，
如果多執行緒情況下創建多個producer，性能消耗比想象中消耗要大，甚至不如單執行緒，
因為producer的send是往中間佇列中存入資料，后臺執行緒將資料批量的刷給服務器，創建多個producer使頻繁的背景關系爭搶，背景關系切換

而每次進入controller->service就相當于創建一個新實體，為了防止producer被創建多次，應該單獨把producer封裝到common或utils或conf

Https

SSL的AC證書認證
在這里插入圖片描述域名備案20個作業日左右
同一個證書只能系結一個域名
系結域名不包含二三級子域名

證書下載
因為springBoot內置的tomcat
在這里插入圖片描述

在這里插入圖片描述
檢驗證書+添加二級域名：域名決議會多出一行txt，

在這里插入圖片描述
下載出的證書及密碼

啟動協議變為https
在這里插入圖片描述

server:
  port: 443
  ssl:
    key-store: 3974629_www.996cloud.work.pfx # 證書的檔案名
    key-store-password: O4d8Fl8t

在這里插入圖片描述
準備上傳服務器的檔案

解決本地443埠號沖突

windows查看埠號
C:\Users\rxguo>netstat -ano |findstr "443"

在這里插入圖片描述

赫然發現443被一個pid為7296的行程占用著.
查看該pid對應的程式:
tasklist |findstr "行程id號"
在這里插入圖片描述
于是我嘗試殺掉該行程:被拒絕
taskkill /f /t /im "行程id或者行程名稱"

打開VM虛擬機,點擊選單中的“編輯-首選項”,把共享虛擬機給關閉;
在這里插入圖片描述

解決

在這里插入圖片描述 https://localhost/v1/template

待解決

查logbak.xml
在這里插入圖片描述

將windows檔案壓縮tgz

tar -zcvf 檔案.tgz 檔案名
在這里插入圖片描述

linux檔案上傳

yum install -y lrzsz

linux修改專案配置

地址和ip地址
在這里插入圖片描述

root@iZ2ze21075lo3b5h7k3wozZ wechat]# ll
total 29468
-rw-r--r-- 1 root root 30175119 Oct 21 17:29 wechat-template.tgz
[root@iZ2ze21075lo3b5h7k3wozZ wechat]# tar -zxf wechat-template.tgz 
[root@iZ2ze21075lo3b5h7k3wozZ wechat]# ll
total 29472
drwxr-xr-x 3 1173931 1049089     4096 Oct 21 17:27 wechat-template
-rw-r--r-- 1 root    root    30175119 Oct 21 17:29 wechat-template.tgz
[root@iZ2ze21075lo3b5h7k3wozZ wechat]# cd wechat-template
[root@iZ2ze21075lo3b5h7k3wozZ wechat-template]# ll
total 32076
-rw-r--r-- 1 1173931 1049089     4554 Oct 21 16:57 3974629_www.996cloud.work.pfx
-rw-r--r-- 1 1173931 1049089      819 Oct 21 17:07 application.yml
-rw-r--r-- 1 1173931 1049089 32825383 Oct 21 17:25 kafka-template.jar
drwxr-xr-x 2 1173931 1049089     4096 Oct 21 17:21 templates
[root@iZ2ze21075lo3b5h7k3wozZ wechat-template]# vi application.yml

解決centos7埠443占用

停掉之前的專案

cd /usr/local/java/tomcat/apache-tomcat-8.5.40/bin/
netstat -nap | grep 443

在這里插入圖片描述

驗證https線上運行成功

https://www.996cloud.work/v1/template
在這里插入圖片描述
注意因為線上環境缺少kafka所以會報warn

啟動腳本

[root@iZ2ze21075lo3b5h7k3wozZ wechat-template]# vi start.sh

# !/bin/bash
nohub java -jar wechat-template.jar &

// 賦予腳本執行權限
-rw-r--r-- 1 root    root          51 Oct 22 10:36 start.sh
[root@iZ2ze21075lo3b5h7k3wozZ wechat-template]# chmod u+x start.sh 
// 有了權限檔案名變為綠色
[root@iZ2ze21075lo3b5h7k3wozZ wechat-template]# ll
total 32080
-rw-r--r-- 1 1173931 1049089     4554 Oct 21 16:57 3974629_www.996cloud.work.pfx
-rw-r--r-- 1 1173931 1049089      786 Oct 22 10:21 application.yml
-rwxr--r-- 1 root    root          51 Oct 22 10:36 start.sh

解決：Linux下-bash: nohup: command not found或者bash: nohup: 未找到命令的問題

不要錯寫成nohub是nohup
https://blog.csdn.net/qq_40241957/article/details/98584207

解決安全組443

1 安全組的埠添加綠卡443
在這里插入圖片描述

2 centos的防火墻關閉

[root@iZ2ze21075lo3b5h7k3wozZ wechat-template]# systemctl status fillwalld
Unit fillwalld.service could not be found.
[root@iZ2ze21075lo3b5h7k3wozZ wechat-template]# systemctl status firewalld
● firewalld.service - firewalld - dynamic firewall daemon
   Loaded: loaded (/usr/lib/systemd/system/firewalld.service; disabled; vendor preset: enabled)
   Active: inactive (dead)
     Docs: man:firewalld(1)

小程式上傳

開發工具

小程式
https://developers.weixin.qq.com/miniprogram/dev/devtools/stable.html
nodejs
https://nodejs.org/en/

配置node環境變數
在這里插入圖片描述檢驗node

C:\Users\rxguo>node -v
v12.19.0

微信公眾平臺

appid:wx9018260c5501cfb1238

配置小程式檔案

解壓qe檔案

洗掉自動生成的dist檔案

關注package.json,其中config.ts在src目錄下
在這里插入圖片描述修改config.ts,修改后端對應地址
export const baseUrl: string = 'https://www.996cloud.work'

git bash右鍵，命令列編譯
注意：install只會會產生node_moudle 模板檔案特別大

// 檢驗是否有cnpm
cnpm -v
// 沒有則安裝cnpm
npm install -g cnpm --registry=https://registry.npm.taobao.org

cnpm install -g @tarojs/cli@2.0.6

cnpm install

npm run build:weapp

注意如果taro 出現問題
taro info 查看版本資訊

生成dist檔案，就是要發布到微信程式里的內容

小程式編譯運行-效果預覽

在這里插入圖片描述

centos的kafka環境配置

見博主的【訊息佇列】kafka 文章

解決物理記憶體不足 JVM調優

Java HotSpot? 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000794500000, 576716800, 0)

停止當前后臺運行的jar

// 找到java對應的pid
netstat -anp
// 殺死行程pid
kill -9 行程pid

重新修改啟動腳本

nohup  java -Xms256m -Xmx512m -XX:PermSize=128m -XX:MaxPermSize=256m -jar wechat-template.jar &

JAVA_OPTS="-server -Xms256m -Xmx512m -XX:PermSize=128m -XX:MaxPermSize=256m"
java -Xms512m -Xmx512m -XX:+UseG1GC -XX:+PrintGCDetails -jar 專案.jar

命令列查看記憶體占用的pid
top
選著性
kill -9 pid號

mysql的行程沒法直接關閉一直變動
https://blog.csdn.net/chinabluexfw/article/details/7170123?utm_medium=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.edu_weight&depth_1-utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.edu_weight

瑞新

CSDN認證博客專家分布式 Java 架構

求職中 ? Java全堆疊養成計劃
公眾號 ? 讓我遇見相似的靈魂
回復領取：競賽書籍專案面試

左手代碼，右手吉他，這就是天下:如果有一天我遇見相似的靈魂那它肯定是步履艱難不被理解喜黑怕光的，如果可以的話讓我觸摸一下吧它也一樣孤獨得太久，不一樣的文藝青年，不一樣的程式猿，

轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/187786.html

標籤：其他

上一篇：聚精華于一身！華為資深專家歷時十年‘史詩巨作’網路協議寶典

下一篇：解讀秒殺業務：Redis如何助力高并發秒殺系統以及完美解決超賣問題

【實戰】Kafka Producer實戰——小程式調查問卷

文章目錄

小程式編譯運行-效果預覽

準備作業

技術

流程圖

介面檔案

業務開發

pom依賴

公共類

工具類

配置類conf

資源類resouce

組態檔yml

寫業務

檢驗

Kafka Producer集成單例

Https

解決本地443埠號沖突

解決

待解決

將windows檔案壓縮tgz

linux檔案上傳

linux修改專案配置

解決centos7埠443占用

驗證https線上運行成功

啟動腳本

解決：Linux下-bash: nohup: command not found或者bash: nohup: 未找到命令的問題

解決安全組443

小程式上傳

開發工具

微信公眾平臺

配置小程式檔案

小程式編譯運行-效果預覽

centos的kafka環境配置

解決物理記憶體不足 JVM調優