Наблюдатель на Go

Наблюдатель — это поведенческий паттерн, который позволяет объектам оповещать другие объекты об изменениях своего состояния.

При этом наблюдатели могут свободно подписываться и отписываться от этих оповещений.

Подробней о Наблюдателе

Концептуальный пример

На сайте интернет-магазина периодически может заканчиваться определенный товар. В то же время некоторые пользователи могут быть заинтересованы в этом предмете, которого пока что нет в наличии. У этой проблемы может быть 3 варианта решения:

Покупатель самостоятельно периодически проверяет наличие товара.
Интернет-магазин засыпает пользователей оповещениями о поступлениях всех новых товаров в наличие.
Пользователь подписывается только на тот конкретный предмет, который его интересует, и получает оповещение о его возвращении на полки магазина. Также, на один и тот же продукт могут подписаться несколько покупателей.

Вариант 3 звучит наиболее эффективно, и фактически это и есть суть паттерна Наблюдатель. Главные элементы этого паттерна проектирования следующие:

Издатель — публикует событие, когда что-то происходит.
Наблюдатель — подписывается на события субъекта и получает оповещения в случае их возникновения.

subject.go: Издатель

package main

type subject interface {
	register(Observer observer)
	deregister(Observer observer)
	notifyAll()
}

item.go: Конкретный издатель

package main

import "fmt"

type item struct {
	observerList []observer
	name         string
	inStock      bool
}

func newItem(name string) *item {
	return &item{
		name: name,
	}
}
func (i *item) updateAvailability() {
	fmt.Printf("Item %s is now in stock\n", i.name)
	i.inStock = true
	i.notifyAll()
}
func (i *item) register(o observer) {
	i.observerList = append(i.observerList, o)
}

func (i *item) deregister(o observer) {
	i.observerList = removeFromslice(i.observerList, o)
}

func (i *item) notifyAll() {
	for _, observer := range i.observerList {
		observer.update(i.name)
	}
}

func removeFromslice(observerList []observer, observerToRemove observer) []observer {
	observerListLength := len(observerList)
	for i, observer := range observerList {
		if observerToRemove.getID() == observer.getID() {
			observerList[observerListLength-1], observerList[i] = observerList[i], observerList[observerListLength-1]
			return observerList[:observerListLength-1]
		}
	}
	return observerList
}

observer.go: Наблюдатель

package main

type observer interface {
	update(string)
	getID() string
}

customer.go: Конкретный наблюдатель

package main

import "fmt"

type customer struct {
	id string
}

func (c *customer) update(itemName string) {
	fmt.Printf("Sending email to customer %s for item %s\n", c.id, itemName)
}

func (c *customer) getID() string {
	return c.id
}

main.go: Клиентский код

package main

func main() {

	shirtItem := newItem("Nike Shirt")

	observerFirst := &customer{id: "abc@gmail.com"}
	observerSecond := &customer{id: "xyz@gmail.com"}

	shirtItem.register(observerFirst)
	shirtItem.register(observerSecond)

	shirtItem.updateAvailability()
}

output.txt: Результат выполнения

Item Nike Shirt is now in stock
Sending email to customer abc@gmail.com for item Nike Shirt
Sending email to customer xyz@gmail.com for item Nike Shirt

По материалам: Golang By Example