Herkese merhaba!

Uzun yıllardır bol miktarda kişisel zaman ve enerji harcayarak bilgimizi hepinizle paylaşıyoruz. Ancak şu andan itibaren bu blogu çalışır durumda tutabilmek için yardımınıza ihtiyacımız var. Yapmanız gereken tek şey, sitedeki reklamlardan birine tıklamak olacaktır, aksi takdirde hosting vb. masraflar nedeniyle maalesef yayından kaldırılacaktır. Teşekkürler.

İki servis/konteyneriniz olduğunu varsayın. Biri diğerinden bağlantı kabul etmeye hazır olmalıdır. Fark ettiğiniz gibi, "biri çalışıyor olmalı" demedim çünkü "bağlantıları kabul etmeye hazır" ile "çalışıyor olma" arasında fark var. Docker compose öğesinin depends_on anahtarı sorunu her zaman çözemez çünkü yalnızca konteynerin çalışıp çalışmadığını kontrol eder. Eğer bir servis Cassandra, MySQL, RabbitMQ, Elasticsearch benzeri servislere bağlıysa, genellikle böyle olur. Bunların bağlantıları kabul etmeleri zaman alır. Bu sorunu çözmek için ek bir komut dosyası kullanabiliriz. Bu komut dosyası, ana hizmeti çalıştırmadan önce bağlantıları kabul etmeye hazır olana kadar bu hizmetleri düzenli olarak pingleyecektir.


Bu örnekte bir Go ve Cassandra servisimiz var. Go Cassandra bağlıdır. Cassandra bağlantıları kabul etmede yavaştır. Komut dosyamızı, Go servisini başlatmadan önce Cassandra'nın bağlantıları kabul etmesini beklemeye zorlamak için kullanacağız. Cassandra hazır olduğunu söyledikten sonra Go servisini başlatacağız.


Yapı


├── cassandra
│   └── cassandra.go
├── docker
│   ├── cassandra
│   │   ├── Dockerfile
│   │   ├── init.sh
│   │   └── keyspace.cql
│   ├── docker-compose.yaml
│   └── go
│   ├── Dockerfile
│   └── init.sh
└── main.go

Dosyalar


cassandra.go


package cassandra

import (
"time"

"github.com/gocql/gocql"
)

// The `gocql: no response received from cassandra within timeout period` error
// will be prevented by increasing the default timeout value. e.g. 5 sec
type Config struct {
Hosts []string
Port int
ProtoVersion int
Consistency string
Keyspace string
Timeout time.Duration
}

func New(config Config) (*gocql.Session, error) {
cluster := gocql.NewCluster(config.Hosts...)

cluster.Port = config.Port
cluster.ProtoVersion = config.ProtoVersion
cluster.Keyspace = config.Keyspace
cluster.Consistency = gocql.ParseConsistency(config.Consistency)
cluster.Timeout = config.Timeout

return cluster.CreateSession()
}

main.go


package main

import (
"log"
"time"

"github.com/you/auth/cassandra"
)

func main() {
cass, err := cassandra.New(cassandra.Config{
// From docker go to docker cassandra: "172.17.0.1"
// From local go to docker cassandra: "127.0.0.1"
Hosts: []string{"172.17.0.1"},
Port: 9042,
ProtoVersion: 4,
Consistency: "Quorum",
Keyspace: "tetris",
Timeout: time.Second * 5,
})
if err != nil {
log.Fatalln(err)
}
defer cass.Close()

log.Printf("%+v\n", cass)
}

docker-compose.yaml


version: "3.7"

services:

tetris-cassandra:
build: "cassandra"
container_name: "tetris-cassandra"
ports:
- "9042:9042"
environment:
- "MAX_HEAP_SIZE=256M"
- "HEAP_NEWSIZE=128M"

tetris-go:
build:
context: ".."
dockerfile: "docker/go/Dockerfile"
container_name: "tetris-go"
environment:
DB_HOST: "tetris-cassandra"
DB_PORT: "9042"
depends_on:
- "tetris-cassandra"

Dockerfile (cassandra)


FROM cassandra:3.11.9

COPY ./keyspace.cql /keyspace.cql
COPY ./init.sh /init.sh

RUN chmod +x /init.sh

ENTRYPOINT ["./init.sh"]

init.sh (cassandra)


#!/bin/bash

set -eu

echo "Creating keyspace ..."

sleep=1
index=0
limit=60

while :
do
cqlsh < /keyspace.cql && echo "$(date) Created keyspace ..." && break

index=$(( index + 1 ))

echo "$(date) Waiting for keyspace $sleep seconds ($index/$limit) ..."
sleep $sleep

if [ $index -eq $limit ]
then
echo "$(date) Failed to create keyspace, terminating ..."
exit 1
fi
done &

./docker-entrypoint.sh "$@"

keyspace.cql (cassandra)


DROP KEYSPACE IF EXISTS tetris;

CREATE KEYSPACE IF NOT EXISTS tetris
WITH replication = {
'class': 'NetworkTopologyStrategy',
'datacenter1': 1
};

Dockerfile (go)


FROM golang:1.15-alpine3.12 as build

WORKDIR /source
COPY . .

RUN CGO_ENABLED=0 go build -ldflags "-s -w" -o bin/tetris main.go

FROM alpine:3.12

COPY --from=build /source/bin/tetris /bin/tetris
COPY --from=build /source/docker/go/init.sh /init.sh

RUN chmod +x /init.sh

ENTRYPOINT ["./init.sh"]

init.sh (go)


#!/bin/sh

set -eu

echo "$(date) Connecting to database ..."

sleep=1
index=0
limit=60

until [ $index -ge $limit ]
do
nc -z "${DB_HOST}" "${DB_PORT}" && break

index=$(( index + 1 ))

echo "$(date) Waiting for database $sleep seconds ($index/$limit) ..."
sleep $sleep
done

if [ $index -eq $limit ]
then
echo "$(date) Failed to connect to database, terminating ..."
exit 1
fi

echo "$(date) Connected to database ..."
echo "$(date) Allowing database 3 seconds to complete migrations ..."
sleep 3

./bin/tetris

Test


$ docker-compose -f docker/docker-compose.yaml up

tetris-cassandra | Mon 01 Feb 2021 10:02:52 PM UTC Waiting for keyspace 1 seconds (14/60) ...
tetris-go | Mon Feb 1 22:02:52 UTC 2021 Waiting for database 1 seconds (19/60) ...
tetris-go | Mon Feb 1 22:02:53 UTC 2021 Waiting for database 1 seconds (20/60) ...
tetris-cassandra | Connection error: ('Unable to connect to any servers', {'127.0.0.1': error(111, "Tried connecting to [('127.0.0.1', 9042)]. Last error: Connection refused")})
tetris-cassandra | Mon 01 Feb 2021 10:02:53 PM UTC Waiting for keyspace 1 seconds (15/60) ...
tetris-go | Mon Feb 1 22:02:54 UTC 2021 Waiting for database 1 seconds (21/60) ...
tetris-cassandra | INFO [main] 2021-02-01 22:02:54,643 CassandraDaemon.java:650 - Startup complete
tetris-go | Mon Feb 1 22:02:55 UTC 2021 Connected to database ...
tetris-go | Mon Feb 1 22:02:55 UTC 2021 Allowing database 3 seconds to complete migrations ...
tetris-cassandra | INFO 2021-02-01 22:02:55,354 MigrationManager.java:338 - Create new Keyspace: KeyspaceMetadata{name=tetris, replication=ReplicationParams{class=NetworkTopologyStrategy, datacenter1=1}}}
tetris-cassandra | Mon 01 Feb 2021 10:02:55 PM UTC Created keyspace ...
tetris-cassandra | INFO 2021-02-01 22:02:55,940 CassandraRoleManager.java:372 - Created default superuser role 'cassandra'
tetris-go | 2021/02/01 22:02:58 &{cons:4 pageSize:5000 ... cfg:{Hosts:[172.17.0.1] CQLVersion:3.0.0 ProtoVersion:4 Port:9042 Keyspace:tetris Consistency:4 ... isClosed:false}