Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Feat]: AWS SQS 연동 #142

Merged
merged 1 commit into from
Jul 1, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,10 @@ dependencies {

// Health Check
implementation 'org.springframework.boot:spring-boot-starter-actuator'

// AWS
implementation platform("io.awspring.cloud:spring-cloud-aws-dependencies:3.0.1")
implementation 'io.awspring.cloud:spring-cloud-aws-starter-sqs'
}

tasks.named('bootBuildImage') {
Expand Down
45 changes: 45 additions & 0 deletions src/main/java/io/sobok/SobokSobok/config/SQSConfig.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,45 @@
package io.sobok.SobokSobok.config;

import io.awspring.cloud.sqs.operations.SqsTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import software.amazon.awssdk.auth.credentials.AwsCredentials;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsAsyncClient;

@Configuration
public class SQSConfig {

@Value("${spring.cloud.aws.credentials.access-key}")
private String AWS_ACCESS_KEY;

@Value("${spring.cloud.aws.credentials.secret-key}")
private String AWS_SECRET_KEY;

@Value("${spring.cloud.aws.region.static}")
private String AWS_REGION;

@Bean
public SqsAsyncClient sqsAsyncClient() {
return SqsAsyncClient.builder()
.credentialsProvider(() -> new AwsCredentials() {
@Override
public String accessKeyId() {
return AWS_ACCESS_KEY;
}

@Override
public String secretAccessKey() {
return AWS_SECRET_KEY;
}
})
.region(Region.of(AWS_REGION))
.build();
}

@Bean
public SqsTemplate sqsTemplate() {
return SqsTemplate.newTemplate(sqsAsyncClient());
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
package io.sobok.SobokSobok.external.aws.sqs;

import io.awspring.cloud.sqs.operations.SendResult;
import io.awspring.cloud.sqs.operations.SqsTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import software.amazon.awssdk.services.sqs.SqsAsyncClient;

@Component
public class SQSMessageSender {

private final SqsTemplate queueMessagingTemplate;

@Value("${spring.cloud.aws.sqs.name}")
private String QUEUE_NAME;

public SQSMessageSender(SqsAsyncClient sqsAsyncClient) {
this.queueMessagingTemplate = SqsTemplate.newTemplate(sqsAsyncClient);
}

public SendResult<SQSPushNotificationRequest> sendMessage(SQSPushNotificationRequest request) {
return queueMessagingTemplate.send(to -> to
.queue(QUEUE_NAME)
.payload(request));
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
package io.sobok.SobokSobok.external.aws.sqs;

public record SQSPushNotificationRequest(

String deviceToken,

String title,

String content
) {
}
Loading