在C#中,是不是已经使用Events实现的观察者模式？
在C#中，观察者模式通常是通过使用事件（Events）来实现的。事件是一种特殊的委托类型，允许一个类（发布者）在某个事件发生时通知其他类（订阅者）。
在C#中，要实现观察者模式，通常需要遵循以下步骤：
- 定义一个事件（Event）：在发布者类中定义一个事件，该事件将在特定情况下触发。
- 订阅事件（Subscribe）：订阅者类将自身的方法与发布者类中的事件关联起来。
- 发布事件（Publish）：当发布者类中的某个事件触发时，所有订阅了该事件的订阅者类将接收到通知。
以下是一个简单的C#观察者模式示例：
public class Publisher
{
public event EventHandler<string> OnMessage;
public void SendMessage(string message)
{
OnMessage?.Invoke(this, message);
}
}
public class Subscriber
{
public void Subscribe(Publisher publisher)
{
publisher.OnMessage += OnMessageReceived;
}
private void OnMessageReceived(object sender, string message)
{
Console.WriteLine($"Message received: {message}");
}
}在这个示例中，Publisher类定义了一个名为OnMessage的事件，当有新消息时触发。Subscriber类通过订阅该事件，在接收到消息时执行OnMessageReceived方法。
总之，在C#中，观察者模式可以通过使用事件实现，但需要注意的是，这种实现方式并不局限于C#，也可以应用于其他支持事件机制的编程语言。
相关·内容
2回答
从reactive stream SubmissionPublisher接收项目
reactive-programming、java-9、reactive-streams
我在尝试Java 9中的一些新特性，所以我做了一个测试，让一个发布者以给定的速率发出数字。我还实现了一个订阅服务器来监听这些出版物，并将它们打印到控制台。
尽管我可能不完全理解如何使用这个getLastItem()，因为Api方法不打印任何内容，而Api只返回0。
唯一起作用的部分似乎是正确初始化lastItem变量的onSubscribe()。
@Test
public void testReactiveStreams(){
//Create Publisher
SubmissionPublisher<Integer> publisher = new Submis
浏览 4提问于2017-03-15得票数 5
2回答
垃圾收集器和事件处理程序
c#、events、garbage-collection
一个简单的问题。假设我在下面的例子中实现了一个类。
class Subscriber
{
private Publisher publisher = new Publisher;
public Subscriber()
{
publisher.SomeEvent += new EventHandler(OnEventFired);
}
private void OnEventFired(object sender, EventArgs e)
{
}
}
在程序中的某个地方，我有一个方法，看起来像这样：
public
浏览 6提问于2011-07-13得票数 8
回答已采纳
3回答
在订阅服务器线程中调用Thread.Sleep会导致发布服务器线程休眠
java、multithreading、design-patterns
我已经在我的应用程序中实现了发布和订阅模式，但是当我在任何一个订阅者或任何一个订阅者中调用Thread.sleep()方法抛出异常时，所有其他订阅者和发布者都会受到此影响，所以我如何防止这种情况发生。
我已经创建了上述问题的一个小演示
发布者代码
import java.util.Random;
public class Publisher extends Thread {
Broker broker = Broker.getInstance();
Random random = new Random();
@Override
public void ru
浏览 3提问于2018-07-26得票数 2
1回答
发布主题的订阅者接收事件的顺序
kotlin、rx-java、rx-java2、rx-kotlin2
我有一个具有多个订阅者的发布主题：
下面是这个类：
class Real {
private val publisher: PublishSubject<String> = PublishSubject.create()
fun doPublish() {
for (i in 1 until 20) {
publisher.onNext("$i Hello")
}
publisher.onComplete()
}
fun doSubscribe() {
浏览 2提问于2020-05-05得票数 0
4回答
如何在java中获取实现接口类
java、android、oop
我的问题非常接近Java通知/观察者设计模式。我做过不同的java / Android编程。我想了解的一件事是publisher如何知道实现给定接口的类是什么。例如，在android中，当摄像头准备就绪时，如果你实现了一个特定的接口，就会调用一个方法。android如何在打开摄像头时调用此方法，而不向android注册我的类。
class mydevice implements camerainterface{
public void cameraup(){
// Implementing my logic when camera up. How android know t
浏览 0提问于2017-05-15得票数 2
2回答
分离事件
c#、performance、memory-leaks、event-handling
我已经在我的WPF应用程序中跟踪了C#代码，并且有一个关于分离事件的问题。
public class Publisher
{
public event EventHandler Completed;
public void Process()
{
// do something
if (Completed != null)
{
Completed(this, EventArgs.Empty);
}
}
}
public class Subscriber
{
publ
浏览 4提问于2017-09-07得票数 0
3回答
C#主题观察者体系结构问题
c#、design-patterns、.net、programming-practices、observer-pattern
我正在以稍微不同的方式使用Subject观察者设计模式来制作一个C#应用程序。
我将提供程序类传递给观察者类构造器，实现IObservable (这个方法有通知订阅它的所有类的OnNext()方法)，实现IObserver (它作用于提供者类发布的OnNext()方法)。
这样，每个观察者类都具有执行OnNext()方法通知其他类更改的能力。
因此，我的示例项目的一个非常简单的外观如下：
ProviderClass provider;
ObserverClass observer1;
ObserverClass observer2;
.......... observer3;
........
浏览 0提问于2015-03-27得票数 1
2回答
ZMQ Pub Sub -它应该丢弃消息吗？
java、publish、zeromq、subscribe
正在尝试测试一个简单的pub/sub实现。我发现，如果我让订阅者打开并发送消息，订阅者并不能接收到所有的消息。有时全部接收，有时部分接收，有时全集不接收。
运行订阅服务器(保持运行)，然后多次运行发布服务器。
import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Context;
import org.zeromq.ZMQ.Socket;
public static void main (String[] args) {
// Prepare our context and subscriber
Context context = ZM
浏览 2提问于2014-09-18得票数 1
2回答
Glassfish & JMS:为什么发布的消息没有到达订阅者那里？
java、glassfish、jms、mq
我有一个运行在远程机器(JDK 1.6.0_30)上的Glassfish 3.1.2服务器。以下代码是在Java SE环境中运行的独立客户端，使用JNDI查找连接到JMS。客户端同时是发布者和订阅者。
我创建了JMS连接池和主题，如下所示：
./asadmin create-jms-resource --restype javax.jms.ConnectionFactory jms/TopicConnectionFactory
./asadmin create-jms-resource --restype javax.jms.Topic jms/TopicUpdate
我启动了这个客户端的两个
浏览 0提问于2012-04-20得票数 2
回答已采纳
1回答
深模块与SRP
oop、architecture、solid-principles
我有一个可以添加内容的消息对象。该消息也可以发送。提供一个向客户端隐藏调度程序的“深层模块”更好，还是每个类只有一个责任更好？
示例:公开调度程序
class Message {
void add(String key, String value) { ... }
}
class Dispatcher {
Result send(Message message) { ... }
}
class DispatcherFactory {
Dispatcher create() { return new DefaultDispatcher(); }
}
示例:隐藏调度程序
class
浏览 0提问于2022-08-25得票数 0
回答已采纳
1回答
如果Rx中没有订阅服务器，则为“默认”订阅(反应性扩展)
c#、.net、system.reactive、reactive
我已经读过这个问题了。
我的情况很相似。
我喜欢创造这样的东西..。
class Example {
private stativ readonly Subject<Unit> EventStreamSubject =
new Subject<Unit>();
public static IObservable<Unit> EventStream {
get {
// TODO
}
}
public static void SetDefault(IO
浏览 0提问于2017-05-08得票数 0
1回答
将subscribe和send结合起来，为什么顺序很重要？
swift、combine
我不明白为什么在这段代码中，如果我在主题订阅了publisher之后在subject上调用send，subscriber似乎没有接收到事件。 而如果我将send调用移到subscribe函数之前，所有的项都会列出(10,20,1,2,3) let publisher = [1,2,3].publisher
let subject = PassthroughSubject<Int, Never>()
let subscriber = subject.sink { print("value :\($0)")}
publisher.su
浏览 11提问于2019-12-23得票数 0
回答已采纳
1回答
ZeroMQ两家酒吧代理
java、proxy、zeromq、publish-subscribe
我想为我们的分布式系统实现一个发布子架构。您在图片中可以看到，网络背后的想法是，我想在java中实现publisher和订户。但是在JZmq曲线中，加密还不被支持。因此，我想在C(++)中实现它可用的代理(目前我只使用java)。
这是我的密码
Subscriber.java：
import java.nio.charset.Charset;
import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Context;
import org.zeromq.ZMQ.Socket;
public class Subscriber {
public stat
浏览 3提问于2015-02-13得票数 1
3回答
这是一个设计模式吗？帮我找出
design-patterns
我想知道我是不是无意中使用了设计模式？请帮帮我。
我有一个应用程序，它将生成事件(event1，事件2，...事件n)。
我还有另一个库(Event Hanlder Library)，其中编写了事件处理方法。
我使用一个接口(通信器)，它的方法是由事件处理程序库实现的"GenerateEvent“。
最后，生成事件的主应用程序...使用反射来加载事件处理程序库，并在运行时根据event no，挂钩( event handler的)特定于事件的类。主应用程序使用接口方法GenerateEvent发送事件
这是一种设计模式，因为在两个程序集之间使用接口来共同工作吗？我可以在伪代码方面提供更
浏览 0提问于2012-08-01得票数 1
2回答
观测器模式实现
c++、c++11、design-patterns、observer-pattern
我正在阅读Head First Design Patterns，我目前正在阅读有关观察者模式的内容。我做的是对的吗？
#include <iostream>
#include <string>
#include <vector>
#include <algorithm>
class ObserverInterface
{
public:
virtual void update(std::string message) = 0;
};
class concreteObserver : ObserverInterface
{
浏览 0提问于2015-07-26得票数 2
回答已采纳
1回答
ViewController.swift可能无法正确加载
swift、uiviewcontroller、xcode6、opentok
我正在使用Xcode6和swift制作一个支持视频聊天的应用程序--使用OpenTok。我有两个场景“菜单”和“视频”。从我使用的菜单中：
self.performSegueWithIdentifier("StreamScene", sender: self)
在按钮内转到“视频”视图控制器。当我第一次加载我的应用程序时，一切都很完美，但是当我从“视频”导航到“菜单”，然后再次从“菜单”导航到“视频”时，我看不到我的会话的订阅者，但当我关闭我的应用程序，但仍然让视频会话运行，并再次启动我的应用程序，并导航到“视频”视窗控制器它工作-这是因为我的ViewControler可能不能
浏览 0提问于2015-08-12得票数 0
1回答
Javascript发布者/订阅者模式示例
javascript、asp.net-mvc-4、publish-subscribe
我正在学习发布者/订阅者模式，为了更好地理解它，我做了一个简单的例子。
var Publisher = {
subscribers: {},
Subscribe: function (event, callback) {
if (Publisher[event] && typeof callback === "function") {
if (Publisher.subscribers[event]) {
Publisher.subscribers[event]
浏览 0提问于2013-04-17得票数 1
回答已采纳
1回答
订阅者未主动接收已发布消息
c#、mqtt
我已经成功地将MQTT连接到我的代理发布者和订阅者都工作得很好，但存在一个问题，我的订阅者没有主动接收消息，当我重新启动订阅者应用程序时，函数mqtt_publishedRecieved仅触发一次，并且一次只接收一条消息。为了获得另一条消息，我必须再次重启我的应用程序。据我所知，这是因为我在启动时调用了我的类的config方法。因此，它只在启动时检查订阅的主题。但我真的希望我的subscriber类中的功能在接收方发布消息后立即接收消息，这意味着两者应该并行工作。我的要求是，如果订阅者已连接，则为=>，在发布者触发时立即接收消息。=>如果订阅者断开连接，则消息应排队，稍后当订阅者
浏览 56提问于2021-11-07得票数 1
回答已采纳
2回答
ZeroMQ / JZMQ -订阅者未收到任何消息
zeromq、jzmq
我检查了ZMQ指南中给出的几个例子，但由于某种原因，subsriber在任何地方都没有收到msgs。以下是我试图测试的代码，但徒劳无功。请给出一个解决方案-
public class SyncPubTest {
protected static int SUBSCRIBERS_EXPECTED = 2;
public static void main (String[] args) {
Context context = ZMQ.context(1);
Socket publisher = context.socket(ZMQ.P
浏览 4提问于2013-06-27得票数 0
回答已采纳
1回答
对发布的确认-- MQTT
ruby、mqtt、ruby-mqtt
如何识别publish到topic是否成功。是否有任何方法可以在发布到某个主题时获得确认。
如果在clients(Publisher/Subscriber)之间的publish期间有任何连接丢失，如何处理它。
我不希望订阅者在收到pay_load后向发布端的特定主题发送ack。
这里是我的红宝石代码：
假设，我已经创建了客户端(@client)，并在双方上进行了配置。
发布
def publish_it
@client.publish('test/hai', 'message')
# Ack the publish
end
订阅
@client.subs
浏览 1提问于2016-06-17得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
