티스토리 뷰
go get github.com/go-redis/redis/v8
package main
import (
"context"
"fmt"
"github.com/go-redis/redis/v8"
)
func main() {
// Redis 연결
rdb := redis.NewClient(&redis.Options{
Addr: "{host}",
Password: "{password}",
DB: "{dababase}",
})
ctx := context.Background()
pubsub := rdb.Subscribe(ctx, "mychannel")
defer pubsub.Close()
// 고루틴으로 수신된 메시지를 처리
go func() {
for {
msg, err := pubsub.ReceiveMessage(ctx)
if err != nil {
fmt.Println("Error:", err)
return
}
fmt.Println(msg.Payload)
}
}()
err := rdb.Publish(ctx, "mychannel", "Hello world!").Err()
if err != nil {
fmt.Println("Error:", err)
return
}
}
반응형
'공부합시다 > Golang' 카테고리의 다른 글
GVM으로 go설치하기 (0) | 2023.03.30 |
---|---|
golang 웹크롤링 예제 (0) | 2023.03.15 |
Golang으로 Todo 만들기 (0) | 2022.01.21 |
댓글
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
TAG
- django
- MySQL
- vitepress-plugin-mermaid
- password-manager
- graphql
- 정규식
- 컨테이너내에서 메일 발송하기
- l5-swagger-response
- Laravel
- msmtp
- addMonthWithoutOverflow
- 정의
- exception-test
- vitepress
- bitwarden-cli
- l5-swagger
- eloquent-observer
- Python
- laravel-kafka
- POP3
- graphql-php
- 라라벨
- vim
- redis
- 메일
- aaa패턴
- php
- addMonth
- 자바스크립트
- observer 매개변수 전달하기
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | |
7 | 8 | 9 | 10 | 11 | 12 | 13 |
14 | 15 | 16 | 17 | 18 | 19 | 20 |
21 | 22 | 23 | 24 | 25 | 26 | 27 |
28 | 29 | 30 |
글 보관함