GVKun编程网logo

javascript – 如何在Meteor中使用ActiveMQ？

13

在这篇文章中，我们将为您详细介绍javascript–如何在Meteor中使用ActiveMQ？的内容。此外，我们还会涉及一些关于ActiveMQ学习之java代码调用ActiveMQ队列、JavaS

在这篇文章中，我们将为您详细介绍javascript – 如何在Meteor中使用ActiveMQ？的内容。此外，我们还会涉及一些关于ActiveMQ学习之java代码调用ActiveMQ队列、JavaScript setTimeout和setInterval的使用方法 说明_javascript技巧、javascript – meteor在Mac上安装在哪里？、javascript – Meteor定时器中的Meteor.setTimeout()问题？的知识，以帮助您更全面地了解这个主题。

本文目录一览：

javascript – 如何在Meteor中使用ActiveMQ？

javascript – 如何在Meteor中使用ActiveMQ？

我正在构建一个Meteor应用程序,需要接收JMS或AMQP消息,处理它们,并将结果存储在Meteor的MongoDB中.我希望这一切都发生在服务器上,而不是客户端上.

我阅读了ActiveMQ AJAX page,这似乎是一个很有前途的领导,但我不知道如何让它工作.我希望在我的项目的服务器文件夹中创建一个新的.js文件并将所有代码放在那里,但是创建ActiveMQ AJAX servlet并导入ActiveMQ javascript文件似乎需要HTML标记.此外,是否需要运行AciveMQ才能使servlet正常工作？

我是网络开发的新手.

解决方法

你应该看看node-amqp( https://www.npmjs.com/package/amqp).它应该很好地融入流星项目,并为您提供您正在寻找的功能.一旦安装并需要它,您就应该能够连接到消息服务器,创建队列,接收消息到队列中,然后由您自己处理它们并将它们存储到您的mongo中.

ActiveMQ学习之java代码调用ActiveMQ队列

ActiveMQ学习之java代码调用ActiveMQ队列

一、基本概念：

        ActiveMQ中共分为两种：queue和topic

                

            queue：在点对点消息传递域中，目的地被称为队列（一对一）

            topic：在发布订阅消息中，目的地被称为主题（一对多）

二、创建maven工程，并引入依赖，这里我创建的springboot项目，所以引入的依赖如下：

           依赖：            

    <!--activemq-->
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-all</artifactId>
      <version>5.15.9</version>
    </dependency>

            创建main方法测试连接，消息提供者。


import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * @ProjectName: springbootActiveMQ
 * @Package: cn.**.test
 * @Author: huat
 * @Date: 2020/1/2 17:04
 * @Version: 1.0
 */
public class ActiveMQTest {
    //url路径
    private static final String ACTRIVE_URL="tcp://192.168.44.135:61616";
    //队列名称
    private static final String QUEUE_NAME="queue01";
  

    public static void main(String[] args) {
        //1、创建连接工厂
        //如果账号密码没有修改的话，账号密码默认均为admin
        ActiveMQConnectionFactory activeMQConnectionFactory=new ActiveMQConnectionFactory(ACTRIVE_URL);
        //如果账号密码修改的话
        //第一个参数为账号，第二个为密码，第三个为请求的url
        //ActiveMQConnectionFactory activeMQConnectionFactory1=new ActiveMQConnectionFactory("admin","admin",ACTRIVE_URL);
        try {
            //2、通过连接工厂获取连接
            Connection connection = activeMQConnectionFactory.createConnection();
            connection.start();
            //3、创建session会话
            //里面会有两个参数，第一个为事物，第二个是签收
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //4、创建目的地（具体是队列还是主题）,这里是创建队列
            Queue queue=session.createQueue(QUEUE_NAME);
           
            //5、创建消息生产者
            MessageProducer messageProducer = session.createProducer(queue);
            //6、通过messageProducer生产三条消息发送到MQ消息队列中
            for (int i=0;i<3;i++){
                //7、创建消息
                TextMessage textMessage = session.createTextMessage("msg----->" + i);//创建一个文本消息
                //8、通过messageProducer发送给mq
                messageProducer.send(textMessage);
            }
            messageProducer.close();
            session.close();
            connection.close();
            System.out.println("消息发送成功");
        } catch (JMSException e) {
            e.printStackTrace();
        }

    }
}

            查看管理页面是否有消息

            创建main方法测试连接，消息消费者。（同步调用）


import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * @ProjectName: springbootActiveMQ
 * @Package: cn.**.test
 * @Author: huat
 * @Date: 2020/1/3 8:47
 * @Version: 1.0
 */
public class ActiveMQConsumer {
    //url路径
    private static final String ACTRIVE_URL="tcp://192.168.44.135:61616";
    //队列名称
    private static final String QUEUE_NAME="queue01";

    public static void main(String[] args) {
        //1、创建连接工厂
        //如果账号密码没有修改的话，账号密码默认均为admin
        ActiveMQConnectionFactory activeMQConnectionFactory=new ActiveMQConnectionFactory(ACTRIVE_URL);
        //如果账号密码修改的话
        //第一个参数为账号，第二个为密码，第三个为请求的url
        //ActiveMQConnectionFactory activeMQConnectionFactory1=new ActiveMQConnectionFactory("admin","admin",ACTRIVE_URL);
        try {
            //2、通过连接工厂获取连接
            Connection connection = activeMQConnectionFactory.createConnection();
            connection.start();
            //3、创建session会话
            //里面会有两个参数，第一个为事物，第二个是签收
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //4、这里接受的queue的名称要和发送者的一致
            Queue queue = session.createQueue(QUEUE_NAME);
            //5、创建消费者
            MessageConsumer consumer = session.createConsumer(queue);
            //6、获取消息
            while(true){
                //MessageConsumer 调用的receive方法为同步调用，在消息到达之前一直阻塞线程
                //用什么格式发送，这里就用什么格式接受
                //receive等待消息，不限制时间
                    TextMessage message=(TextMessage)consumer.receive();
                //receive带参数等待消息，限制时间，单位毫秒
                //TextMessage message=(TextMessage)consumer.receive(4000L);

                if(null != message){
                    System.out.println("接受的消息为------>"+message.getText());
                }else{
                    break;
                }
            }
            //7、闭资源
            consumer.close();
            session.close();
            connection.close();
        }catch (Exception e){
            e.printStackTrace();
        }
    }

}

            创建main方法测试连接，消息消费者。（异步调用）



import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * @ProjectName: springbootActiveMQ
 * @Package: cn.**.test
 * @Author: huat
 * @Date: 2020/1/3 8:47
 * @Version: 1.0
 */
public class ActiveMQConsumer {
    //url路径
    private static final String ACTRIVE_URL="tcp://192.168.44.135:61616";
    //队列名称
    private static final String QUEUE_NAME="queue01";

    public static void main(String[] args) {
        //1、创建连接工厂
        //如果账号密码没有修改的话，账号密码默认均为admin
        ActiveMQConnectionFactory activeMQConnectionFactory=new ActiveMQConnectionFactory(ACTRIVE_URL);
        //如果账号密码修改的话
        //第一个参数为账号，第二个为密码，第三个为请求的url
        //ActiveMQConnectionFactory activeMQConnectionFactory1=new ActiveMQConnectionFactory("admin","admin",ACTRIVE_URL);
        try {
            //2、通过连接工厂获取连接
            Connection connection = activeMQConnectionFactory.createConnection();
            connection.start();
            //3、创建session会话
            //里面会有两个参数，第一个为事物，第二个是签收
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //4、这里接受的queue的名称要和发送者的一致
            Queue queue = session.createQueue(QUEUE_NAME);
            //5、创建消费者
            MessageConsumer consumer = session.createConsumer(queue);
            //6、通过监听的方式消费消息
            consumer.setMessageListener(new MessageListener() {
                @Override
                public void onMessage(Message message) {
                    //如果message不等于null并且属于TextMessage类型（因为消息发送的类型是TextMessage，所以这里判断是否是这个类型）
                    if(null!=message&&message instanceof TextMessage){
                        TextMessage textMessage=(TextMessage)message;
                        try {
                            System.out.println(textMessage.getText());
                        } catch (JMSException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });
            //7、保证控制台一直在运行
            System.in.read();
            //8、闭资源
            consumer.close();
            session.close();
            connection.close();
        }catch (Exception e){
            e.printStackTrace();
        }
    }

}

三、具体分析

            情况一：先启动生产者，再启动一号消费者，一号消费者可以消费全部消息

            情况二：先启动生产者，先启动一号消费者再启动二号消费者，一号消费者可以消费全部消息，二号消费者无消费

            情况三：先启动一号和二号两个消费者，再启动生产者，一号和二号消费者平均分配消息。

JavaScript setTimeout和setInterval的使用方法 说明_javascript技巧

JavaScript setTimeout和setInterval的使用方法 说明_javascript技巧

不同的是setInterval会每隔指定的时间段就执行一次代码，具有重复性。而setTimeout只会调用后执行一次。
下面通过函数的建立和函的自动删除来深刻理解两个函数；
1.函数的建立
setTimeOut的建立：

复制代码 代码如下:

showTime();
function showTime()
{
var today = new Date();
alert("The time is: " + today.toString());
setTimeout("showTime()", 5000);
}

调用函数后五秒钟才会执行一次showtime函数
setInterval的建立
复制代码 代码如下:

setInterval("showTime()", 5000);
function showTime()
{
var today = new Date();
alert("The time is: " + today.toString());
}

总结：貌似两个函数的结果相似，其实不然第二个函数会反复的报时，直到该网页被关闭。
两个函数的消除：
setTimeout的消除使用
clearTimeout（）函数；调用的实例：
复制代码 代码如下:

var timeoutProcess = setTimeout("alert(''GOAL!'')", 3000);
var stopGoalLink = document.getElementById("stopGoalLink");
attachEventListener(stopGoalLink, "click", stopGoal, false);//加入事件函数，参数为（目标；事件；调用的函数；是否冒泡）
function stopGoal()
{
clearTimeout(timeoutProcess);
}

setInterval的消除
复制代码 代码如下:

var timeoutProcess = setTimeout("alert(''GOAL!'')", 3000);
var stopGoalLink = document.getElementById("stopGoalLink");
attachEventListener(stopGoalLink, "click", stopGoal, false);//加入事件函数，参数为（目标；事件；调用的函数；是否冒泡）
function stopGoal()
{
clearInterval(timeoutProcess);
}

javascript – meteor在Mac上安装在哪里？

javascript – meteor在Mac上安装在哪里？

我安装了meteor并在tut之后创建了一个应用程序
http://docs.meteor.com/#quickstart

在查找器中,我搜索了流星但我找不到它.

解决方法

/usr/local / meteor – 您可以在 http://install.meteor.com/的安装脚本中找到它

javascript – Meteor定时器中的Meteor.setTimeout()问题？

javascript – Meteor定时器中的Meteor.setTimeout()问题？

我使用Meteor在Meteor.setTimeout()上做了一个示例.在这个例子中我得到一个错误.我对此没有任何想法.所以请看下面的代码,错误并建议我怎么办？

错误：

Exception in setTimeout callback: TypeError: undefined is not a function
    at _.extend.withValue (http://localhost:3000/packages/meteor.js?8ec262df25783897eaad01255bc8bd1ca4e78b24:773:17)
    at http://localhost:3000/packages/meteor.js?8ec262df25783897eaad01255bc8bd1ca4e78b24:358:45
    at http://localhost:3000/packages/meteor.js?8ec262df25783897eaad01255bc8bd1ca4e78b24:801:22

JS代码：

if (Meteor.isClient) 
{
  Meteor.setTimeout(Test("10"),1000);
  Meteor.setInterval(Test1,1000);

  Template.hello.greeting = function () 
  {
    return "Welcome to timerapp.";
  };

  Template.hello.events
  ({
    'click input' : function () 
    {
      // template data,if any,is available in 'this'
      if (typeof console !== 'undefined')
        console.log("You pressed the button");

        //test();
    }
  });
}
function Test(x)
{
   console.log("*** test() ***"+x);
}
function Test1()
{
   console.log("*** Test1() ***");
}
if (Meteor.isServer)
 {

  Meteor.startup(function ()
  {
    // code to run on server at startup
  });


}

解决方法

问题是setTimeout需要一个函数作为第一个参数,但是你传递的是评估Test(“10”)的结果,它是“未定义的”.

您可以通过在匿名函数中包含对Test1的调用来解决此问题：

Meteor.setTimeout(function(){Test("10");},1000);

我们今天的关于javascript – 如何在Meteor中使用ActiveMQ？的分享已经告一段落，感谢您的关注，如果您想了解更多关于ActiveMQ学习之java代码调用ActiveMQ队列、JavaScript setTimeout和setInterval的使用方法 说明_javascript技巧、javascript – meteor在Mac上安装在哪里？、javascript – Meteor定时器中的Meteor.setTimeout()问题？的相关信息，请在本站查询。

本文标签：

上一篇javascript – 验证google reCaptcha失败（谷歌验证器错误）

下一篇javascript – 有没有正确的方法来存储已解决的承诺？（js的存储方式）

相关文章