This lesson's interactive features are locked, please to keep using them

Connect

Let's scaffold the Peril project! Fork and then clone starter code from GitHub and move it somewhere on your machine. We will use this project for the rest of the course.

The starter code contains a few interesting things

The internal/gamelogic package which contains the game logic for the Peril game.
The internal/routing package which contains some routing constants for the game.
Stubs of the cmd/client and cmd/server packages, which are main packages that run the client and server for the game.
The rabbit.sh script: a convenience for starting and stopping RabbitMQ with Docker. You can run:
- ./rabbit.sh start to start RabbitMQ
- ./rabbit.sh stop to stop it
- ./rabbit.sh logs to view the server logs

Assignment

Install the Go AMQP library:

go get github.com/rabbitmq/amqp091-go

Update the cmd/server package's main.go. You'll want to use an alias to import the amqp package:

import (
    amqp "github.com/rabbitmq/amqp091-go"
)

In the main function, do the following:
1. Declare a connection string with the value: amqp://guest:guest@localhost:5672/. This is how your application will know where to connect to the RabbitMQ server.
2. Call amqp.Dial with the connection string to create a new connection to RabbitMQ.
3. Defer a .Close() of the connection to ensure it's closed when the program exits.
4. Print a message to the console that the connection was successful.
5. Wait for a signal (e.g. Ctrl+C) to exit the program.
6. If a signal is received, print a message to the console that the program is shutting down and close the connection.

To test your code, use the script to start a RabbitMQ server with Docker in the background:

./rabbit.sh start

Once it's running, open a new terminal and run your server:

go run ./cmd/server

You should see your message that the connection was successful. Press Ctrl+C to exit the program and see the shutdown message.

Tip

The Go standard library has a package called os/signal that you can use to listen for signals. Here's an example of how you can listen for a signal:

// wait for ctrl+c
signalChan := make(chan os.Signal, 1)
signal.Notify(signalChan, os.Interrupt)
<-signalChan