主页
产品
Red Hat OpenShift Serverless
1.28
Functions
4.3. 关于调用 Quarkus 功能

4.3. 关于调用 Quarkus 功能

您可以创建一个 Quarkus 项目来响应云事件，或创建响应简单 HTTP 请求的 Quarkus 项目。Knative 中的云事件作为 POST 请求通过 HTTP 传输，因此任一功能类型都可以侦听和响应传入的 HTTP 请求。

收到传入请求时，通过允许类型的实例调用 Quarkus 函数。

Expand

表 4.1. 功能调用选项
调用方法	实例中包含的数据类型	数据示例
HTTP POST 请求	请求正文中的 JSON 对象	`{ "customerId": "0123456", "productId": "6543210" }`
HTTP GET 请求	查询字符串中的数据	`?customerId=0123456&productId=6543210`
`CloudEvent`	`data` 属性中的 JSON 对象	`{ "customerId": "0123456", "productId": "6543210" }`

以下示例显示了接收并处理上表中列出的 customerId 和 productId 购买数据的函数：

Quarkus 功能示例

public class Functions {
    @Funq
    public void processPurchase(Purchase purchase) {
        // process the purchase
    }
}

public class Functions {
    @Funq
    public void processPurchase(Purchase purchase) {
        // process the purchase
    }
}

Copy to Clipboard

Toggle word wrap

包含购买数据的对应 Purchase JavaBean 类如下：

类示例

public class Purchase {
    private long customerId;
    private long productId;
    // getters and setters
}

public class Purchase {
    private long customerId;
    private long productId;
    // getters and setters
}

Copy to Clipboard

Toggle word wrap

4.3.1. 调用示例
复制链接

以下示例代码定义了名为 withBeans、withCloudEvent 和 withBinary 的三个功能；

示例

import io.quarkus.funqy.Funq;
import io.quarkus.funqy.knative.events.CloudEvent;

public class Input {
    private String message;

    // getters and setters
}

public class Output {
    private String message;

    // getters and setters
}

public class Functions {
    @Funq
    public Output withBeans(Input in) {
        // function body
    }

    @Funq
    public CloudEvent<Output> withCloudEvent(CloudEvent<Input> in) {
        // function body
    }

    @Funq
    public void withBinary(byte[] in) {
        // function body
    }
}

import io.quarkus.funqy.Funq;
import io.quarkus.funqy.knative.events.CloudEvent;

public class Input {
    private String message;

    // getters and setters
}

public class Output {
    private String message;

    // getters and setters
}

public class Functions {
    @Funq
    public Output withBeans(Input in) {
        // function body
    }

    @Funq
    public CloudEvent<Output> withCloudEvent(CloudEvent<Input> in) {
        // function body
    }

    @Funq
    public void withBinary(byte[] in) {
        // function body
    }
}

Copy to Clipboard

Toggle word wrap

Functions 类的 withBeans 功能可以通过以下方法调用：

带有 JSON 正文的 HTTP POST 请求：

curl "http://localhost:8080/withBeans" -X POST \
    -H "Content-Type: application/json" \
    -d '{"message": "Hello there."}'

$ curl "http://localhost:8080/withBeans" -X POST \
    -H "Content-Type: application/json" \
    -d '{"message": "Hello there."}'

Copy to Clipboard

Toggle word wrap

带有查询参数的 HTTP GET 请求：

curl "http://localhost:8080/withBeans?message=Hello%20there." -X GET

$ curl "http://localhost:8080/withBeans?message=Hello%20there." -X GET

Copy to Clipboard

Toggle word wrap

二进制编码中的 CloudEvent 对象：

curl "http://localhost:8080/" -X POST \
  -H "Content-Type: application/json" \
  -H "Ce-SpecVersion: 1.0" \
  -H "Ce-Type: withBeans" \
  -H "Ce-Source: cURL" \
  -H "Ce-Id: 42" \
  -d '{"message": "Hello there."}'

$ curl "http://localhost:8080/" -X POST \
  -H "Content-Type: application/json" \
  -H "Ce-SpecVersion: 1.0" \
  -H "Ce-Type: withBeans" \
  -H "Ce-Source: cURL" \
  -H "Ce-Id: 42" \
  -d '{"message": "Hello there."}'

Copy to Clipboard

Toggle word wrap

结构化编码中的 CloudEvent 对象：

curl http://localhost:8080/ \
    -H "Content-Type: application/cloudevents+json" \
    -d '{ "data": {"message":"Hello there."},

$ curl http://localhost:8080/ \
    -H "Content-Type: application/cloudevents+json" \
    -d '{ "data": {"message":"Hello there."},
          "datacontenttype": "application/json",
          "id": "42",
          "source": "curl",
          "type": "withBeans",
          "specversion": "1.0"}'

Copy to Clipboard

Toggle word wrap

与 withBeans 函数类似，可以利用 CloudEvent 对象来调用 Functions 类的 withCloudEvent 功能。但是，与 Beans 不同，CloudEvent 无法通过普通 HTTP 请求来调用。

Functions 类的 withBinary 功能可通过以下方式调用：

二进制编码中的 CloudEvent 对象：

curl "http://localhost:8080/" -X POST \
  -H "Content-Type: application/octet-stream" \
  -H "Ce-SpecVersion: 1.0"\
  -H "Ce-Type: withBinary" \
  -H "Ce-Source: cURL" \
  -H "Ce-Id: 42" \
  --data-binary '@img.jpg'

$ curl "http://localhost:8080/" -X POST \
  -H "Content-Type: application/octet-stream" \
  -H "Ce-SpecVersion: 1.0"\
  -H "Ce-Type: withBinary" \
  -H "Ce-Source: cURL" \
  -H "Ce-Id: 42" \
  --data-binary '@img.jpg'

Copy to Clipboard

Toggle word wrap

结构化编码中的 CloudEvent 对象：

curl http://localhost:8080/ \
  -H "Content-Type: application/cloudevents+json" \
  -d "{ \"data_base64\": \"$(base64 --wrap=0 img.jpg)\",

$ curl http://localhost:8080/ \
  -H "Content-Type: application/cloudevents+json" \
  -d "{ \"data_base64\": \"$(base64 --wrap=0 img.jpg)\",
        \"datacontenttype\": \"application/octet-stream\",
        \"id\": \"42\",
        \"source\": \"curl\",
        \"type\": \"withBinary\",
        \"specversion\": \"1.0\"}"

Copy to Clipboard

Toggle word wrap

返回顶部

4.3. 关于调用 Quarkus 功能

4.3.1. 调用示例
复制链接

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

4.3. 关于调用 Quarkus 功能

4.3.1. 调用示例复制链接链接已复制到粘贴板!

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

4.3.1. 调用示例
复制链接