<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-function-adapter-aws</artifactId>
    <version>3.2.1</version>
</dependency>

@Component
public class GreetingFunction {
    public String greet(String name) {
        return "Hello, " + name + "!";
    }
}

service: spring-boot-serverless
provider:
  name: aws
  runtime: java11
  region: us-east-1
functions:
  greeting:
    handler: org.springframework.cloud.function.adapter.aws.FunctionInvoker::handleRequest
    events:
      - http:
          path: /greeting
          method: get
package:
  artifact: target/spring-boot-serverless-0.0.1-SNAPSHOT.jar

# 構(gòu)建項(xiàng)目
mvn clean package
# 部署函數(shù)
serverless deploy

@Component
public class EventHandler {
    // 處理 S3 事件
    public String handleS3Event(S3Event event) {
        // 處理 S3 事件邏輯
        return "S3 event processed";
    }
    // 處理 SQS 事件
    public String handleSqsEvent(SQSEvent event) {
        // 處理 SQS 事件邏輯
        return "SQS event processed";
    }
    // 處理 API Gateway 事件
    public APIGatewayProxyResponseEvent handleApiEvent(APIGatewayProxyRequestEvent event) {
        // 處理 API Gateway 事件邏輯
        APIGatewayProxyResponseEvent response = new APIGatewayProxyResponseEvent();
        response.setStatusCode(200);
        response.setBody("API event processed");
        return response;
    }
}

@Service
public class GreetingService {
    public String greet(String name) {
        return "Hello, " + name + "!";
    }
}
@Component
public class GreetingFunction {
    private final GreetingService greetingService;
    public GreetingFunction(GreetingService greetingService) {
        this.greetingService = greetingService;
    }
    public String greet(String name) {
        return greetingService.greet(name);
    }
}

@Configuration
public class DatabaseConfig {
    @Bean
    public DataSource dataSource() {
        HikariConfig config = new HikariConfig();
        config.setJdbcUrl(System.getenv("DATABASE_URL"));
        config.setUsername(System.getenv("DATABASE_USER"));
        config.setPassword(System.getenv("DATABASE_PASSWORD"));
        return new HikariDataSource(config);
    }
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
}
@Service
public class UserService {
    private final JdbcTemplate jdbcTemplate;
    public UserService(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
    public User getUserById(Long id) {
        String sql = "SELECT * FROM users WHERE id = ?";
        return jdbcTemplate.queryForObject(sql, new Object[]{id}, (rs, rowNum) -> {
            User user = new User();
            user.setId(rs.getLong("id"));
            user.setName(rs.getString("name"));
            user.setEmail(rs.getString("email"));
            return user;
        });
    }
}
@Component
public class UserFunction {
    private final UserService userService;
    public UserFunction(UserService userService) {
        this.userService = userService;
    }
    public User getUser(Long id) {
        return userService.getUserById(id);
    }
}

@Configuration
@ConfigurationProperties(prefix = "app")
public class AppConfig {
    private String greeting;
    private int timeout;
    // getter 和 setter 方法
}
@Component
public class GreetingFunction {
    private final AppConfig appConfig;
    public GreetingFunction(AppConfig appConfig) {
        this.appConfig = appConfig;
    }
    public String greet(String name) {
        return appConfig.getGreeting() + ", " + name + "!";
    }
}

@Component
public class UserFunctions {
    private final UserService userService;
    public UserFunctions(UserService userService) {
        this.userService = userService;
    }
    public User getUser(Long id) {
        return userService.getUserById(id);
    }
    public User createUser(User user) {
        return userService.createUser(user);
    }
    public User updateUser(User user) {
        return userService.updateUser(user);
    }
    public boolean deleteUser(Long id) {
        return userService.deleteUser(id);
    }
}

service: spring-boot-serverless
provider:
  name: aws
  runtime: java11
  region: us-east-1
functions:
  getUser:
    handler: org.springframework.cloud.function.adapter.aws.FunctionInvoker::handleRequest
    events:
      - http:
          path: /users/{id}
          method: get
  createUser:
    handler: org.springframework.cloud.function.adapter.aws.FunctionInvoker::handleRequest
    events:
      - http:
          path: /users
          method: post
  updateUser:
    handler: org.springframework.cloud.function.adapter.aws.FunctionInvoker::handleRequest
    events:
      - http:
          path: /users
          method: put
  deleteUser:
    handler: org.springframework.cloud.function.adapter.aws.FunctionInvoker::handleRequest
    events:
      - http:
          path: /users/{id}
          method: delete
package:
  artifact: target/spring-boot-serverless-0.0.1-SNAPSHOT.jar

@Component
public class OrderEventHandler {
    private final OrderService orderService;
    
    public OrderEventHandler(OrderService orderService) {
        this.orderService = orderService;
    }
    
    public String handleOrderCreated(SQSEvent event) {
        for (SQSEvent.SQSMessage message : event.getRecords()) {
            try {
                Order order = new ObjectMapper().readValue(message.getBody(), Order.class);
                orderService.processOrder(order);
            } catch (JsonProcessingException e) {
                e.printStackTrace();
            }
        }
        return "Order events processed";
    }
}

service: spring-boot-serverless
provider:
  name: aws
  runtime: java11
  region: us-east-1
functions:
  handleOrderCreated:
    handler: org.springframework.cloud.function.adapter.aws.FunctionInvoker::handleRequest
    events:
      - sqs:
          arn: arn:aws:sqs:us-east-1:123456789012:order-created-queue
package:
  artifact: target/spring-boot-serverless-0.0.1-SNAPSHOT.jar