精华内容
下载资源
问答
  • xftp和xhell必备,这里差一个题外话,提一下遇到一个小问题,xftp5老是发送一个错误的信息,卸载后重装就提示我更新到我安装的那个版本,然后就完成了,删除注册表回滚注册表 都没用,也不知道咋回事,换了xftp6就...

    官网下载,我的是5.14.0的版本,注意下载的是tar.gz压缩包,别下载成了windows使用的zip包。
    xftp和xhell必备,这里差一个题外话,提一下遇到一个小问题,xftp5老是发送一个错误的信息,卸载后重装就提示我更新到我安装的那个版本,然后就完成了,删除注册表回滚注册表 都没用,也不知道咋回事,换了xftp6就正常安装了,如果你遇到了一样的问题私信或者留言看到会给一个xftp6.exe然后上传到home/soft目录下,解压

     tar -zxvf apache-activemq-5.14.0.tar.gz  -C /home/soft

    这样可以在soft目录下看到解压好的文件了,下面我们修改一下配置文件,一般其他的基本不用做修改了,直接修改apache-activemq-5.14.0/conf目录下的activemq.xml文件。一般这个文件也只是修改一下61616等你要使用到的端口的ip,我的配置文件放上来吧

    <!--
        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.
    -->
    <!-- START SNIPPET: example -->
    <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">
    
        <!-- Allows us to use system properties as variables in this configuration file -->
        <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
            <property name="locations">
                <value>file:${activemq.conf}/credentials.properties</value>
            </property>
        </bean>
    
       <!-- Allows accessing the server log -->
        <bean id="logQuery" class="io.fabric8.insight.log.log4j.Log4jLogQuery"
              lazy-init="false" scope="singleton"
              init-method="start" destroy-method="stop">
        </bean>
    
        <!--
            The <broker> element is used to configure the ActiveMQ broker.
        -->
        <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
    
            <destinationPolicy>
                <policyMap>
                  <policyEntries>
                    <policyEntry topic=">" >
                        <!-- 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
    
                        -->
                      <pendingMessageLimitStrategy>
                        <constantPendingMessageLimitStrategy limit="1000"/>
                      </pendingMessageLimitStrategy>
                    </policyEntry>
                  </policyEntries>
                </policyMap>
            </destinationPolicy>
    
    
            <!--
                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
            -->
            <managementContext>
                <managementContext createConnector="false"/>
            </managementContext>
    
            <!--
                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
            -->
            <persistenceAdapter>
                <kahaDB directory="${activemq.data}/kahadb"/>
            </persistenceAdapter>
    
    
              <!--
                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
              -->
              <systemUsage>
                <systemUsage>
                    <memoryUsage>
                        <memoryUsage percentOfJvmHeap="70" />
                    </memoryUsage>
                    <storeUsage>
                        <storeUsage limit="100 gb"/>
                    </storeUsage>
                    <tempUsage>
                        <tempUsage limit="50 gb"/>
                    </tempUsage>
                </systemUsage>
            </systemUsage>
    
            <!--
                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
            -->
            <transportConnectors>
                <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
                <transportConnector name="openwire" uri="tcp://ip:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="amqp" uri="amqp://ip:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="stomp" uri="stomp://ip:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
            </transportConnectors>
    		
    
            <!-- destroy the spring context on shutdown to stop jetty -->
            <shutdownHooks>
                <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" />
            </shutdownHooks>
    
        </broker>
    
        <!--
            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
        -->
        <import resource="jetty.xml"/>
    
    </beans>
    <!-- END SNIPPET: example -->

    之后就是开放端口如下图,如果只是测试请 service iptables stop简单粗暴

    iptables -I INPUT -p tcp --dport 61616 -j ACCEPT
    自己看还需要开放那些端口,复制上面并修改端口号
    service iptables save
    service iptables restart

    最后确定一下是否ok,输入

      netstat -anp|grep 61616
    
      netstat -anp|grep 8161
    

    如果安装没什么错误一般会显示


    基本这样就没什么问题了,在安装的目录下./bin/activemq start启动服务就可以了,直接浏览器访问http://ip:8161/,输入用户名,密码;admin,admin。就可以了。关闭服务同理./bin/activemq stop
    如果遇到使用上述命令报错提示-bash: netstat: command not found,请

    yum install net-tools

    直接重新安装一下net-tools工具包解决。
    踩坑提醒,activemq.xml文件中的0.0.0.0,最好不要修改,我虚拟机测试没有问题但是换了阿里云的linux系统时候会报错,修改为0.0.0.0就可以了,可能是我主机设置的有点问题,有大佬看到能不能和我说下为什么?(只是单纯的发送消息,没有做集群)

    展开全文
  • activemq安装(linux

    2020-09-30 08:49:41
    本文内容引用的链接,如有侵权,请及时联系我删除 安装参见:https://blog.csdn.net/u012249177/article/details/81294334 设置开机启动:https://www.itsvse.com/thread-4617-1-1.html 问题: 如果遇见...

    本文内容引用的链接,如有侵权,请及时联系我删除

     

    安装参见:https://blog.csdn.net/u012249177/article/details/81294334

    设置开机启动:https://www.itsvse.com/thread-4617-1-1.html

     

    问题:

    如果遇见“服务activemq不支持chkconfig”错误,则需要检查一下文件里是否存在多余的空格字符或者中文空格一类的,也可以尝试修改#chkconfig:2345 61 61 这几个数值

     

    遇见启动activemq Configuration variable JAVA_HOME or JAVACMD is not defined correctly问题

    则参见https://www.jianshu.com/p/772e06e16997

    展开全文
  • 有windows和linux两种 windows的安装 :把下载的文件解压,复制到d盘中,然后打开bin里面的win64,里面有个InstallService,双击就行了,然后右键我的电脑,点击 服务和应用程序,找到 启动就行了 打开...

    1,安装activemq
    http://activemq.apache.org/download.html官网上下载
    在这里插入图片描述
    有windows和linux两种
    windows的安装 :把下载的文件解压,复制到d盘中,然后打开bin里面的win64,里面有个InstallService,双击就行了,然后右键我的电脑,点击 服务和应用程序,找到
    在这里插入图片描述
    启动就行了
    打开http://localhost:8161/进行登录 账号密码都是admin
    2,进行配置activemq.xml
    在这里插入图片描述
    3,依赖架

    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-all</artifactId>
      <version>5.12.1</version>
    </dependency>
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-core</artifactId>
      <version>5.7.0</version>
    </dependency>
    
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jms</artifactId>
      <version>4.3.4.RELEASE</version>
    </dependency>
    4,配置spring-jms文件
     <!--activeMQ为我们提供的ConnectionFactory-->
    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://192.168.0.139:61616"/>
    </bean>
    <!--spring jms为我们提供的连接池-->
    <bean id = "connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
        <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
    </bean>
    
    <bean id="waitForDeleteQueue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg name="name" value="waitForDeleteQueue" />
    </bean>
    
    
    <!-- 配置jmsTemplate   -->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"></property>
        <property name="messageConverter">
            <bean class="org.springframework.jms.support.converter.SimpleMessageConverter"></bean>
        </property>
    </bean>
    
    <!-- 待删除队列监听 -->
    <bean id="waitForDeleteContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory"></property>
        <property name="destination" ref="waitForDeleteQueue"></property>
    </bean>
    5,在spring-context.xml里面导入spring-jms.xml文件
    <!-- 引入jar包中的jms配置文件 -->
    <import resource="classpath*:spring-jms.xml" />
    6,在添加spu的时候创建一下监听
     jmsTemplate.send(waitForDeleteQueue,(session)-> {
                ObjectMessage objectMessage = session.createObjectMessage(goodsSpu.getId());
                objectMessage.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY,2*60*1000);
                return objectMessage;
            });
            7,写一个公开的方法
             public void delete(Integer id) {
        GoodsSpu goodsSpu = goodsSpuMapper.selectByPrimaryKey(id);
        if (("0").equals(goodsSpu.getState())){
            goodsSpuMapper.deleteByPrimaryKey(id);
    
        }
    }
    8,写一个WaitForDeleteListener等待删除的方法实现MessageListener监听模式
    @Component("waitForPaymentListener")
    

    public class WaitForDeleteListener implements MessageListener {
    @Autowired
    private WaitForDeleteListener waitForDeleteListener;

    private DefaultMessageListenerContainer waitForDeleteContainer;
    
    @Autowired
    public void setWaitForEvaluateContainer(DefaultMessageListenerContainer waitForDeleteContainer) {
        this.waitForDeleteContainer = waitForDeleteContainer;
        waitForDeleteContainer.setMessageListener(waitForDeleteListener);
    }
    @Autowired
    private GoodsSpuService goodsSpuService;
    
    @Override
    public void onMessage(Message message) {
        try {
    
            Integer id = (Integer) ((ObjectMessage) message).getObject();
            goodsSpuService.delete(id);
            System.out.println("消费了一条消息 id是"+id);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
    

    这个项目启动就开始监听了,创建一个spu时,activemq就开始监听这条信息,等时间到了之后,自动删除

    展开全文
  • 测试插入一万条数据,耗时290秒,然后测试添加和删除持久化配置,添加和删除事物都没有多大影响 后面修改连接为 测试插入一万条数据,耗时1.4秒, 本地测试,上传到linux环境测试都是快了

    原先的配置

    	<!-- 真正可以产生Connection的ConnectionFactory,由对应的 JMS服务厂商提供-->  
    	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">  
    	    <property name="brokerURL" value="${jms.brokerURL}"/>  
    	</bean>  
    	  
    	<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">  
    	    <property name="connectionFactory" ref="targetConnectionFactory"/>  
    	    <property name="maxConnections" value="${jms.maxConnections}"/>  
    	</bean>  
    	  
    	<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">  
    	    <property name="targetConnectionFactory" ref="pooledConnectionFactory"/>  
    	</bean>  

    测试插入一万条数据,耗时290秒,然后测试添加和删除持久化配置,添加和删除事物都没有多大影响

    后面修改连接为

    	<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    	 	  <property name="brokerURL" value="tcp://10.100.21.201:61616?jms.useAsyncSend=true" />   
    	</bean>  

    测试插入一万条数据,耗时1.4秒,


    本地测试,上传到linux环境测试都是快了200倍,,,,


    展开全文
  • 2019-10-30 21:09:26,578 | INFO | Client environment:os.name=Linux | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:os.arch=amd64 | org.apache.zookeeper....
  • 中间消息插件的介绍 消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息...ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。...
  • 1、本机安装Jdk7、Mysql、Redis、Zookeeper、ActiveMQ并启动相关服务,使用默认配置默认端口即可 2、克隆源代码到本地并打开,推荐使用IntelliJ IDEA,本地编译并安装到本地maven仓库 修改本地Host 127.0.0.1 ui...
  • springboot-activemq active简单使用 点对点 topic 以及virtualtopic 使用 springboot-canal 整合canal 对于跨机房数据库进行数据同步监听...... springboot-easypoi 整合easypoi 导入导出 以及 导入数据校验 ...
  • [系统架构]新增集成消息中间件管理消息队列,比如kafka,activeMQ [平台配置]系统增强,增加在线编辑部分配置文件的能力,并在集群时同步配置信息 [用户认证]新增用户登录ip限制(黑名单)功能 [流程管理]新增了数据...
  • │ 第15节:带查询的分页、修改和删除页面.avi │ 第16节:Mybatis动态查询和Json自动拼装.avi │ 第17节:X-gen生成所需的DAO部分模板.avi │ 第18节:X-gen所需service、web层模板.avi │ 第19节:X-gen生成相应的...
  •  Fourinone整体代码短小精悍,跟Hadoop, Zookeeper, Memcache, ActiveMq等开源产品代码上没有任何相似性,不需要任何依赖,引用一个jar包就可以嵌入式使用,良好支持window环境,可以在一台机器上模拟分布式环境,...
  • fourinone-3.04.25

    2013-12-11 21:35:04
    Fourinone整体代码短小精悍,跟Hadoop, Zookeeper, Memcache, ActiveMq等开源产品代码上没有任何相似性,不需要任何依赖,引用一个jar包就可以嵌入式使用,良好支持window环境,可以在一台机器上模拟分布式环境,更...
  • 保证Bean正常被激活和钝化,EJB对象是用完毕,从内存中清除,从账户中取出amt,如果amt>账户余额抛出异常,一个实体Bean可以表示不同的数据实例,我们应该通过主键来判断删除哪个数据实例…… ejbCreate函数用于初始...
  • JAVA上百实例源码以及开源项目

    千次下载 热门讨论 2016-01-03 17:37:40
    从内存中清除,从账户中取出amt,如果amt>账户余额抛出异常,一个实体Bean可以表示不同的数据实例,我们应该通过主键来判断删除哪个数据实例…… ejbCreate函数用于初始化一个EJB实例 5个目标文件,演示Address ...
  • java开源包1

    千次下载 热门讨论 2013-06-28 09:14:34
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包12

    热门讨论 2013-06-28 10:14:45
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • Java资源包01

    2016-08-31 09:16:25
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包101

    2016-07-13 10:11:08
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包11

    热门讨论 2013-06-28 10:10:38
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包2

    热门讨论 2013-06-28 09:17:39
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包3

    热门讨论 2013-06-28 09:20:52
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包6

    热门讨论 2013-06-28 09:48:32
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包5

    热门讨论 2013-06-28 09:38:46
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包10

    热门讨论 2013-06-28 10:06:40
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包4

    热门讨论 2013-06-28 09:26:54
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包8

    热门讨论 2013-06-28 09:55:26
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包9

    热门讨论 2013-06-28 09:58:55
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
  • java开源包7

    热门讨论 2013-06-28 09:52:16
    ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...

空空如也

空空如也

1 2
收藏数 29
精华内容 11
关键字:

linux删除activemq

linux 订阅