ActiveMQ持久化订阅后,为什么Messages Dequeued一直都是0

package com.activmq.tms.PubSub;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;

import org.apache.activemq.ActiveMQConnectionFactory;

import com.activmq.tms.util.SystemContent;

/**

  • 消息的生产者(发送者)
  • @author chen
    *
    */
    public class JMSPub {
    //private static final String USERNAME = SystemContent.getUSERNAME();
    //private static final String PASSWORD = SystemContent.getPASSWORD();
    //private static final String BROKEURL = SystemContent.getURL();
    //private static final int SENDNUM = 10;

    public static void main(String[] args) {
    //连接工厂
    ConnectionFactory connectionFactory = null;
    //链接
    Connection connection = null;
    //会话 接受或者发送消息的线程
    Session session = null;
    //消息的目的地
    Destination destiation = null;
    //消息生成者
    MessageProducer messageProducer = null;
    try {
    //实例化连接工厂
    connectionFactory = new ActiveMQConnectionFactory(SystemContent.getUSERNAME(),SystemContent.getPASSWORD(),SystemContent.getURL());
    //通过工厂获得连接
    connection = connectionFactory.createConnection();
    //启动连接
    connection.start();
    //创建session
    session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
    destiation = session.createTopic("userSyncTopic");
    //创建消息生产者
    messageProducer = session.createProducer(destiation);
    //设置持久化方式/非持久化 如果非持久化,那么意味着MQ的重启会导致消息丢失
    messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);
    //发送消息
    sendMessage(session, messageProducer);
    session.commit();
    } catch (JMSException e) {
    e.printStackTrace();
    }finally{
    if(connection != null){
    try {
    connection.close();
    } catch (JMSException e) {
    e.printStackTrace();
    }
    }
    }
    }

    /**

    • 发送消息
    • @param session
    • @param messageProducer
    • @throws JMSException */ public static void sendMessage(Session session,MessageProducer messageProducer) throws JMSException{ try{ for(int i = 0;i < 10;i++){ TextMessage message = session.createTextMessage("ActiveMQ 发送消息 "+i); message.setStringProperty("property", "消息Property"); messageProducer.send(message); System.out.println("ActiveMQ 已发送消息:"+i); } }catch(Exception e){ e.printStackTrace(); }

    }
    }

package com.activmq.tms.PubSub;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicSubscriber;

import org.apache.activemq.ActiveMQConnectionFactory;

import com.activmq.tms.util.SystemContent;

public class JMSSub{

public static void main(String[] args) {
    //连接工厂
    ConnectionFactory connectionFactory = null;
    //连接
    Connection connection = null;
    //会话
    Session session = null;
    //消息的目的地
    Topic topic = null;
    //消息的消费者(接收方)
    MessageConsumer  consumer = null;
    try {
        connectionFactory = new ActiveMQConnectionFactory(SystemContent.getUSERNAME(),SystemContent.getPASSWORD(),SystemContent.getURL());
        connection = connectionFactory.createConnection();
        connection.setClientID("client_ids");
        connection.start();
        session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
        topic = session.createTopic("userSyncTopic");
        consumer = session.createDurableSubscriber(topic, "client_ids");
        consumer.setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                if(message instanceof TextMessage){
                    TextMessage mes = (TextMessage) message;
                    try {
                        System.out.println("收到的消息:" + mes.getText());
                        mes.acknowledge();
                    } catch (JMSException e) {
                        e.printStackTrace();
                    }
                }
            }
        });
    } catch (JMSException e) {
        e.printStackTrace();
    }finally{

    }
}

}

消费者即使下线后仍能收到消息,可是为什么队列里面的消息数不会减少呀,用的是mysql的持久化方式

1个回答

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
求问,activemq监控中,队列的Messages Enqueued数量比Messages Dequeued少是为什么?

![图片说明](https://img-ask.csdn.net/upload/201908/09/1565322886_337353.png) 但是进到队列里面的消费数据看又没有问题

ActiveMQ持久化文件清除问题?

在学习activemq,用kahaDB持久化,在测试性能时发现 1.如果持久订阅者都在线接收消息,db-.log会自动删除,但是db.data文件越来越大,对以后系统性能肯定会有影响,怎么控制这个文件大小? 2.如果持久订阅者很多,有几个一直不在线,则导致db-.log文件一直保留,即使消息过期了也不会删除,只有所有的持久订阅者都在线后才会删除db-.log 3.设置4个持久订阅者,先一个在线,两个不在线,生产者插入50W条消息后,大概使用了500M磁盘空间,然后让第二个在线消费消息,磁盘空间使用反而增加了一百多M,第三个再消费者启动消费消息,磁盘空间继续增加,除非四个都消费消息之后磁盘空间才会释放,这是什么问题。。。(若是有很多持久订阅者不在线不就把磁盘撑爆了。。。) 请大牛帮忙解释下,是哪个参数配置不对吗?

ActiveMQ 持久化到数据库

Topic消息发送成功,并且并没有消费者进行消费,为什么ACTIVEMQ_MSGS 表中没有任何记录??

把activemq.xml文件更改为mysql持久化之后就会启动报错是怎么回事呢?

在弄activemq持久化的,我把activemq.xml文件更改为mysql持久化之后就会启动报错是怎么回事呢?

activemq持久订阅后kahadb的log在不断增加,可以手动删除吗?

activemq持久订阅后kahadb的log在不断增加,可以手动删除吗? log存在的一个原因就是一些消费者始终没有在线导致数据不能自动删除, 但是项目测试中有一些clientId不会再使用了,请问这种情况下可以删除旧的 log吗?

关于activemq 队列持久化消息传送速度的问题?

我使用两种方法测试activemq在队列模式下使用kahadb持久化消息传送速度,结果上来看两种方法测出来的速度相差很大,一个一万多条每秒,一个五千左右每秒。 两种测试方法的测试机器是一样的,测试用例相同,activemq的配置也是一样的,谁能给分析下为什么速度差很多??? 做服务器机器叫server,方法一:先脚本启动10个消费者,当20秒没有收到消息就退出,再脚本启动10个生产者,几下开始时间T1秒,每个生产者发送10万条消息,并监视是否消费者进程都退出了,若果退出几下时间T2秒,用总的生产数量/(T2-T1-20)(消费者设置20秒超时退出),得到一万多条每秒,CPU大概300左右,io 读写11000k每秒。 方法二:单独测试生产者或者消费者速度,脚本启动十个生产者,每个发送10万条到server,测试结果大概每秒五千条消息,CPU 120左右io读写8500k每秒。 为什么这两种测试情况速度会相差很大呢?没有币给悬赏了,谢谢大家。

用java代码如何设置activemq消息持久化到数据库中?

想将activeMQ消息持久化到数据库中,网上都是说将activeMQ.xml文件做如下设置: <persistence> <jdbcPersistence dataSourceRef=" mysql-ds"/> </persistence> <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/> <property name="username" value="activemq"/> <property name="password" value="activemq"/> <property name="poolPreparedStatements" value="true"/> </bean> 我能否在java代码中进行设置呢?因为我是在eclipse中导入的activemq-all-5.2.0.jar包,开发的系统,包中没有activemq.xml文件。而且时间比较紧,我没有用spring。 而且我是把broker嵌入在eclipse中启动的,代码如下: BrokerService broker = new BrokerService(); broker.setUseJmx(true); broker.setBrokerName(brokerName); broker.addConnector("tcp://localhost:61616"); broker.start(); 用java代码如何设置消息持久化到数据库中?什么教程有这方面的说明吗?您可以帮忙解答一下吗?不胜感激!

activeMQ的疑问,高手求教

![图片说明](https://img-ask.csdn.net/upload/201703/21/1490066185_164005.png) 这个topic 是一个什么信息,我发现每次处理完一条消息后 都会生成这样一条信息,有点儿糊涂。

activeMQ异步,订阅模式,如何解决消息丢失和重发

我们现在在做一个商城项目;使用activeMQ完成系统之间的信息同步,实用异步发 送,发布订阅模式,因为异步,所以使用的事listener监听,这样如果我配置消息 持久化,问题如下: 1. consumer返回给broker的ackknowldge是在onmessage方法后,所以不 会存在消息丢失,对吗? 2. 如果consumer在接收到消息但是未给broker应答,consumer宕机了,默认重发 数是6次,如果我consumer一直宕机,broker会在发送第一条发现连接不上的时候停止发送,还是一直发完6次?最后消息又会怎样? 3. 我的消息都比较重要,不允许丢失,要怎么处理? 各位大哥,我已经看各种博文两天两夜了,实在理解总结不了,请帮忙解惑,不要丢给我一堆连接叫我看,谢谢!

求解决:ActiveMQ在发布订阅模式下会递增式的重复接收消息

求解决:ActiveMQ在发布订阅模式下有多个consumer,consumer会递增式的重复接收消息 问题:springboot集成ActiveMQ实现了消费队列和发布订阅两种消息类型,发布订阅模式下有TopicConsumer1和TopicConsumer2,监听的destination都是alarm.topic,但这两个consumer会递增式的重复接收消息。我的实现代码如下: ------------------------------------------------------------- test入口类 @RunWith(SpringRunner.class) @SpringBootTest(classes = MessageCenterApplication.class) public class ActivemqTest { @Autowired private Producer producer; @Test public void testSendTopicMessage(){ for (int i = 0; i < 5; i++) { producer.sendTopicMessage(Destinations.ALARM_TOPIC, "here is a topic message, the number is " + i); } } /*输出结果如下,这个输出结果不是我所期望的 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 0 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 0 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 1 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 1 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 1 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 1 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 2 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 2 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 2 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 2 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 2 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 2 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 3 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer2接收到的消息内容为:here is a topic message, the number is 4 TopicConsumer1接收到的消息内容为:here is a topic message, the number is 4*/ } ------------------------------------------------------------- Producer实现类 @Component public class Producer { @Autowired @Qualifier("jmsQueueMessagingTemplate") private JmsMessagingTemplate jmsQueueMessagingTemplate; @Autowired @Qualifier("jmsTopicMessagingTemplate") private JmsMessagingTemplate jmsTopicMessagingTemplate; /** * 使用queue消息类型(点对点) */ public void sendQueueMessage(String destination, final String message){ Queue queue = new ActiveMQQueue(destination); jmsQueueMessagingTemplate.convertAndSend(queue, message); } /** * 使用topic消息类型 */ public void sendTopicMessage(String destination, final String message){ Topic topic = new ActiveMQTopic(destination); jmsTopicMessagingTemplate.convertAndSend(topic, message); } } ------------------------------------------------------------- TopicConsumer1和TopicConsumer2的实现代码 @Component public class TopicConsumer1 { @JmsListener(destination = Destinations.ALARM_TOPIC, containerFactory = "jmsListenerContainerFactory4Topic") public void receive(String message){ System.out.println("TopicConsumer1接收到的消息内容为:" + message); } } @Component public class TopicConsumer2 { @JmsListener(destination = Destinations.ALARM_TOPIC, containerFactory = "jmsListenerContainerFactory4Topic") public void receive(String message){ System.out.println("TopicConsumer2接收到的消息内容为:" + message); } } ------------------------------------------------------------- jmsTopicMessagingTemplate对应的bean的配置 @Configuration public class JmsMessagingConfig { @Autowired @Qualifier(value = "jmsQueueTemplate") private JmsTemplate jmsQueueTemplate; @Autowired @Qualifier(value = "jmsTopicTemplate") private JmsTemplate jmsTopicTemplate; @Bean(name = "jmsQueueMessagingTemplate") public JmsMessagingTemplate jmsQueueMessagingTemplate(){ return new JmsMessagingTemplate(jmsQueueTemplate); } @Bean(name = "jmsTopicMessagingTemplate") public JmsMessagingTemplate jmsTopicMessagingTemplate(){ return new JmsMessagingTemplate(jmsTopicTemplate); } } ------------------------------------------------------------ jmsTopicTemplate对应的bean的配置 @Configuration public class JmsConfig { private final JmsProperties jmsProperties; private final ObjectProvider<DestinationResolver> destinationResolver; private final ObjectProvider<MessageConverter> messageConverter; public JmsConfig(JmsProperties jmsProperties, ObjectProvider<DestinationResolver> destinationResolver, ObjectProvider<MessageConverter> messageConverter) { this.jmsProperties = jmsProperties; this.destinationResolver = destinationResolver; this.messageConverter = messageConverter; } @ConfigurationProperties(prefix = "spring.activemq") @Bean(name = "jmsQueueTemplate") @Primary public JmsTemplate jmsQueueTemplate(PooledConnectionFactory pooledConnectionFactory) { JmsTemplate template = new JmsTemplate(pooledConnectionFactory); // 设置为使用queue消息类型 template.setPubSubDomain(false); DestinationResolver destinationResolver = (DestinationResolver) this.destinationResolver.getIfUnique(); if (destinationResolver != null) { template.setDestinationResolver(destinationResolver); } MessageConverter messageConverter = (MessageConverter) this.messageConverter.getIfUnique(); if (messageConverter != null) { template.setMessageConverter(messageConverter); } // deliveryMode, priority, timeToLive 的开关,要生效,必须配置为true,默认false template.setExplicitQosEnabled(true); // DeliveryMode.NON_PERSISTENT=1:非持久 ; DeliveryMode.PERSISTENT=2:持久 template.setDeliveryMode(DeliveryMode.PERSISTENT); // 默认不开启事务 // 如果不启用事务,则会导致XA事务失效; // 作为生产者如果需要支持事务,则需要配置SessionTransacted为true template.setSessionTransacted(true); return template; } @ConfigurationProperties(prefix = "spring.activemq") @Bean(name = "jmsTopicTemplate") public JmsTemplate jmsTopicTemplate(PooledConnectionFactory pooledConnectionFactory) { JmsTemplate template = new JmsTemplate(pooledConnectionFactory); // 设置为使用topic消息类型 template.setPubSubDomain(true); DestinationResolver destinationResolver = (DestinationResolver) this.destinationResolver.getIfUnique(); if (destinationResolver != null) { template.setDestinationResolver(destinationResolver); } MessageConverter messageConverter = (MessageConverter) this.messageConverter.getIfUnique(); if (messageConverter != null) { template.setMessageConverter(messageConverter); } // deliveryMode, priority, timeToLive 的开关,要生效,必须配置为true,默认false template.setExplicitQosEnabled(true); // DeliveryMode.NON_PERSISTENT=1:非持久 ; DeliveryMode.PERSISTENT=2:持久 template.setDeliveryMode(DeliveryMode.PERSISTENT); // 默认不开启事务 // 如果不启用事务,则会导致XA事务失效; // 作为生产者如果需要支持事务,则需要配置SessionTransacted为true template.setSessionTransacted(true); return template; } @ConfigurationProperties(prefix = "spring.activemq") @Bean(name = "jmsListenerContainerFactory4Topic") public DefaultJmsListenerContainerFactory jmsListenerContainerFactory4Topic(PooledConnectionFactory pooledConnectionFactory) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setConnectionFactory(pooledConnectionFactory); // 设置为使用topic消息类型 factory.setPubSubDomain(true); //如果单独配置了分布式事务,则启用 // if (this.transactionManager != null) { // factory.setTransactionManager(transactionManager); // } else { factory.setSessionTransacted(Boolean.valueOf(true)); // } JmsProperties.Listener listener = jmsProperties.getListener(); factory.setAutoStartup(listener.isAutoStartup()); if (listener.getAcknowledgeMode() != null) { factory.setSessionAcknowledgeMode(Integer.valueOf(listener.getAcknowledgeMode().getMode())); } String concurrency = listener.formatConcurrency(); if (concurrency != null){ factory.setConcurrency(concurrency); } return factory; } @ConfigurationProperties(prefix = "spring.activemq") @Bean(name = "jmsListenerContainerFactory4Queue") public DefaultJmsListenerContainerFactory jmsListenerContainerFactory4Queue(PooledConnectionFactory pooledConnectionFactory) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setConnectionFactory(pooledConnectionFactory); // 设置为使用queue消息类型 factory.setPubSubDomain(false); //如果单独配置了分布式事务,则启用 // if (this.transactionManager != null) { // factory.setTransactionManager(transactionManager); // } else { factory.setSessionTransacted(Boolean.valueOf(true)); // } JmsProperties.Listener listener = jmsProperties.getListener(); factory.setAutoStartup(listener.isAutoStartup()); if (listener.getAcknowledgeMode() != null) { factory.setSessionAcknowledgeMode(Integer.valueOf(listener.getAcknowledgeMode().getMode())); } String concurrency = listener.formatConcurrency(); if (concurrency != null){ factory.setConcurrency(concurrency); } return factory; } } -------------------------------------------------------------------------------------- yml配置文件的配置 spring: #jms配置,配合activemq一起配置 jms: listener: concurrency: 1 max-concurrency: 50 #activemq配置 activemq: #默认使用spring-boot-starter-activemq内嵌的activemq,除非明确指定了broker-url in-memory: false user: system password: manager broker-url: auto+nio://192.168.137.5:61616 pool: enabled: true max-connections: 500

ActiveMQ中队列没有堆积的情况下,持久化的kahadb的数据量一直在增长

我的理解是当队列处于空闲状态原本因为数据量过大持久化到db-log的数据不是应该写回队列 中了吗,现在的情况是队列的生产者端并没有产生数据堆积,但是kahadb中的数据却一直在增 长,应该怎么解决。

spring+activemq 发布订阅模式,短期运行正常后监听消失

activeMQ发布/订阅模式下,消费者端通过异步消息监听器(messagelistener)实现消息订阅,同样的消费者端应用被部署到两台linux服务器上,正常监听一段时间后,经过没有消息发送阶段后,等到消息生产者再次开始发布消息时,其中一台服务器上的消费者端应用没有监听线程了,请问这是啥原因?请大神们赐教!!配置了失效重连机制

activemq使用kahadb持久化搭建分布式集群后发下消息处理速度明显不如单台机器的性能,为什么会下降呢

最近在linux下测试ActiveMQ5.11 ,使用两台电脑进行分布式布控,测试处理消息性能时,发现对消息的处理速度远不如一台机器工作处理速度,搭建分布式集群后哪里会影响其速度吗?

ActiveMQ发布订阅问题?

1、使用ActiveMQ开发,如果发布者每1秒发布一条数据,有些订阅者每4秒读取一条,怎么才能让订阅者跳过缓存,读取到最新数据。 ``` //发布者测试代码 public class MessageProducer { //定义ActivMQ的连接地址 private static final String ACTIVEMQ_URL = "tcp://localhost:61616"; public static void main(String[] args) throws JMSException { //创建连接工厂 ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory( ACTIVEMQ_URL); //创建连接 Connection connection = activeMQConnectionFactory.createConnection(); //打开连接 connection.start(); //创建会话 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //创建队列目标 //Destination destination = session.createQueue(QUEUE_NAME); Topic test = session.createTopic("572890"); //创建一个生产者 javax.jms.MessageProducer producer = session.createProducer(test); //创建模拟100个消息 int num = 0; long sTime = System.currentTimeMillis(); TextMessage message = null; while (true) { num++; message = session.createTextMessage(num+""); //发送消息 producer.send(message); try { System.out.println(num); Thread.sleep(1000); } catch (Exception e) { } if (num > 100) { break; } } long eTime = System.currentTimeMillis(); System.out.println("总计用时:" + (eTime - sTime)); //关闭连接 connection.close(); } } //订阅者测试代码 public class MessageConsumer { //定义ActivMQ的连接地址 private static final String ACTIVEMQ_URL = "tcp://localhost:61616"; //定义发送消息的队列名称 private static final String QUEUE_NAME = "PP_ERROR"; static int num = 0; public static void main(String[] args) throws JMSException { //创建连接工厂 ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL); //创建连接 Connection connection = activeMQConnectionFactory.createConnection(); //打开连接 connection.start(); //创建会话 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //创建队列目标 //Destination destination = session.createQueue(QUEUE_NAME); Topic test = session.createTopic("572890"); //创建消费者 javax.jms.MessageConsumer consumer = session.createConsumer(test); //创建消费的监听 consumer.setMessageListener(new MessageListener() { @Override public void onMessage(Message message) { num ++; TextMessage textMessage = (TextMessage) message; try { System.out.println(textMessage.getText()); Thread.sleep(4000); } catch (Exception e) { e.printStackTrace(); } } }); } } ```

activemq中的topic队列在删除队列后消费者依然能够接收到请求

我在jmeter中对一个http接口进行了一百次请求![图片说明](https://img-ask.csdn.net/upload/202001/09/1578569643_727542.png) ![图片说明](https://img-ask.csdn.net/upload/202001/09/1578570841_912688.png) 接口如下: ``` java @GetMapping("send") public void send(String msg) { // 指定消息发送的目的地及内容 System.out.println(new Date().toString()); queueMessageService.setTopic("topic",msg); } ``` 调用的Bean ``` java @Component public class QueueMessageService { @Autowired private JmsMessagingTemplate jmsMessagingTemplate; public void setQueue(String queue,String msg){ jmsMessagingTemplate.convertAndSend(new ActiveMQQueue(queue),msg); } public void setTopic(String topic,String msg) { jmsMessagingTemplate.convertAndSend(new ActiveMQTopic(topic),msg); } } ``` 我使用了两个消费者用于接收请求 ```java @JmsListener(destination = "topic") public void receiveMessage(String message) throws InterruptedException { Thread.sleep(4000); System.out.println(hfnsTermService.getCount()); System.out.println(new Date().toString()+"topic接收:"+message); } @JmsListener(destination = "topic") public void readResponse(String message) throws InterruptedException { Thread.sleep(1000); for(HfnsTerm hfnsTerm:hfnsTermService.getHfnsTerm()){ System.out.println(hfnsTerm.getId()); } System.out.println(new Date().toString()+"topic1接收:"+message); } ``` ![图片说明](https://img-ask.csdn.net/upload/202001/09/1578570403_712572.png) ![图片说明](https://img-ask.csdn.net/upload/202001/09/1578570672_991950.png) 当我在请求还没完全接收完时在activemq控制台把topic队列进行了删除操作 ![图片说明](https://img-ask.csdn.net/upload/202001/09/1578570549_153369.png) 此时activemq中是没有topic队列的,但是我依然能够接收到topic队列中的消息 ![图片说明](https://img-ask.csdn.net/upload/202001/09/1578570782_702718.png) 请问这是为什么?

activemq使用kahadb持久化搭建分布式集群后发下消息处理速度明显不如一台机器的性能

最近在linux下测试ActiveMQ5.11 ,使用两台电脑进行分布式布控,测试处理消息性能时,发现对消息的处理速度远不如一台机器工作处理速度,搭建分布式集群后哪里会影响其速度吗?

如何激活ActiveMQ持久性以抵抗重启?

<div class="post-text" itemprop="text"> <p>I do get ActiveMQ supports data persistence (<a href="http://activemq.apache.org/persistence.html" rel="nofollow noreferrer">http://activemq.apache.org/persistence.html</a>), but i cannot understand how to make it work, the result is when i restart ActiveMQ all the messages disappear, while queues and topics remain. </p> <p>I've read about to enable persistence on a database but i want to keep data on the filesystem since my system is facing database perfomance issues.</p> <p>This is my activemq.xml</p> <pre><code>&lt;!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. --&gt; &lt;!-- START SNIPPET: example --&gt; &lt;beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"&gt; &lt;!-- Allows us to use system properties as variables in this configuration file --&gt; &lt;bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"&gt; &lt;property name="locations"&gt; &lt;value&gt;file:${activemq.conf}/credentials.properties&lt;/value&gt; &lt;/property&gt; &lt;/bean&gt; &lt;!-- Allows accessing the server log --&gt; &lt;bean id="logQuery" class="io.fabric8.insight.log.log4j.Log4jLogQuery" lazy-init="false" scope="singleton" init-method="start" destroy-method="stop"&gt; &lt;/bean&gt; &lt;!-- The &lt;broker&gt; element is used to configure the ActiveMQ broker. --&gt; &lt;broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}"&gt; &lt;destinationPolicy&gt; &lt;policyMap&gt; &lt;policyEntries&gt; &lt;policyEntry topic="&gt;" &gt; &lt;!-- The constantPendingMessageLimitStrategy is used to prevent slow topic consumers to block producers and affect other consumers by limiting the number of messages that are retained For more information, see: http://activemq.apache.org/slow-consumer-handling.html --&gt; &lt;pendingMessageLimitStrategy&gt; &lt;constantPendingMessageLimitStrategy limit="1000"/&gt; &lt;/pendingMessageLimitStrategy&gt; &lt;/policyEntry&gt; &lt;/policyEntries&gt; &lt;/policyMap&gt; &lt;/destinationPolicy&gt; &lt;!-- The managementContext is used to configure how ActiveMQ is exposed in JMX. By default, ActiveMQ uses the MBean server that is started by the JVM. For more information, see: http://activemq.apache.org/jmx.html --&gt; &lt;managementContext&gt; &lt;managementContext createConnector="false"/&gt; &lt;/managementContext&gt; &lt;!-- Configure message persistence for the broker. The default persistence mechanism is the KahaDB store (identified by the kahaDB tag). For more information, see: http://activemq.apache.org/persistence.html --&gt; &lt;persistenceAdapter&gt; &lt;kahaDB directory="${activemq.data}/kahadb"/&gt; &lt;/persistenceAdapter&gt; &lt;!-- The systemUsage controls the maximum amount of space the broker will use before disabling caching and/or slowing down producers. For more information, see: http://activemq.apache.org/producer-flow-control.html --&gt; &lt;systemUsage&gt; &lt;systemUsage&gt; &lt;memoryUsage&gt; &lt;memoryUsage percentOfJvmHeap="70" /&gt; &lt;/memoryUsage&gt; &lt;storeUsage&gt; &lt;storeUsage limit="100 gb"/&gt; &lt;/storeUsage&gt; &lt;tempUsage&gt; &lt;tempUsage limit="50 gb"/&gt; &lt;/tempUsage&gt; &lt;/systemUsage&gt; &lt;/systemUsage&gt; &lt;!-- The transport connectors expose ActiveMQ over a given protocol to clients and other brokers. For more information, see: http://activemq.apache.org/configuring-transports.html --&gt; &lt;transportConnectors&gt; &lt;!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --&gt; &lt;transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;amp;wireFormat.maxFrameSize=104857600"/&gt; &lt;transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;amp;wireFormat.maxFrameSize=104857600"/&gt; &lt;transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;amp;wireFormat.maxFrameSize=104857600"/&gt; &lt;transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;amp;wireFormat.maxFrameSize=104857600"/&gt; &lt;transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;amp;wireFormat.maxFrameSize=104857600"/&gt; &lt;/transportConnectors&gt; &lt;!-- destroy the spring context on shutdown to stop jetty --&gt; &lt;shutdownHooks&gt; &lt;bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /&gt; &lt;/shutdownHooks&gt; &lt;/broker&gt; &lt;!-- Enable web consoles, REST and Ajax APIs and demos The web consoles requires by default login, you can disable this in the jetty.xml file Take a look at ${ACTIVEMQ_HOME}/conf/jetty.xml for more details --&gt; &lt;import resource="jetty.xml"/&gt; </code></pre> <p> </p> </div>

ACTIVEMQ Topic消息 生产者 发布消息后 消费者收不到消息

<p> </p> <pre name="code" class="java">生产者 public class Producer { public static void main(String[] args) throws JMSException { ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); ActiveMQTopic topic= new ActiveMQTopic("testTopic"); MessageProducer producer = session.createProducer(topic); producer.setDeliveryMode(DeliveryMode.PERSISTENT); for(int i=0; i&lt;10; i++){ TextMessage message = session.createTextMessage(); message.setText("message_" + System.currentTimeMillis()); producer.send(message); System.out.println("Sent message: " + message.getText()); } // session.close(); // connection.stop(); // connection.close(); } } 发布消息的结果 Sent message: message_1341915173083 Sent message: message_1341915173085 Sent message: message_1341915173085 Sent message: message_1341915173086 Sent message: message_1341915173086 Sent message: message_1341915173086 Sent message: message_1341915173087 Sent message: message_1341915173087 Sent message: message_1341915173088 Sent message: message_1341915173088 消费者 public class Consumer { public static void main(String[] args) throws JMSException { ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); ActiveMQTopic topic= new ActiveMQTopic("testTopic"); // javax.jms.Topic topic = session.createTopic("myTopic.messages"); MessageConsumer consumer = session.createConsumer( topic); consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { TextMessage tm = (TextMessage) message; try { System.out.println("Received message: " + tm.getText()); } catch (JMSException e) { e.printStackTrace(); } } }); MessageConsumer comsumer2 = session.createConsumer(topic); comsumer2.setMessageListener(new MessageListener(){ public void onMessage(Message message) { TextMessage tm = (TextMessage) message; try { System.out.println("Received message: " + tm.getText()); } catch (JMSException e) { e.printStackTrace(); } } }); // session.close(); // connection.stop(); // connection.close(); } } <span>消费者运行程序后后获取不到生产者发布的消息,初识 ActiveMQ不太熟悉, 求解答</span></pre>   <p> </p>

初级玩转Linux+Ubuntu(嵌入式开发基础课程)

课程主要面向嵌入式Linux初学者、工程师、学生 主要从一下几方面进行讲解: 1.linux学习路线、基本命令、高级命令 2.shell、vi及vim入门讲解 3.软件安装下载、NFS、Samba、FTP等服务器配置及使用

我以为我对Mysql事务很熟,直到我遇到了阿里面试官

太惨了,面试又被吊打

Python代码实现飞机大战

文章目录经典飞机大战一.游戏设定二.我方飞机三.敌方飞机四.发射子弹五.发放补给包六.主模块 经典飞机大战 源代码以及素材资料(图片,音频)可从下面的github中下载: 飞机大战源代码以及素材资料github项目地址链接 ————————————————————————————————————————————————————————— 不知道大家有没有打过飞机,喜不喜欢打飞机。当我第一次接触这个东西的时候,我的内心是被震撼到的。第一次接触打飞机的时候作者本人是身心愉悦的,因为周边的朋友都在打飞机, 每

Python数据分析与挖掘

92讲视频课+16大项目实战+源码+¥800元课程礼包+讲师社群1V1答疑+社群闭门分享会=99元 &nbsp; 为什么学习数据分析? &nbsp; &nbsp; &nbsp; 人工智能、大数据时代有什么技能是可以运用在各种行业的?数据分析就是。 &nbsp; &nbsp; &nbsp; 从海量数据中获得别人看不见的信息,创业者可以通过数据分析来优化产品,营销人员可以通过数据分析改进营销策略,产品经理可以通过数据分析洞察用户习惯,金融从业者可以通过数据分析规避投资风险,程序员可以通过数据分析进一步挖掘出数据价值,它和编程一样,本质上也是一个工具,通过数据来对现实事物进行分析和识别的能力。不管你从事什么行业,掌握了数据分析能力,往往在其岗位上更有竞争力。 &nbsp;&nbsp; 本课程共包含五大模块: 一、先导篇: 通过分析数据分析师的一天,让学员了解全面了解成为一个数据分析师的所有必修功法,对数据分析师不在迷惑。 &nbsp; 二、基础篇: 围绕Python基础语法介绍、数据预处理、数据可视化以及数据分析与挖掘......这些核心技能模块展开,帮助你快速而全面的掌握和了解成为一个数据分析师的所有必修功法。 &nbsp; 三、数据采集篇: 通过网络爬虫实战解决数据分析的必经之路:数据从何来的问题,讲解常见的爬虫套路并利用三大实战帮助学员扎实数据采集能力,避免没有数据可分析的尴尬。 &nbsp; 四、分析工具篇: 讲解数据分析避不开的科学计算库Numpy、数据分析工具Pandas及常见可视化工具Matplotlib。 &nbsp; 五、算法篇: 算法是数据分析的精华,课程精选10大算法,包括分类、聚类、预测3大类型,每个算法都从原理和案例两个角度学习,让你不仅能用起来,了解原理,还能知道为什么这么做。

如何在虚拟机VM上使用串口

在系统内核开发中,经常会用到串口调试,利用VMware的Virtual Machine更是为调试系统内核如虎添翼。那么怎么搭建串口调试环境呢?因为最近工作涉及到这方面,利用强大的google搜索和自己

程序员的兼职技能课

获取讲师答疑方式: 在付费视频第一节(触摸命令_ALL)片头有二维码及加群流程介绍 限时福利 原价99元,今日仅需39元!购课添加小助手(微信号:csdn590)按提示还可领取价值800元的编程大礼包! 讲师介绍: 苏奕嘉&nbsp;前阿里UC项目工程师 脚本开发平台官方认证满级(六级)开发者。 我将如何教会你通过【定制脚本】赚到你人生的第一桶金? 零基础程序定制脚本开发课程,是完全针对零脚本开发经验的小白而设计,课程内容共分为3大阶段: ①前期将带你掌握Q开发语言和界面交互开发能力; ②中期通过实战来制作有具体需求的定制脚本; ③后期将解锁脚本的更高阶玩法,打通任督二脉; ④应用定制脚本合法赚取额外收入的完整经验分享,带你通过程序定制脚本开发这项副业,赚取到你的第一桶金!

MFC一站式终极全套课程包

该套餐共包含从C小白到C++到MFC的全部课程,整套学下来绝对成为一名C++大牛!!!

C++语言基础视频教程

C++语言基础视频培训课程:本课与主讲者在大学开出的程序设计课程直接对接,准确把握知识点,注重教学视频与实践体系的结合,帮助初学者有效学习。本教程详细介绍C++语言中的封装、数据隐藏、继承、多态的实现等入门知识;主要包括类的声明、对象定义、构造函数和析构函数、运算符重载、继承和派生、多态性实现等。 课程需要有C语言程序设计的基础(可以利用本人开出的《C语言与程序设计》系列课学习)。学习者能够通过实践的方式,学会利用C++语言解决问题,具备进一步学习利用C++开发应用程序的基础。

北京师范大学信息科学与技术学院笔试10复试真题

北京师范大学信息科学与技术学院笔试,可以更好的让你了解北师大该学院的复试内容,获得更好的成绩。

深度学习原理+项目实战+算法详解+主流框架(套餐)

深度学习系列课程从深度学习基础知识点开始讲解一步步进入神经网络的世界再到卷积和递归神经网络,详解各大经典网络架构。实战部分选择当下最火爆深度学习框架PyTorch与Tensorflow/Keras,全程实战演示框架核心使用与建模方法。项目实战部分选择计算机视觉与自然语言处理领域经典项目,从零开始详解算法原理,debug模式逐行代码解读。适合准备就业和转行的同学们加入学习! 建议按照下列课程顺序来进行学习 (1)掌握深度学习必备经典网络架构 (2)深度框架实战方法 (3)计算机视觉与自然语言处理项目实战。(按照课程排列顺序即可)

网络工程师小白入门--【思科CCNA、华为HCNA等网络工程师认证】

本课程适合CCNA或HCNA网络小白同志,高手请绕道,可以直接学习进价课程。通过本预科课程的学习,为学习网络工程师、思科CCNA、华为HCNA这些认证打下坚实的基础! 重要!思科认证2020年2月24日起,已启用新版认证和考试,包括题库都会更新,由于疫情原因,请关注官网和本地考点信息。题库网络上很容易下载到。

Python界面版学生管理系统

前不久上传了一个控制台版本的学生管理系统,这个是Python界面版学生管理系统,这个是使用pycharm开发的一个有界面的学生管理系统,基本的增删改查,里面又演示视频和完整代码,有需要的伙伴可以自行下

软件测试2小时入门

本课程内容系统、全面、简洁、通俗易懂,通过2个多小时的介绍,让大家对软件测试有个系统的理解和认识,具备基本的软件测试理论基础。 主要内容分为5个部分: 1 软件测试概述,了解测试是什么、测试的对象、原则、流程、方法、模型;&nbsp; 2.常用的黑盒测试用例设计方法及示例演示;&nbsp; 3 常用白盒测试用例设计方法及示例演示;&nbsp; 4.自动化测试优缺点、使用范围及示例‘;&nbsp; 5.测试经验谈。

Tomcat服务器下载、安装、配置环境变量教程(超详细)

未经我的允许,请不要转载我的文章,在此郑重声明!!! 请先配置安装好Java的环境,若没有安装,请参照我博客上的步骤进行安装! 安装Java环境教程https://blog.csdn.net/qq_40881680/article/details/83585542 Tomcat部署Web项目(一)·内嵌https://blog.csdn.net/qq_40881680/article/d...

2019数学建模A题高压油管的压力控制 省一论文即代码

2019数学建模A题高压油管的压力控制省一完整论文即详细C++和Matlab代码,希望对同学们有所帮助

图书管理系统(Java + Mysql)我的第一个完全自己做的实训项目

图书管理系统 Java + MySQL 完整实训代码,MVC三层架构组织,包含所有用到的图片资源以及数据库文件,大三上学期实训,注释很详细,按照阿里巴巴Java编程规范编写

linux下利用/proc进行进程树的打印

在linux下利用c语言实现的进程树的打印,主要通过/proc下的目录中的进程文件,获取status中的进程信息内容,然后利用递归实现进程树的打印

微信小程序开发实战之番茄时钟开发

微信小程序番茄时钟视频教程,本课程将带着各位学员开发一个小程序初级实战类项目,针对只看过官方文档而又无从下手的开发者来说,可以作为一个较好的练手项目,对于有小程序开发经验的开发者而言,可以更好加深对小程序各类组件和API 的理解,为更深层次高难度的项目做铺垫。

[已解决]踩过的坑之mysql连接报“Communications link failure”错误

目录 前言 第一种方法: 第二种方法 第三种方法(适用于项目和数据库在同一台服务器) 第四种方法 第五种方法(项目和数据库不在同一台服务器) 总结 前言 先给大家简述一下我的坑吧,(我用的是mysql,至于oracle有没有这样的问题,有心的小伙伴们可以测试一下哈), 在自己做个javaweb测试项目的时候,因为买的是云服务器,所以数据库连接的是用ip地址,用IDE开发好...

人工智能-计算机视觉实战之路(必备算法+深度学习+项目实战)

系列课程主要分为3大阶段:(1)首先掌握计算机视觉必备算法原理,结合Opencv进行学习与练手,通过实际视项目进行案例应用展示。(2)进军当下最火的深度学习进行视觉任务实战,掌握深度学习中必备算法原理与网络模型架构。(3)结合经典深度学习框架与实战项目进行实战,基于真实数据集展开业务分析与建模实战。整体风格通俗易懂,项目驱动学习与就业面试。 建议同学们按照下列顺序来进行学习:1.Python入门视频课程 2.Opencv计算机视觉实战(Python版) 3.深度学习框架-PyTorch实战/人工智能框架实战精讲:Keras项目 4.Python-深度学习-物体检测实战 5.后续实战课程按照自己喜好选择就可以

2019 AI开发者大会

2019 AI开发者大会(AI ProCon 2019)是由中国IT社区CSDN主办的AI技术与产业年度盛会。多年经验淬炼,如今蓄势待发:2019年9月6-7日,大会将有近百位中美顶尖AI专家、知名企业代表以及千余名AI开发者齐聚北京,进行技术解读和产业论证。我们不空谈口号,只谈技术,诚挚邀请AI业内人士一起共铸人工智能新篇章!

机器学习初学者必会的案例精讲

通过六个实际的编码项目,带领同学入门人工智能。这些项目涉及机器学习(回归,分类,聚类),深度学习(神经网络),底层数学算法,Weka数据挖掘,利用Git开源项目实战等。

Python数据分析师-实战系列

系列课程主要包括Python数据分析必备工具包,数据分析案例实战,核心算法实战与企业级数据分析与建模解决方案实战,建议大家按照系列课程阶段顺序进行学习。所有数据集均为企业收集的真实数据集,整体风格以实战为导向,通俗讲解Python数据分析核心技巧与实战解决方案。

YOLOv3目标检测实战系列课程

《YOLOv3目标检测实战系列课程》旨在帮助大家掌握YOLOv3目标检测的训练、原理、源码与网络模型改进方法。 本课程的YOLOv3使用原作darknet(c语言编写),在Ubuntu系统上做项目演示。 本系列课程包括三门课: (1)《YOLOv3目标检测实战:训练自己的数据集》 包括:安装darknet、给自己的数据集打标签、整理自己的数据集、修改配置文件、训练自己的数据集、测试训练出的网络模型、性能统计(mAP计算和画出PR曲线)和先验框聚类。 (2)《YOLOv3目标检测:原理与源码解析》讲解YOLOv1、YOLOv2、YOLOv3的原理、程序流程并解析各层的源码。 (3)《YOLOv3目标检测:网络模型改进方法》讲解YOLOv3的改进方法,包括改进1:不显示指定类别目标的方法 (增加功能) ;改进2:合并BN层到卷积层 (加快推理速度) ; 改进3:使用GIoU指标和损失函数 (提高检测精度) ;改进4:tiny YOLOv3 (简化网络模型)并介绍 AlexeyAB/darknet项目。

2021考研数学张宇基础30讲.pdf

张宇:博士,全国著名考研数学辅导专家,教育部“国家精品课程建设骨干教师”,全国畅销书《张宇高等数学18讲》《张宇线性代数9讲》《张宇概率论与数理统计9讲》《张宇考研数学题源探析经典1000题》《张宇考

三个项目玩转深度学习(附1G源码)

从事大数据与人工智能开发与实践约十年,钱老师亲自见证了大数据行业的发展与人工智能的从冷到热。事实证明,计算机技术的发展,算力突破,海量数据,机器人技术等,开启了第四次工业革命的序章。深度学习图像分类一直是人工智能的经典任务,是智慧零售、安防、无人驾驶等机器视觉应用领域的核心技术之一,掌握图像分类技术是机器视觉学习的重中之重。针对现有线上学习的特点与实际需求,我们开发了人工智能案例实战系列课程。打造:以项目案例实践为驱动的课程学习方式,覆盖了智能零售,智慧交通等常见领域,通过基础学习、项目案例实践、社群答疑,三维立体的方式,打造最好的学习效果。

DirectX修复工具V4.0增强版

DirectX修复工具(DirectX Repair)是一款系统级工具软件,简便易用。本程序为绿色版,无需安装,可直接运行。 本程序的主要功能是检测当前系统的DirectX状态,如果发现异常则进行修复

期末考试评分标准的数学模型

大学期末考试与高中的考试存在很大的不同之处,大学的期末考试成绩是主要分为两个部分:平时成绩和期末考试成绩。平时成绩和期末考试成绩总分一般为一百分,然而平时成绩与期末考试成绩所占的比例不同会导致出现不同

Vue.js 2.0之全家桶系列视频课程

基于新的Vue.js 2.3版本, 目前新全的Vue.js教学视频,让你少走弯路,直达技术前沿! 1. 包含Vue.js全家桶(vue.js、vue-router、axios、vuex、vue-cli、webpack、ElementUI等) 2. 采用笔记+代码案例的形式讲解,通俗易懂

c语言项目开发实例

十个c语言案例 (1)贪吃蛇 (2)五子棋游戏 (3)电话薄管理系统 (4)计算器 (5)万年历 (6)电子表 (7)客户端和服务器通信 (8)潜艇大战游戏 (9)鼠标器程序 (10)手机通讯录系统

董付国老师Python全栈学习优惠套餐

购买套餐的朋友可以关注微信公众号“Python小屋”,上传付款截图,然后领取董老师任意图书1本。

相关热词 c# dbml文件 修改 c#遍历tree c# 能够控制单片机 c#对象写入数据库 c# 添加activex c#2005 json c# 数据库在云端 c# 字符串移位加密 c#禁用滚轮 c#实体类list去重复
立即提问