Observer — แนวคิดหลักของแพทเทิร์นการสมัครสมาชิกการเปลี่ยนแปลง

Observer คืออะไร: แก่นแท้ของแพทเทิร์นผู้สังเกตการณ์

Observer — แพทเทิร์นเชิงพฤติกรรม GoF ที่กำหนดความสัมพันธ์แบบหนึ่งต่อหลายระหว่างออบเจ็กต์ เมื่อออบเจ็กต์หนึ่ง (Subject หรือ Observable) เปลี่ยนสถานะ ออบเจ็กต์ที่ขึ้นต่อกันทั้งหมด (Observers) จะได้รับการแจ้งเตือนและอัปเดตโดยอัตโนมัติ แพทเทิร์นนี้ใช้การเชื่อมโยงแบบหลวม: ผู้เผยแพร่ไม่ทราบคลาสเฉพาะของผู้สมัครสมาชิก — เพียงแต่ว่าพวกเขาใช้อินเทอร์เฟซ Observer

โครงสร้าง Observer ประกอบด้วยอินเทอร์เฟซ Subject พร้อมเมธอด attach(), detach(), notify() และอินเทอร์เฟซ Observer พร้อมเมธอด update() ConcreteSubject เก็บสถานะและรายการผู้สมัครสมาชิก ConcreteObserver ใช้ update() และตอบสนองต่อการเปลี่ยนแปลง ในการพัฒนาแอปมือถือ การนำ GoF แบบคลาสสิกไปใช้นั้นหายาก — ถูกแทนที่ด้วยกลไกในตัว: NotificationCenter, Combine, Flow, LiveData ซึ่งใช้แนวคิดเดียวกันกับ API ที่ทันสมัย

โมเดล Push vs Pull — ในโมเดล Push Subject จะส่งข้อมูลไปยังผู้สมัครสมาชิกทั้งหมด (NotificationCenter.post) ในโมเดล Pull Subject จะแจ้งเตือนเท่านั้น และผู้สมัครสมาชิกจะขอข้อมูลเอง Android LiveData ใช้ Push (ข้อมูลถูกส่งใน observe()) RxJava/Flow รองรับทั้งสองโมเดล การเลือกขึ้นอยู่กับงาน: Push ง่ายกว่าสำหรับการอัปเดต UI Pull มีประสิทธิภาพมากกว่าสำหรับข้อมูลปริมาณมากที่ผู้สมัครสมาชิกอาจไม่ต้องการรับ

Observer ใน iOS: NotificationCenter, Combine และ KVO

NotificationCenter — กลไกในตัวของ iOS/macOS สำหรับการใช้ Observer ผู้เผยแพร่ส่ง Notification ผ่าน NotificationCenter.default.post(name:, object:, userInfo:) ผู้สมัครสมาชิกลงทะเบียนผ่าน addObserver(forName:, queue:, using:) NotificationCenter รองรับการแจ้งเตือนที่มีชื่อ (Notification.Name) และสามารถส่งข้อมูลใด ๆ ใน userInfo UIKeyboardWillShowNotification, UIApplicationDidEnterBackgroundNotification — ตัวอย่างของระบบ

extension Notification.Name {
    static let userDidLogin = Notification.Name("userDidLogin")
}

// ผู้เผยแพร่
NotificationCenter.default.post(
    name: .userDidLogin,
    object: nil,
    userInfo: ["userId": "123"]
)

// ผู้สมัครสมาชิก
class ProfileViewModel {
    private var observers: [NSObjectProtocol] = []

    func startObserving() {
        let observer = NotificationCenter.default.addObserver(
            forName: .userDidLogin,
            object: nil,
            queue: .main
        ) { [weak self] notification in
            guard let userId = notification.userInfo?["userId"] as? String else { return }
            // ผู้สมัครสมาชิกตอบสนองต่อเหตุการณ์
            self?.loadProfile(userId: userId)
        }
        observers.append(observer)
    }

    func stopObserving() {
        observers.forEach { NotificationCenter.default.removeObserver($0) }
        observers.removeAll()
    }
}

เฟรมเวิร์ก Combine — ทางเลือกเชิงรับที่ทันสมัยสำหรับ NotificationCenter เปิดตัวใน iOS 13 Publisher (NotificationCenter, URLSession, Timer) — ผู้เผยแพร่, Subscriber (sink, assign) — ผู้สมัครสมาชิก Combine เพิ่มตัวดำเนินการ (map, filter, combineLatest) สำหรับการแปลงสตรีมข้อมูล @Published — property wrapper ที่แจ้งให้ผู้สมัครสมาชิกทราบเกี่ยวกับการเปลี่ยนแปลงโดยอัตโนมัติ ใน MVVM กับ SwiftUI Combine แทนที่ NotificationCenter สำหรับเชื่อมต่อ ViewModel และ View

KVO (Key-Value Observing) — กลไก ObjC/Swift รุ่นเก่าสำหรับสังเกตคุณสมบัติแต่ละรายการของออบเจ็กต์ @objc dynamic var name: String — คุณสมบัติที่สังเกตได้ observe(.name) — การสมัครสมาชิก KVO ทำงานเฉพาะกับคลาสที่เข้ากันได้กับ @objc และการสืบทอด ObjC Apple แนะนำ Combine และ @Published แทน KVO ในโปรเจ็กต์ใหม่ KVO ยังคงเกี่ยวข้องสำหรับความเข้ากันได้กับ UIKit ในโปรเจ็กต์แบบผสม

Observer ใน Android: LiveData, StateFlow และ SharedFlow

LiveData — คอมโพเนนต์ของ Android Architecture Components สำหรับการใช้ Observer คลาสที่สังเกตได้ซึ่งแจ้งให้ผู้สมัครสมาชิกทราบเกี่ยวกับการเปลี่ยนแปลงข้อมูล LiveData ตระหนักถึงวงจรชีวิต: ผู้สมัครสมาชิก (LifecycleOwner) ยกเลิกการสมัครโดยอัตโนมัติเมื่อถูกทำลาย LiveData ใช้โมเดล Push: ข้อมูลถูกส่งใน observe() LiveData เป็นบล็อกพื้นฐานของ MVVM ใน Android ก่อน Jetpack Compose

// ViewModel — ผู้เผยแพร่
class UserViewModel : ViewModel() {
    private val _user = MutableLiveData<User?>(null)
    val user: LiveData<User?> = _user

    fun loadUser(id: String) {
        viewModelScope.launch {
            val result = userRepository.getUser(id)
            _user.value = result
        }
    }
}

// Fragment — ผู้สมัครสมาชิก
class UserFragment : Fragment() {
    private val viewModel: UserViewModel by viewModels()

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        viewModel.user.observe(viewLifecycleOwner) { user ->
            // ผู้สมัครสมาชิกตอบสนองต่อการเปลี่ยนแปลง
            userName.text = user?.name
            userEmail.text = user?.email
        }
    }
}

StateFlow และ SharedFlow — ชนิดเชิงรับจาก Kotlin Coroutines ที่แทนที่ LiveData ใน Jetpack Compose StateFlow — ตัวเก็บสถานะที่สังเกตได้พร้อมค่าปัจจุบันคงที่ SharedFlow — โฟลว์ร้อนที่กำหนดค่าได้โดยไม่มีสถานะ เหมาะสำหรับเหตุการณ์ครั้งเดียว (การนำทาง, โทสต์) ทั้งสองชนิดถูกรวมเข้ากับ Compose อย่างใกล้ชิด: collectAsState(), collectAsEffect() StateFlow เป็นข้อบังคับในโปรเจ็กต์ Android สมัยใหม่กับ Compose

LiveData vs StateFlow — LiveData ผูกกับวงจรชีวิต Android, StateFlow ไม่ขึ้นกับแพลตฟอร์ม StateFlow รองรับ coroutines, ตัวดำเนินการ (map, filter) และสามารถทดสอบได้โดยไม่ต้องพึ่งพา Android LiveData ง่ายกว่าสำหรับความเข้ากันได้กับ Java Google แนะนำ StateFlow สำหรับโปรเจ็กต์ใหม่บน Kotlin + Compose, LiveData สำหรับการบำรุงรักษาโปรเจ็กต์เก่าหรือโค้ด Java

การจัดการการสมัครสมาชิกและหน่วยความจำรั่ว

หน่วยความจำรั่ว — ปัญหาหลักของ Observer หากไม่มีการจัดการการสมัครสมาชิกที่เหมาะสม หากผู้สมัครสมาชิก (Activity, Fragment, UIViewController) ถูกทำลายแต่ไม่ได้ยกเลิกการสมัคร ผู้เผยแพร่จะยังคงเก็บการอ้างอิงถึงมันและตัวเก็บขยะไม่สามารถปล่อยหน่วยความจำได้ ใน Android LifecycleOwner (Activity/Fragment) ควรเรียก removeObserver() หรือใช้ observe(viewLifecycleOwner) ใน iOS — removeObserver ใน deinit หรือ disposeBag ใน Combine

การอ้างอิงแบบอ่อนในผู้สมัครสมาชิก — เมื่อใช้ closure ในบล็อกการสมัครสมาชิก ให้ใช้ [weak self] ใน Swift และอ้างอิงขอบเขตวงจรชีวิตใน Kotlin LiveData จัดการการสมัครสมาชิกโดยอัตโนมัติผ่าน LifecycleOwner — การสมัครสมาชิกจะทำงานเฉพาะเมื่อ Lifecycle อยู่ในสถานะ STARTED หรือ RESUMED StateFlow ใน Compose ใช้ collectAsState() โดยคำนึงถึงวงจรชีวิต NotificationCenter ใน iOS ต้องใช้ [weak self] อย่างชัดเจนเนื่องจาก closure เก็บการอ้างอิงแบบแข็งไปยัง self

Observer vs ผู้เผยแพร่-ผู้สมัครสมาชิก: ความแตกต่าง

Observer (GoF) และผู้เผยแพร่-ผู้สมัครสมาชิก (PubSub) — แพทเทิร์นที่คล้ายกันแต่ต่างกัน ใน Observer ผู้เผยแพร่แจ้งผู้สมัครสมาชิกโดยตรงโดยเรียกเมธอดของพวกเขา ผู้เผยแพร่รู้เกี่ยวกับผู้สมัครสมาชิก (เก็บรายการ) ใน PubSub ผู้เผยแพร่และผู้สมัครสมาชิกไม่รู้จักกัน — มีตัวกลาง (Event Bus, Message Queue, NotificationCenter) อยู่ระหว่างพวกเขา ผู้เผยแพร่ส่งข้อความไปยังช่องทาง ผู้สมัครสมาชิกฟังช่องทาง PubSub มีการเชื่อมโยงที่หลวมกว่า

ตัวอย่างของ PubSub ในการพัฒนาแอปมือถือ — NotificationCenter ใน iOS ถือได้ว่าเป็น PubSub: ผู้เผยแพร่ไม่รู้จักผู้สมัครสมาชิก — เพียงแค่โพสต์การแจ้งเตือน EventBus หรือ Otto ใน Android (เลิกใช้แล้ว) SharedFlow กับ BroadcastChannel — PubSub ในโลก Kotlin ในระบบกระจาย PubSub ถูกนำไปใช้ผ่าน RabbitMQ, Kafka, Google PubSub สำหรับการพัฒนาแอปมือถือ PubSub มีประโยชน์ในสถาปัตยกรรมแบบโมดูลที่โมดูลไม่ควรพึ่งพากัน

เลือกอะไร — สำหรับการอัปเดต UI (ViewModel → View) ให้ใช้ Observer (LiveData, StateFlow, @Published) สำหรับเหตุการณ์ระหว่างโมดูล (การยืนยันตัวตน, การออกจากระบบ, การเปลี่ยนธีม) — PubSub (SharedFlow, NotificationCenter, EventBus) Observer ง่ายกว่าและมีประสิทธิภาพมากกว่าภายในหน้าจอเดียว PubSub ยืดหยุ่นกว่าสำหรับเหตุการณ์ทั่วโลกแต่ดีบักยากกว่าเนื่องจากการพึ่งพาโดยนัย