36.
Microservices, Part 2
Written by Tim Condon
Heads up... You're reading this book for free, with parts of this chapter shown beyond this point as text.
Note: This update is an early-access release. This chapter has not yet been updated to Vapor 4.
In the previous chapter, you learned the basics of microservices and how to apply the architecture to the TIL application. In this chapter, you’ll learn about API gateways and how to make microservices accessible to clients. Finally, you’ll learn how to use Docker and Docker Compose to spin up the whole application.
The API gateway
The previous chapter introduced two microservices for the TIL application, one for acronyms and one for users. In a real application, you may have many more services for all different aspects of your application. It’s difficult for clients to integrate with an application made up of such a large number of microservices. Each client needs to know what each microservice does and the URL of each service. The client may even have to use different authentication methods for each service. A microservices architecture makes it hard to split a service into separate services. For example, moving authentication out of the users service in the TIL application would require an update to all clients.
One solution to this problem is the API gateway. An API gateway can aggregate requests from clients and distribute them to all required services. Additionally, an API gateway can retrieve results from multiple services and combine them into a single response.
Most cloud providers offer API gateway solutions to manage large numbers of microservices, but you can easily create your own. In this chapter, you’ll do just that.
Download the starter project for this chapter. The TILAppUsers and TILAppAcronyms projects are the same as the final projects from the previous chapter. There’s a new TILAppAPI project that contains the skeleton for the API gateway.
Starting the services
In Terminal, open three separate tabs. Ensure the MySQL, Postgres and Redis Docker containers are running from the previous chapter. In Terminal, type the following:
docker ps
swift run
swift run
vapor xcode -y
Forwarding requests
In the TILAppAPI Xcode project, open UsersController.swift. Below boot(router:) enter the following:
// 1
func getAllHandler(_ req: Request) throws -> Future<Response> {
return try req.client().get("\(userServiceURL)/users")
}
// 2
func getHandler(_ req: Request) throws -> Future<Response> {
let id = try req.parameters.next(UUID.self)
return try req.client().get("\(userServiceURL)/users/\(id)")
}
// 3
func createHandler(_ req: Request) throws -> Future<Response> {
return try req.client().post("\(userServiceURL)/users") {
createRequest in
// 4
try createRequest.content.encode(
req.content.syncDecode(CreateUserData.self))
}
}
// 1
routeGroup.get(use: getAllHandler)
// 2
routeGroup.get(UUID.parameter, use: getHandler)
// 3
routeGroup.post(use: createHandler)
// 1
func getAllHandler(_ req: Request) throws -> Future<Response> {
return try req.client().get("\(acronymsServiceURL)/")
}
// 2
func getHandler(_ req: Request) throws -> Future<Response> {
let id = try req.parameters.next(Int.self)
return try req.client().get("\(acronymsServiceURL)/\(id)")
}
// 1
acronymsGroup.get(use: getAllHandler)
// 2
acronymsGroup.get(Int.parameter, use: getHandler)
API Authentication
Logging in
Authentication for the API gateway works in exactly the same way as the microservices. First, you must allow a user to log in.
func loginHandler(_ req: Request) throws -> Future<Response> {
// 1
return try req.client().post("\(userServiceURL)/auth/login") {
loginRequest in
// 2
guard let authHeader =
req.http.headers[.authorization].first else {
throw Abort(.unauthorized)
}
// 3
loginRequest.http.headers.add(name: .authorization,
value: authHeader)
}
}
routeGroup.post("login", use: loginHandler)
Accessing protected routes
Back in Xcode, open AcronymsController.swift. Below getHandler(_:), create a new route handler to create an acronym:
func createHandler(_ req: Request) throws -> Future<Response> {
// 1
return try req.client().post("\(acronymsServiceURL)/") {
createRequest in
// 2
guard let authHeader =
req.http.headers[.authorization].first else {
throw Abort(.unauthorized)
}
// 3
createRequest.http.headers.add(
name: .authorization,
value: authHeader)
// 4
try createRequest.content.encode(
req.content.syncDecode(CreateAcronymData.self))
}
}
acronymsGroup.post(use: createHandler)
func updateHandler(_ req: Request) throws -> Future<Response> {
// 1
let acronymID = try req.parameters.next(Int.self)
// 2
return try req.client()
.put("\(acronymsServiceURL)/\(acronymID)") {
updateRequest in
// 3
guard let authHeader =
req.http.headers[.authorization].first else {
throw Abort(.unauthorized)
}
// 4
updateRequest.http.headers.add(
name: .authorization,
value: authHeader)
// 5
try updateRequest.content.encode(
req.content.syncDecode(CreateAcronymData.self))
}
}
func deleteHandler(_ req: Request) throws -> Future<Response> {
// 6
let acronymID = try req.parameters.next(Int.self)
// 7
return try req.client()
.delete("\(acronymsServiceURL)/\(acronymID)") {
deleteRequest in
// 8
guard let authHeader =
req.http.headers[.authorization].first else {
throw Abort(.unauthorized)
}
// 9
deleteRequest.http.headers.add(
name: .authorization,
value: authHeader)
}
}
// 1
acronymsGroup.put(Int.parameter, use: updateHandler)
// 2
acronymsGroup.delete(Int.parameter, use: deleteHandler)
Handling relationships
In the previous chapter, you saw how relationships work with microservices. Getting relationships for different models is difficult for clients in an microservices architecture. You can use the API gateway to help simplify this.
Getting a user’s acronyms
In Xcode, open UsersController.swift. Below loginHandler(_:) add a new route handler to get a user’s acronyms:
func getAcronyms(_ req: Request) throws -> Future<Response> {
// 1
let userID = try req.parameters.next(UUID.self)
// 2
return try req.client()
.get("\(acronymsServiceURL)/user/\(userID)")
}
routeGroup.get(UUID.parameter, "acronyms", use: getAcronyms)
Getting an acronym’s user
Getting a user’s acronyms looks the same as other requests in the microservice as the client knows the user’s ID. Getting the user for a particular acronym is more complicated. Open AcronymsController.swift and add a new route handler to do this below deleteHandler(_:):
func getUserHandler(_ req: Request) throws -> Future<Response> {
// 1
let acronymID = try req.parameters.next(Int.self)
// 2
return try req
.client()
.get("\(acronymsServiceURL)/\(acronymID)")
.flatMap(to: Response.self) { response in
// 3
let acronym =
try response.content.syncDecode(Acronym.self)
// 4
return try req
.client()
.get("\(self.userServiceURL)/users/\(acronym.userID)")
}
}
acronymsGroup.get(Int.parameter, "user", use: getUserHandler)
Running everything in Docker
You now have three microservices that make up your TIL application. These microservices also require another three databases to work. If you’re developing a client application, or another microservice, there’s a lot to run to get started. You may also want to run everything in Linux to check your services deploy correctly. Like in Chapter 11, “Testing”, you’re going to use Docker Compose to run everything.
Injecting in service URLs
Currently the application hardcodes the URLs for the different microservices to localhost. You must change this to run them in Docker Compose. Back in Xcode in TILAppAPI, open AcronymsController.swift. Replace the definitions of userServiceURL and acronymsServiceURL with the following:
let acronymsServiceURL: String
let userServiceURL: String
init(
acronymsServiceHostname: String,
userServiceHostname: String) {
acronymsServiceURL =
"http://\(acronymsServiceHostname):8082"
userServiceURL = "http://\(userServiceHostname):8081"
}
let userServiceURL: String
let acronymsServiceURL: String
init(
userServiceHostname: String,
acronymsServiceHostname: String) {
userServiceURL = "http://\(userServiceHostname):8081"
acronymsServiceURL =
"http://\(acronymsServiceHostname):8082"
}
let usersHostname: String
let acronymsHostname: String
// 1
if let users = Environment.get("USERS_HOSTNAME") {
usersHostname = users
} else {
usersHostname = "localhost"
}
// 2
if let acronyms = Environment.get("ACRONYMS_HOSTNAME") {
acronymsHostname = acronyms
} else {
acronymsHostname = "localhost"
}
// 3
try router.register(collection: UsersController(
userServiceHostname: usersHostname,
acronymsServiceHostname: acronymsHostname))
try router.register(collection: AcronymsController(
acronymsServiceHostname: acronymsHostname,
userServiceHostname: usersHostname))
let authHostname: String
init(authHostname: String) {
self.authHostname = authHostname
}
"http://\(authHostname):8081/auth/authenticate"
let authHostname: String
// 1
if let host = Environment.get("AUTH_HOSTNAME") {
authHostname = host
} else {
authHostname = "localhost"
}
// 2
let authGroup = router.grouped(
UserAuthMiddleware(authHostname: authHostname))
The Docker Compose file
In the root directory containing all three projects, create a new file called docker-compose.yml and open it in an editor. First, define the version and database services:
# 1
version: '3'
services:
# 2
postgres:
image: "postgres"
environment:
- POSTGRES_DB=vapor
- POSTGRES_USER=vapor
- POSTGRES_PASSWORD=password
# 3
mysql:
image: "mysql/mysql-server:5.7"
environment:
- MYSQL_USER=vapor
- MYSQL_PASSWORD=password
- MYSQL_DATABASE=vapor
# 4
redis:
image: "redis"
# 1
til-users:
# 2
depends_on:
- postgres
- redis
# 3
build:
context: ./TILAppUsers
dockerfile: web.Dockerfile
# 4
environment:
- DATABASE_HOSTNAME=postgres
- REDIS_HOSTNAME=redis
- PORT=8081
- ENVIRONMENT=production
- DATABASE_PASSWORD=password
# 1
til-acronyms:
# 2
depends_on:
- mysql
- til-users
# 3
build:
context: ./TILAppAcronyms
dockerfile: web.Dockerfile
# 4
environment:
- DATABASE_HOSTNAME=mysql
- PORT=8082
- ENVIRONMENT=production
- AUTH_HOSTNAME=til-users
# 1
til-api:
# 2
depends_on:
- til-users
- til-acronyms
# 3
ports:
- "8080:8080"
# 4
build:
context: ./TILAppAPI
dockerfile: web.Dockerfile
# 5
environment:
- USERS_HOSTNAME=til-users
- ACRONYMS_HOSTNAME=til-acronyms
- PORT=8080
- ENVIRONMENT=production
Modifying Dockerfiles
Before you can run everything, you must change the Dockerfiles. Docker Compose starts the different containers in the requested order but won’t wait for them to be ready to accept connections. This causes issues if your Vapor application tries to connect to a database before the database is ready. In TILAppAcronyms, open web.Dockerfile. Replace ENTRYPOINT ./Run serve --env $ENVIRONMENT --hostname 0.0.0.0 --port $PORT with the following:
ENTRYPOINT sleep 10 && \
./Run serve --env $ENVIRONMENT --hostname 0.0.0.0 --port $PORT
Running everything
You’re now ready to spin up your application in Docker Compose. In Terminal, in the directory containing docker-compose.yml, enter the following:
docker-compose up
Where to go from here?
In this chapter, you learned how to use Vapor to create an API gateway. This makes it simple for clients to interact with your different microservices. You learned how to send requests between different microservices and return single responses. You also learned how to use Docker Compose to build and start all the microservices and link them together.