java消息订阅

Ⅰ java mqtt客户端能不能订阅多个主题

可以设置通配符#、+，但是通配符只能在订阅消息的时候用

Ⅱ java中消息的订阅指的是什么

Connection 对象表示了到两种消息模型中的任一种的消息系统的连接。服务器端和客户机端对象要求管理创建的JMS连接的状态。连接是由Connection Factory创建的并且通过JNDI查寻定位。//取得用于 P2P的 QueueConnectionFactory QueueConnectionFactory = queueConnectionFactory( ); Context messaging = new InitialContext( ); QueueConnectionFactory = (QueueConnectionFactory) Messaging.lookup(“QueueConnectionFactory”); //取得用于 pub/sub的 TopicConnectionFactory TopicConnectonFactory topicConnectionFactory; Context messaging = new InitialContext(); topicConnectionFactory = (TopicConnectionFactory) messaging.lookup(“TopicConnectionFactory”);
注意：用于P2P的代码和用于PublishSubscribe的代码非常相似。
如果 session 被标记为 transactiona l的话，确认消息就通过确认和校正来自动地处理。如果 session 没有标记为 transactional，你有三个用于消息确认的选项：
· AUTO_ACKNOWLEDGE：session 将自动地确认收到一则消息；
· CLIENT_ACKNOWLEDGE：客户端程序将确认收到一则消息，调用这则消息的确认方法；
· DUPS_OK_ACKNOWLEDGE：这个选项命令 session “懒散地”确认消息传递，可以想到，这将导致消息提供者传递的一些复制消息可能会出错。这种确认的方式只应当用于消息消费程序可以容忍潜在的副本消息存在的情况。 queueSession = queueConnection.createQueueSession(false, session.AUTO_ACKNOWLEDGE);//P2P topicSession = topicConnection.createTopicSession(false, session.AUTO_ACKNOWLEDGE); //Pub-Sub
注意：在本例中，一个session目的从连结中创建，非值指出session是non-transactional的，并且 session将自动地确认收到一则消息。

Ⅲ 微信订阅号推送信息给关注的用户运用到JAVA23种设计模式中的哪种

典型的观察着模式，主要为信息同步更新。

Ⅳ java 观察者模式怎么判断是否订阅被中断

观察者（Observer）模式又名发布-订阅（Publish/Subscribe）模式。GOF给观察者模式如下定义：定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。在这里先讲一下面向对象设计的一个重

Ⅳ 怎么用java中的消息发布和订阅完成在三台pc上同时执行一个方法

消息队列专门来解决此类问题，可以使用activemq rabbitmq kafka rokectmq 都可以。具体的安装很使用方法 网上都有 。你的这个场景 是一个发布 多个订阅，

Ⅵ Java消息服务的持久订阅

JMS 通过允许创建持久订阅来简化时间相关性，即使消息预订者未激活也可以接收到消息。此外，使用持久订阅还可通过队列提供灵活性和可靠性，而仍然允许消息被发给许多的接收者。 Topic Subscriber topic Subscriber = topicSession.createDurableSubscriber(topic, subscriptionName);
Connection 对象表示了到两种消息模型中的任一种的消息系统的连接。服务器端和客户机端对象要求管理创建的JMS连接的状态。连接是由Connection Factory创建的并且通过JNDI查寻定位。//取得用于 P2P的 QueueConnectionFactory QueueConnectionFactory = queueConnectionFactory( ); Context messaging = new InitialContext( ); QueueConnectionFactory = (QueueConnectionFactory) Messaging.lookup(“QueueConnectionFactory”); //取得用于 pub/sub的 TopicConnectionFactory TopicConnectonFactory topicConnectionFactory; Context messaging = new InitialContext(); topicConnectionFactory = (TopicConnectionFactory) messaging.lookup(“TopicConnectionFactory”);
注意：用于P2P的代码和用于PublishSubscribe的代码非常相似。
如果 session 被标记为 transactiona l的话，确认消息就通过确认和校正来自动地处理。如果 session 没有标记为 transactional，你有三个用于消息确认的选项：
· AUTO_ACKNOWLEDGE：session 将自动地确认收到一则消息；
· CLIENT_ACKNOWLEDGE：客户端程序将确认收到一则消息，调用这则消息的确认方法；
· DUPS_OK_ACKNOWLEDGE：这个选项命令 session “懒散地”确认消息传递，可以想到，这将导致消息提供者传递的一些复制消息可能会出错。这种确认的方式只应当用于消息消费程序可以容忍潜在的副本消息存在的情况。 queueSession = queueConnection.createQueueSession(false, session.AUTO_ACKNOWLEDGE);//P2P topicSession = topicConnection.createTopicSession(false, session.AUTO_ACKNOWLEDGE); //Pub-Sub
注意：在本例中，一个session目的从连结中创建，非值指出session是non-transactional的，并且 session将自动地确认收到一则消息。

Ⅶ java redis消息订阅与发布 消息发布后 会丢失吗

subscribe是一个阻塞的方法，在取消订阅该频道前，会一直阻塞在这，只有当取消了订阅才会执行下面的other code，参考上面代码，我在onMessage里面收到消息后，调用了this.unsubscribe(); 来取消订阅，这样才会执行后面的other code！java redis消息订阅与发布 消息发布后 会丢失吗

Ⅷ java spring 订阅怎么接收消息

站内消息不需要用到线程。主要都用系统当前时间、消息状态控制消息的显示与否
首先数据库要一张消息表，记录消息体信息。包括消息主题、用户id、时间、发出页面、消息状态。
主体实现主要是用js控制，我们用的dwr技术，将消息体的获取，时间控制及当前时间要显示的消息个数，都写到dwr配置的类中。
接着在消息js中通过dwr生成的js名称调用上述的方法获取消息信息，将数据封装到js中，在需要使用消息的页面只需要导入消息js、dwr的js就可以使用了。
首先后台需要有一个Action接收页面的消息请求,其次页面需要定时循环触发一个到此Action的请求,以获取消息
页面上可以放置一个Iframe专门用于请求消息,但这样会造成页面不停的刷新,所以更好的方法是使用现下说的比较多的Ajax相关技术,做到无刷新的请求后台
另外后台还需要对用户发送的消息进行储存

Ⅸ kafka怎么发布订阅 怎么在java中实现

这是我们项目中用到的代码

publicclassProcerService{
	privatestaticLoggerlog=Logger.getLogger(ProcerService.class);
	privatestaticProcer<String,String>procer=null;
	privatestaticStringserviceIp=PropertiesUtils.getValue("/epoo.properties","bootstrap.servers");
	=PropertiesUtils.getValue("/epoo.properties","name");
publicbooleaninitProcer(){
Propertiesprops=newProperties();


//dataPlace.getIp()
props.put("bootstrap.servers",serviceIp);
props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");
props.put("acks","-1");
procer=newKafkaProcer(props);
try{
List<PartitionInfo>list=procer.partitionsFor(serviceName);

}catch(Exceptione){
JOptionPane.showMessageDialog(null,e.getMessage(),"错误",JOptionPane.YES_OPTION);
log.error(e.getMessage());
returnfalse;
}
returntrue;
}

publicvoidsendData(Stringmess){
if(procer==null){
initProcer();
}

procer.send(newProcerRecord<String,String>(serviceName,mess),newCallback(){
@Override
publicvoidonCompletion(RecordMetadatarm,Exceptione){
if(e!=null){
e.printStackTrace();
log.error(e.getMessage());
}
System.out.println("发送到服务器的Offset:"+rm.offset()+"-----Topic:"+rm.topic()+"-----partition:"+rm.partition());
}
});
}

publicvoidclose(){
if(procer!=null){
procer.close();
}
}
}

Ⅹ java消息推送，一个实时数据的web显示该怎么做