520来袭之前和我用serverless和FaaS实现一个表白小程序

var getRawBody = require('raw-body');
var getFormBody = require('body/form');
var body = require('body');


/*
To enable the initializer feature (https://help.aliyun.com/document_detail/156876.html)
please implement the initializer function as below：
exports.initializer = (context, callback) => {
  console.log('initializing');
  callback(null, '');
};
*/

exports.handler = (req, resp, context) => {
   
 		resp.send('hello world');
}

fun config

fun init -n demo

fun build

fun deploy

        
            
                org.springframework.boot
                spring-boot-dependencies
                ${spring-boot.version}
                pom
                import
            
        
    

        org.springframework.boot
        spring-boot-starter-parent
        2.3.7.RELEASE
    

package com.itheima.love520demo.controller;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author itheima
 * @version 1.0
 * @date 2021/5/13 18:25
 */
@RestController
public class TestController {

    @RequestMapping("/test")
    public String test(){
        return "itheima";
    }
}

cd 

mvn package -Dmaven.test.skip=true

[INFO] Scanning for projects...
[INFO] 
[INFO] ---------------------------------------------
[INFO] Building Spring-Boot 0.0.1-SNAPSHOT
[INFO] --------------------------------[ jar ]---------------------------------
[INFO] 
[INFO] --- maven-resources-plugin:3.1.0:resources (default-resources) @ Spring-Boot ---
... ... ...
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-jar-plugin:3.1.2:jar (default-jar) @ Spring-Boot ---
[INFO] Building jar: /Users/txd123/Desktop/Spring-Boot/target/Spring-Boot-0.0.1-SNAPSHOT.jar
[INFO] 
[INFO] --- spring-boot-maven-plugin:2.2.6.RELEASE:repackage (repackage) @ Spring-Boot ---
[INFO] Replacing main artifact with repackaged archive
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time:  38.850 s
[INFO] Finished at: 2020-03-31T15:09:34+08:00
[INFO] ------------------------------------------------------------------------

fun deploy -y

current folder is not a fun project.
Generating template.yml...
Generate Fun project successfully!
========= Fun will use 'fun deploy' to deploy your application to Function Compute! =========
using region: cn-qingdao
using accountId: ***********3743
using accessKeyId: ***********Ptgk
using timeout: 60

Collecting your services information, in order to caculate devlopment changes...

Resources Changes(Beta version! Only FC resources changes will be displayed):

               trigger httpTrigger deploy success
       function Spring-Boot deploy success
service Spring-Boot deploy success

Detect 'DomainName:Auto' of custom domain 'Domain'
Request a new temporary domain ...
The assigned temporary domain is 15639196-XXX.test.functioncompute.com，expired at 2020-04-10 15:19:56, limited by 1000 per day.
Waiting for custom domain Domain to be deployed...
custom domain Domain deploy success

server.servlet.context-path=/2016-08-15/proxy/love520demo/love520demo

mvn package -Dmaven.test.skip=true
fun deploy -y

		
            com.aliyun.oss
            aliyun-sdk-oss
            3.10.2
        
        
            com.aliyun
            aliyun-java-sdk-core
            4.1.1
        
		
        
            com.google.zxing
            core
            3.3.0
        
        
            com.google.zxing
            javase
            3.3.0
        
        
            org.projectlombok
            lombok
        

package com.itheima.love520.utils;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.GetObjectRequest;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.*;

/**
 * @author brianxia
 * @version 1.0
 * @date 2021/4/18 23:45
 */

@Component
public class OssUtil {

    @Value("${oss.bucketName}")
    private String bucketName;
    @Value("${oss.accessKeyId}")
    private String accessKeyId;
    @Value("${oss.accessKeySecret}")
    private String accessKeySecret;
    @Value("${qr.image.path}")
    private String qrPath;

    public OSS createClient() {
        // Endpoint以杭州为例，其它Region请按实际情况填写。
        String endpoint = "https://oss-cn-beijing.aliyuncs.com";
        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
        return ossClient;
    }

    /**
     * 以流的方式保存，用于保存文件
     * @param objectName 文件名
     * @param stream 流对象
     */
    public void save(String objectName, InputStream stream) {
        OSS client = createClient();
        // 上传文件到指定的存储空间（bucketName）并将其保存为指定的文件名称（objectName）。
        client.putObject(bucketName, objectName, stream);
        // 关闭OSSClient。
        client.shutdown();
    }

    /**
     * 保存字符串
     * @param objectName 文件名
     * @param content   字符串
     */
    public void save(String objectName, String content) {
        OSS client = createClient();
        // 上传文件到指定的存储空间（bucketName）并将其保存为指定的文件名称（objectName）。
        client.putObject(bucketName, objectName, new ByteArrayInputStream(content.getBytes()));
        // 关闭OSSClient。
        client.shutdown();
    }

    /**
     * 保存二维码
     * @param objectName 文件名
     * @param context   二维码内容
     * @param logo      中间的logo图
     */
    public void saveQr(String objectName, String context,String logo) throws IOException {
        BufferedImage image = null;
        if(StringUtils.isEmpty(logo)){
            image = QRCodeKit.createQRCode(context);
        }else{
            String path = loadFile(logo);
            File file = new File(path);
            image = QRCodeKit.createQRCodeWithLogo(context,file);
            if(file.exists()){
                file.delete();
            }
        }

        if(image == null){
            return;
        }

        ByteArrayOutputStream os = new ByteArrayOutputStream();
        ImageIO.write(image, "png", os);
        InputStream qrCode = new ByteArrayInputStream(os.toByteArray());

        try{
            OSS client = createClient();
            // 上传文件到指定的存储空间（bucketName）并将其保存为指定的文件名称（objectName）。
            client.putObject(bucketName, objectName, qrCode);
            // 关闭OSSClient。
            client.shutdown();
        }finally {
            if(qrCode != null){
                try {
                    qrCode.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }

    /**
     * 加载文件
     * @param objectName 文件名
     * @return 文件内容字符串
     */
    public String loadFile(String objectName) {
        String path = qrPath + objectName;
        OSS ossClient = createClient();
        // 下载Object到本地文件，并保存到指定的本地路径中。如果指定的本地文件存在会覆盖，不存在则新建。
        // 如果未指定本地路径，则下载后的文件默认保存到示例程序所属项目对应本地路径中。
        ossClient.getObject(new GetObjectRequest(bucketName, objectName), new File(path));
        // 关闭OSSClient。
        ossClient.shutdown();

        return path;
    }

}

package com.itheima.love520.utils;

import com.google.zxing.*;
import com.google.zxing.common.BitMatrix;
import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.codec.binary.Base64OutputStream;

import javax.imageio.ImageIO;
import java.awt.*;
import java.awt.image.BufferedImage;
import java.io.*;
import java.util.HashMap;
import java.util.Map;

public class QRCodeKit {

    public static final String QRCODE_DEFAULT_CHARSET = "UTF-8";

    public static final int QRCODE_DEFAULT_HEIGHT = 400;

    public static final int QRCODE_DEFAULT_WIDTH = 400;

    public static final int LOGO_DEFAULT_HEIGHT = 100;
    public static final int LOGO_DEFAULT_WIDTH = 100;

    private static final int BLACK = 0xFF000000;
    private static final int WHITE = 0xFFFFFFFF;

    public static void main(String[] args) throws IOException, NotFoundException{
        String data = "http://www.baidu.com";
        File logoFile = new File("logo.png");
        BufferedImage image = QRCodeKit.createQRCodeWithLogo(data, logoFile);
        ImageIO.write(image, "png", new File("result7.png"));
        System.out.println("done");
    }

    /**
     * Create qrcode with default settings
     *
     * @param data
     * @return
     */
    public static BufferedImage createQRCode(String data) {
        return createQRCode(data, QRCODE_DEFAULT_WIDTH, QRCODE_DEFAULT_HEIGHT);
    }

    /**
     * Create qrcode with default charset
     *
     * @param data
     * @param width
     * @param height
     * @return
     */
    public static BufferedImage createQRCode(String data, int width, int height) {
        return createQRCode(data, QRCODE_DEFAULT_CHARSET, width, height);
    }

    /**
     * Create qrcode with specified charset
     *
     * @param data
     * @param charset
     * @param width
     * @param height
     * @return
     */
    @SuppressWarnings({ "unchecked", "rawtypes" })
    public static BufferedImage createQRCode(String data, String charset, int width, int height) {
        Map hint = new HashMap();
        hint.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.H);
        hint.put(EncodeHintType.CHARACTER_SET, charset);

        return createQRCode(data, charset, hint, width, height);
    }

    /**
     * Create qrcode with specified hint
     *
     * @param data
     * @param charset
     * @param hint
     * @param width
     * @param height
     * @return
     */
    public static BufferedImage createQRCode(String data, String charset, Map hint, int width,
                                             int height) {
        BitMatrix matrix;
        try {
            matrix = new MultiFormatWriter().encode(new String(data.getBytes(charset), charset), BarcodeFormat.QR_CODE,
                    width, height, hint);
            return toBufferedImage(matrix);
        } catch (WriterException e) {
            throw new RuntimeException(e.getMessage(), e);
        } catch (Exception e) {
            throw new RuntimeException(e.getMessage(), e);
        }
    }
    public static BufferedImage toBufferedImage(BitMatrix matrix) {
        int width = matrix.getWidth();
        int height = matrix.getHeight();
        BufferedImage image = new BufferedImage(width, height,
                BufferedImage.TYPE_INT_RGB);
        for (int x = 0; x  hint,
                                                     int width, int height, File logoFile) {
        try {
            BufferedImage qrcode = createQRCode(data, charset, hint, width, height);
            BufferedImage logo2 = ImageIO.read(logoFile);

            BufferedImage logo =new BufferedImage(LOGO_DEFAULT_WIDTH,LOGO_DEFAULT_HEIGHT,BufferedImage.TYPE_INT_RGB);
            Graphics graphics=logo.getGraphics();
            //将原始位图缩小后绘制到bufferedImage对象中
            graphics.drawImage(logo2,0,0,LOGO_DEFAULT_WIDTH,LOGO_DEFAULT_HEIGHT,null);

            int deltaHeight = height - logo.getHeight();
            int deltaWidth = width - logo.getWidth();

            BufferedImage combined = new BufferedImage(height, width, BufferedImage.TYPE_INT_ARGB);
            Graphics2D g = (Graphics2D) combined.getGraphics();
            g.drawImage(qrcode, 0, 0, null);
            g.setComposite(AlphaComposite.getInstance(AlphaComposite.SRC_OVER, 1f));
            g.drawImage(logo, (int) Math.round(deltaWidth / 2), (int) Math.round(deltaHeight / 2), null);

            return combined;
        } catch (IOException e) {
            throw new RuntimeException(e.getMessage(), e);
        } catch (Exception e) {
            throw new RuntimeException(e.getMessage(), e);
        }
    }

    /**
     * Return base64 for image
     *
     * @param image
     * @return
     */
    public static String getImageBase64String(BufferedImage image) {
        String result = null;
        try {
            ByteArrayOutputStream os = new ByteArrayOutputStream();
            OutputStream b64 = new Base64OutputStream(os);
            ImageIO.write(image, "png", b64);
            result = os.toString("UTF-8");
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e.getMessage(), e);
        } catch (IOException e) {
            throw new RuntimeException(e.getMessage(), e);
        }
        return result;
    }

    /**
     * Decode the base64Image data to image
     *
     * @param base64ImageString
     * @param file
     */
    public static void convertBase64StringToImage(String base64ImageString, File file) {
        FileOutputStream os;
        try {
            Base64 d = new Base64();
            byte[] bs = d.decode(base64ImageString);
            os = new FileOutputStream(file.getAbsolutePath());
            os.write(bs);
            os.close();
        } catch (FileNotFoundException e) {
            throw new RuntimeException(e.getMessage(), e);
        } catch (IOException e) {
            throw new RuntimeException(e.getMessage(), e);
        } catch (Exception e) {
            throw new RuntimeException(e.getMessage(), e);
        }
    }


}

oss.bucketName=OSS仓库名
oss.accessKeyId=OSS的ak
oss.accessKeySecret=OSS的SK
qr.url=http://www.cloudprogrammer.cn:8090/show/confess
qr.image.path=/tmp/

5609a150-22cf-4d8f-a8a4-7d673444b617

{
	"content": "",
	"logo": "",
	"template": "",
	"to": ""
}

5609a150-22cf-4d8f-a8a4-7d673444b617

package com.itheima.love520.entity;

import lombok.Data;

/**
 * 表白内容实体定义
 * @author itheima
 * @version 1.0
 * @date 2021/4/18 23:35
 */
@Data
public class Confess {
    //表白对象
    private String to;
    //表白内容
    private String content;
    //二维码中间的logo图片
    private String logo;
    //用户选择的模板
    private String template;
}

package com.itheima.love520demo.controller;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.itheima.love520demo.entity.Confess;
import com.itheima.love520demo.utils.OssUtil;
import lombok.extern.java.Log;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Map;
import java.util.UUID;

/**
 * @author itheima
 * @version 1.0
 * @date 2021/4/18 23:34
 */
@RestController
@CrossOrigin("*")
@RequestMapping("/confess")
@Slf4j
public class ConfessController {
    /**
     * JSON转换器
     */
    @Autowired
    private ObjectMapper objectMapper;
    /**
     * OSS上传下载工具类
     */
    @Autowired
    private OssUtil ossUtil;
    /**
     * 表白的展示页面，已提供
     */
    @Value("${qr.url}")
    private String qrUrl;

    /**
     * 上传图片接口
     * @param file 文件对象
     * @return 文件名，是一个随机字符串
     */
    @PostMapping("/upload")
    public String uploadFile(MultipartFile file) throws Exception {

        //生成随机字符串作为文件名
        String uuid = UUID.randomUUID().toString();
        try {
            //存储图片
            ossUtil.save(uuid,file.getInputStream());
        } catch (Exception e) {
            log.error("二维码图片保存失败",e);
        }
        return uuid;
    }


    /**
     * 保存表白内容
     * @param confess 表白内容
     * @return 文件名，是一个随机字符串
     */
    @PostMapping("/save")
    public String saveConfess(@RequestBody Confess confess) throws Exception {

        //生成随机文件名
        String uuid = UUID.randomUUID().toString();
        String qrRealUrl = qrUrl + "?id=" + uuid;
        try {
            //存储数据
            ossUtil.save(uuid,objectMapper.writeValueAsString(confess));
            //存储二维码
            ossUtil.saveQr(uuid + "qr.jpg",qrRealUrl,confess.getLogo());
        } catch (IOException e) {
            log.error("表白保存失败",e);
        }
        return uuid;
    }


}

package com.itheima.love520show.controller;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.itheima.love520show.entity.Confess;
import com.itheima.love520show.util.OssUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;

/**
 * @author itheima
 * @version 1.0
 * @date 2021/4/20 23:58
 */
@Controller
@RequestMapping("/show")
public class ShowController {
    @Autowired
    OssUtil ossUtil;
    @Autowired
    ObjectMapper mapper;

    @RequestMapping("/confess")
    public String confess(HttpServletRequest request,Model model) throws IOException {
        String id = request.getParameter("id");
        String load = ossUtil.load(id);
        Confess confess = mapper.readValue(load, Confess.class);
        model.addAttribute("to",confess.getTo());
        model.addAttribute("content",confess.getContent());
        return "template" + confess.getTemplate();
    }
}

qr.url=http://www.cloudprogrammer.cn:8090/show/confess

fun deploy -y

nohup java -jar love520-show.jar &

// 修改为程序真实地址
        action: 'https://1847961572749689.cn-hangzhou.fc.aliyuncs.com/2016-08-15/proxy/love520-1/love520-1/confess/upload',
        saveUrl : 'https://1847961572749689.cn-hangzhou.fc.aliyuncs.com/2016-08-15/proxy/love520-1/love520-1/confess/save',
		ossUrl : 'https://itheima-test20210509.oss-cn-beijing.aliyuncs.com/',

Map map1 = restTemplate.getForObject("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=小程序ID&secret=小程序secret", Map.class);
        String token = (String) map1.get("access_token");
        Boolean aBoolean = PickCheckUtil.checkPic(file,token);
        if(!aBoolean){
            return "error";
        }

String content = confess.getTo() + "," + confess.getContent();
        Map map1 = restTemplate.getForObject("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=小程序ID&secret=小程序secret", Map.class);
        String token = (String) map1.get("access_token");
        HashMap

Map map1 = restTemplate.getForObject("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=小程序ID&secret=小程序secret", Map.class);
        String token = (String) map1.get("access_token");
        Boolean aBoolean = PickCheckUtil.checkPic(file,token);
        if(!aBoolean){
            return "error";
        }

String content = confess.getTo() + "," + confess.getContent();
        Map map1 = restTemplate.getForObject("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=小程序ID&secret=小程序secret", Map.class);
        String token = (String) map1.get("access_token");
        HashMap