wns9778.com_威尼斯wns.9778官网

热门关键词: wns9778.com,威尼斯wns.9778官网
wns9778.com > 计算机教程 > wns9778.compython使用stomp连接activemq

原标题:wns9778.compython使用stomp连接activemq

浏览次数:78 时间:2019-05-10

二、python使用stomp连接activemq

安装模块:pip3 install stomp.py  (注意是python3)

Python脚本如下:

# -*- coding: utf-8 -*-
"""
Created on Thu Jul 19 09:54:08 2018

@author: lihc
"""

# -*-coding:utf-8-*-
import stomp
import time


queue_name = '/queue/SampleQueue'
topic_name = '/topic/SampleTopic'
listener_name = 'SampleListener'
post=61613

class SampleListener(object):
    def on_message(self, headers, message):
        print ('headers: %s' % headers)
        print ('message: %s' % message)

# 推送到队列queue
def send_to_queue(msg):
    conn = stomp.Connection10([('127.0.0.1',post)])
    conn.start()
    conn.connect()
    conn.send(queue_name, msg)
    conn.disconnect()

#推送到主题
def send_to_topic(msg):
    conn = stomp.Connection10([('127.0.0.1',post)])
    conn.start()
    conn.connect()
    conn.send(topic_name, msg)
    conn.disconnect()

##从队列接收消息
def receive_from_queue():
    conn = stomp.Connection10([('127.0.0.1',61613)])
    conn.set_listener(listener_name, SampleListener())
    conn.start()
    conn.connect()
    conn.subscribe(queue_name)
    time.sleep(1) # secs
    conn.disconnect()

##从主题接收消息
def receive_from_topic():
    conn = stomp.Connection10([('127.0.0.1',post)])
    conn.set_listener(listener_name, SampleListener())
    conn.start()
    conn.connect()
    conn.subscribe(topic_name)
    while 1:
        send_to_topic('topic')
        time.sleep(3) # secs
    conn.disconnect()

if __name__=='__main__':
    send_to_queue('len 123')
    receive_from_queue()
    # send_to_topic('len 345')
    # receive_from_topic()

 

原文:https://blog.csdn.net/five3/article/details/79569587

另外参考:http://www.cnblogs.com/GarfieldTom/p/4153957.html

配置web管理页面的绑定IP和端口

编辑jetty.xml,查找WebConsolePort

    <bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">

             <!-- the default port number for the web console -->

        <property name="host" value=" style="background-color: #ff0000;">192.168.0.31"/>

        <property name="port" value=" style="background-color: #ff0000;">8161"/>

    </bean>

一、安装ActiveMQ服务

1. 当使用windows时,安装参考:https://blog.csdn.net/WuLex/article/details/78323811

    启动:运行activemq.bat

2. 当使用linux时,安装参考:https://www.cnblogs.com/andylhc/p/9337628.html

    启动:./activemq start

 

配置MQ连接的安全认证

编辑activemq.xml,在<broker>下加

        <plugins>

            <simpleAuthenticationPlugin>

                <users>

                    <authenticationUser username="user" password="user123" groups="users" />

                </users>

            </simpleAuthenticationPlugin>

        </plugins>

绑定协议连接端口到指定IP

编辑activemq.xml,在<transportConnectors>下找到指定协议的配置,并修改0.0.0.0为要绑定的ip

style="font-size: 12px; color: #333333; line-height: 21px; background-color: #f4fdfd;"> style="font-size: 12px; color: #333333; line-height: 21px; background-color: #f4fdfd;"><transportConnector name="openwire" uri="tcp:// style="font-size: 12px; color: #333333; line-height: 21px; background-color: #ff0000;">192.168.0.10:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

默认的web页面用户名密码admin:admin,非常不安全,

注册为Service

linux(RedHat,CentOS)下(官方参考文档),运行以下命令注册为service,并设置为开机自动启动

ln -snf bin/activemq /etc/init.d/activemq
chkconfig --add activemq
chkconfig activemq on

然后就可以使用如下service命令了

service activemq start|stop|status|restart

推荐阅读:

Spring Log4j ActiveMQ实现远程记录日志——实战 分析 http://www.linuxidc.com/Linux/2015-12/126163.htm

Spring下ActiveMQ实战  http://www.linuxidc.com/Linux/2015-11/124854.htm

wns9778.com,Linux系统下ActiveMQ 安装 http://www.linuxidc.com/Linux/2012-03/55623.htm

Ubuntu下的ACTIVEMQ服务器 http://www.linuxidc.com/Linux/2008-07/14587.htm

CentOS 6.5启动ActiveMQ报错解决 http://www.linuxidc.com/Linux/2015-08/120898.htm

Spring JMS ActiveMQ Tomcat实现消息服务 http://www.linuxidc.com/Linux/2011-10/44632.htm

Linux环境下面ActiveMQ端口号设置和WEB端口号设置 http://www.linuxidc.com/Linux/2012-01/51100.htm

ActiveMQ 的详细介绍请点这里
ActiveMQ 的下载地址请点这里

本文永久更新链接地址http://www.linuxidc.com/Linux/2016-01/128028.htm

wns9778.com 1

admin: admin123, admin

user: user123, user

配置web管理页面的安全认证

本文由wns9778.com发布于计算机教程,转载请注明出处:wns9778.compython使用stomp连接activemq

关键词: wns9778.com

上一篇:Code Kata:wns9778.com大整数四则运算—乘法 javascrip

下一篇:没有了