Java Integration with Amazon SQS: Sending and Receiving Messages | Amazon SQS Messaging with Java

🚀 Level Up Your AWS Skills!

Subscribe to Ram N Java for more hands-on AWS SDK and Java tutorials.

SUBSCRIBE ON YOUTUBE

Introduction

Integrating Amazon Simple Queue Service (SQS) with Java is a core skill for building scalable, decoupled applications. In this guide, we'll walk through setting up a Maven project, configuring credentials, and writing the code for both a Producer and a Consumer using the AWS SDK for Java.

Step 1: Maven Project Setup

First, create a new Maven project and add the AWS SDK for SQS dependency to your pom.xml file. This allows your application to communicate with Amazon's messaging infrastructure.

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>sqs</artifactId>
    <version>2.x.x</version>
</dependency>

Step 2: Configure AWS Credentials

Ensure your local machine is configured with valid AWS credentials. You should have a .aws folder containing:

• credentials file: Includes your aws_access_key_id and aws_secret_access_key.
• config file: Specifies your preferred AWS region.

Step 3: Creating the Producer

The Producer's job is to initialize the SqsClient, create a queue (if it doesn't exist), and send messages. Here is the logic:

// Initialize client and send message
SqsClient sqsClient = SqsClient.builder().build();
SendMessageRequest sendMsgRequest = SendMessageRequest.builder()
    .queueUrl(queueUrl)
    .messageBody("Samsung Galaxy")
    .build();
sqsClient.sendMessage(sendMsgRequest);

Step 4: Creating the Consumer

The Consumer polls the queue for messages, processes them, and then explicitly deletes them to prevent reprocessing.

// Receive and delete messages
ReceiveMessageResponse response = sqsClient.receiveMessage(receiveRequest);
for (Message message : response.messages()) {
    System.out.println("Processing: " + message.body());
    // Delete message after processing
    sqsClient.deleteMessage(deleteRequest);
}

Conclusion

By leveraging the AWS SDK for Java, you can implement robust messaging patterns with very little boilerplate code. This setup ensures that your services can exchange data reliably and asynchronously in the cloud. Happy coding!