AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

ActiveMQ系列(四)--------结合 Eclipse 操作

2023-01-09 81
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 步骤如下

打开Eclipse

2345_image_file_copy_300.jpg

创建Maven工程

2345_image_file_copy_301.jpg

2345_image_file_copy_302.jpg

2345_image_file_copy_303.jpg

项目创建完毕  需要配置一下 pom.xml

2345_image_file_copy_304.jpg

在pom.xml中 添加ActiveMQ架包

2345_image_file_copy_305.jpg

添加一个com.tong文件夹  在里面创建一个名为HelloWordProducer的类

2345_image_file_copy_306.jpg

如果javax.jms 报错可以在pom.xml里面添加架包

2345_image_file_copy_307.jpg

2345_image_file_copy_308.jpg

2345_image_file_copy_309.jpg

 编写消息的生产者 

package com.tong;
import javax.jms.ConnectionFactory;
import javax.jms.Connection;
import javax.jms.Session;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Message;
import org.apache.*;
import org.apache.activemq.ActiveMQConnectionFactory;
public class HelloWordProducer {
  /***
   * 生产消息
   */
  public void sendHelloWordActiveMQ(String msgTest)
  {
    //定义链接工厂
    ConnectionFactory  connectionFactory=null;
    //定义链接对象
    Connection connection=null;
    //定义会话
    Session session=null;
    //定义目的地
    Destination destination=null;
    //定义消息的发送者
    MessageProducer producer=null;
    //定义消息
    Message messag=null;
    try
    {
      /***
       * username:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * password:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * brokerURL:访问ActiveMQ服务的路径地址。路径地址结构为:协议名称://主机地址:端口号
       */
      connectionFactory = new ActiveMQConnectionFactory("admin","admin","tcp://192.168.100.133:61616");
      //创建连接对象
      connection =connectionFactory.createConnection();
      //启动连接对象
      connection.start();
      /**
       * transacted:是否使用事务:true|false
       *             true：使用事务 当设置次变量值.Session.SESSION_TRANSACTED
       *             false:不适用事务,设置次变量 则acknowledge参数必须设置
       *             
       * acknowledgeMode :
       *   Session.AUTO_ACKNOWLEDGE:自动消息确认机制
       *   Seesion.CLIENT_ACKNOWLEDGE：客户端确认机制
       *   Session.DUPS_OK_ACKNOWLEDGE：有副本的客户端确认消息队列
       */
      session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
      //创建目的地,目的地名称即队列名称。消息的消费者需要此名称访问对应的队列
      destination=session.createQueue("helloword-destination");
      //创建消息的生产者
      producer=session.createProducer(destination);
      //创建消息对象
      messag =session.createTextMessage(msgTest);
      //发送消息
      producer.send(messag);
    }catch(Exception e)
    {
      e.printStackTrace();
    }finally
    {
      //回收消息发送者资源
      if(producer!=null)
      {
        try
        {
          producer.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(session!=null)
      {
        try
        {
          session.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(connection!=null)
      {
        try
        {
          connection.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
    }
  }
}

编写消息的消费者

          创建新的Maven项目

2345_image_file_copy_310.jpg

pom.xml 文件和消息生产者  一致

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.tong</groupId>
  <artifactId>mq-consumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <dependencies>
        <dependency>
            <groupId>org.apache.activemq</groupId> 
            <artifactId>activemq-all</artifactId>
            <version>5.9.0</version>
        </dependency>
            <!-- https://mvnrepository.com/artifact/javax.jms/javax.jms-api -->
    <dependency>
           <groupId>javax.jms</groupId>
            <artifactId>javax.jms-api</artifactId>
            <version>2.0.1</version>
    </dependency>
<!-- MQ -->
           <!-- https://mvnrepository.com/artifact/org.springframework/spring-jms -->
   <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>5.0.6.RELEASE</version>
   </dependency>
           <!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-core -->
   <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-core</artifactId>
            <version>5.7.0</version>
      </dependency>
  </dependencies>
</project>
package com.tong;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
public class HelloworldConsumer {
  /***
   * 生产消息
   */
  public void sendHelloWordActiveMQ()
  {
    //定义链接工厂
    ConnectionFactory  connectionFactory=null;
    //定义链接对象
    Connection connection=null;
    //定义会话
    Session session=null;
    //定义目的地
    Destination destination=null;
    //定义消息的消费者
    MessageConsumer consumer=null;
    //定义消息
    Message messag=null;
    try
    {
      /***
       * username:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * password:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * brokerURL:访问ActiveMQ服务的路径地址。路径地址结构为:协议名称://主机地址:端口号
       */
      connectionFactory = new ActiveMQConnectionFactory("admin","admin","tcp://192.168.100.133:61616");
      //创建连接对象
      connection =connectionFactory.createConnection();
      //启动连接对象
      connection.start();
      /**
       * transacted:是否使用事务:true|false
       *             true：使用事务 当设置次变量值.Session.SESSION_TRANSACTED
       *             false:不适用事务,设置次变量 则acknowledge参数必须设置
       *             
       * acknowledgeMode :
       *   Session.AUTO_ACKNOWLEDGE:自动消息确认机制
       *   Seesion.CLIENT_ACKNOWLEDGE：客户端确认机制
       *   Session.DUPS_OK_ACKNOWLEDGE：有副本的客户端确认消息队列
       */
      session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
      //创建目的地,目的地名称即队列名称。消息的消费者需要此名称访问对应的队列
      destination=session.createQueue("helloword-destination");
      //创建消息的消费者
       consumer=session.createConsumer(destination);
      //创建消息对象
      messag = consumer.receive();
      //处理消息
       String msg= ((TextMessage)messag).getText();
        System.out.println("从ActiveMQ服务中获取文本信息"+msg);
    }catch(Exception e)
    {
      e.printStackTrace();
    }finally
    {
      //回收消息发送者资源
      if(consumer!=null)
      {
        try
        {
          consumer.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(session!=null)
      {
        try
        {
          session.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(connection!=null)
      {
        try
        {
          connection.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
    }
  }
}

创建Test.java当启动类

package com.tong;
import com.tong.HelloWordProducer;
public class Test {
  public static void main(String[] args)
  {
    HelloWordProducer producer=new HelloWordProducer();
    producer.sendHelloWordActiveMQ("HelloWord");
  }
}

image.jpeg

处理对象消息

关键必须实现 Serializable 接口

package com.tong;
import java.io.Serializable;
public class Users implements Serializable {
  private int userid;
  private String username;
  private int userage;
  @Override
  public String toString() {
    return "Users [userid=" + userid + ", username=" + username + ", userage=" + userage + "]";
  }
  public int getUserid() {
    return userid;
  }
  public void setUserid(int userid) {
    this.userid = userid;
  }
  public String getUsername() {
    return username;
  }
  public void setUsername(String username) {
    this.username = username;
  }
  public int getUserage() {
    return userage;
  }
  public void setUserage(int userage) {
    this.userage = userage;
  }
}

生产者

package com.tong;
import javax.jms.ConnectionFactory;
import javax.jms.Connection;
import javax.jms.Session;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Message;
import org.apache.*;
import org.apache.activemq.ActiveMQConnectionFactory;
public class HelloWordProducer2 {
  /***
   * 生产消息
   */
  public void sendHelloWordActiveMQ(Users user)
  {
    //定义链接工厂
    ConnectionFactory  connectionFactory=null;
    //定义链接对象
    Connection connection=null;
    //定义会话
    Session session=null;
    //定义目的地
    Destination destination=null;
    //定义消息的发送者
    MessageProducer producer=null;
    //定义消息
    Message messag=null;
    try
    {
      /***
       * username:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * password:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * brokerURL:访问ActiveMQ服务的路径地址。路径地址结构为:协议名称://主机地址:端口号
       */
      connectionFactory = new ActiveMQConnectionFactory("admin","admin","tcp://192.168.100.133:61616");
      //创建连接对象
      connection =connectionFactory.createConnection();
      //启动连接对象
      connection.start();
      /**
       * transacted:是否使用事务:true|false
       *             true：使用事务 当设置次变量值.Session.SESSION_TRANSACTED
       *             false:不适用事务,设置次变量 则acknowledge参数必须设置
       *             
       * acknowledgeMode :
       *   Session.AUTO_ACKNOWLEDGE:自动消息确认机制
       *   Seesion.CLIENT_ACKNOWLEDGE：客户端确认机制
       *   Session.DUPS_OK_ACKNOWLEDGE：有副本的客户端确认消息队列
       */
      session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
      //创建目的地,目的地名称即队列名称。消息的消费者需要此名称访问对应的队列
      destination=session.createQueue("my-users");
      //创建消息的生产者
      producer=session.createProducer(destination);
      //创建消息对象
      messag =session.createObjectMessage(user);
      //发送消息
      producer.send(messag);
    }catch(Exception e)
    {
      e.printStackTrace();
    }finally
    {
      //回收消息发送者资源
      if(producer!=null)
      {
        try
        {
          producer.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(session!=null)
      {
        try
        {
          session.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(connection!=null)
      {
        try
        {
          connection.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
    }
  }
}

消费者

package com.tong;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
public class HelloworldConsumer2 {
  /***
   * 生产消息
   */
  public void sendHelloWordActiveMQ()
  {
    //定义链接工厂
    ConnectionFactory  connectionFactory=null;
    //定义链接对象
    Connection connection=null;
    //定义会话
    Session session=null;
    //定义目的地
    Destination destination=null;
    //定义消息的消费者
    MessageConsumer consumer=null;
    //定义消息
    Message messag=null;
    try
    {
      /***
       * username:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * password:访问ActiveMQ服务的用户名 用户密码。 默认的为admin。用户名可以通过jetty-name.properties文件进行修改
       * brokerURL:访问ActiveMQ服务的路径地址。路径地址结构为:协议名称://主机地址:端口号
       */
      connectionFactory = new ActiveMQConnectionFactory("admin","admin","tcp://192.168.100.133:61616");
      //创建连接对象
      connection =connectionFactory.createConnection();
      //启动连接对象
      connection.start();
      /**
       * transacted:是否使用事务:true|false
       *             true：使用事务 当设置次变量值.Session.SESSION_TRANSACTED
       *             false:不适用事务,设置次变量 则acknowledge参数必须设置
       *             
       * acknowledgeMode :
       *   Session.AUTO_ACKNOWLEDGE:自动消息确认机制
       *   Seesion.CLIENT_ACKNOWLEDGE：客户端确认机制
       *   Session.DUPS_OK_ACKNOWLEDGE：有副本的客户端确认消息队列
       */
      session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
      //创建目的地,目的地名称即队列名称。消息的消费者需要此名称访问对应的队列
      destination=session.createQueue("my-users");
      //创建消息的消费者
       consumer=session.createConsumer(destination);
      //创建消息对象
      messag = consumer.receive();
      //处理消息
      ObjectMessage objMessage=(ObjectMessage) messag; 
      Users users=(Users)objMessage.getObject();
      System.out.println(users);
    }catch(Exception e)
    {
      e.printStackTrace();
    }finally
    {
      //回收消息发送者资源
      if(consumer!=null)
      {
        try
        {
          consumer.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(session!=null)
      {
        try
        {
          session.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
      if(connection!=null)
      {
        try
        {
          connection.close();
        }catch(Exception e)
        {
          e.printStackTrace();
        }
      }
    }
  }
}

测试启动类

package com.tong;
import com.tong.HelloWordProducer;
public class Test {
  public static void main(String[] args)
  {
//    HelloWordProducer producer=new HelloWordProducer();
//    producer.sendHelloWordActiveMQ("HelloWord");
    Users users=new Users();
    users.setUserid(1);
    users.setUsername("童小纯");
    users.setUserage(20);
    HelloWordProducer2 producer=new HelloWordProducer2();
    producer.sendHelloWordActiveMQ(users);
  }
}
文章标签：
Java
Android开发
消息中间件
Maven
童小纯
目录
相关文章
程序三两行
|
8月前
|
Java Android开发
eclipse篇1：基本使用总结
eclipse篇1：基本使用总结
程序三两行
74 0
宝耶需努力
|
Java 开发工具 Android开发
【Eclipse】Eclipse使用技巧
【Eclipse】Eclipse使用技巧
宝耶需努力
146 0
Jack魏
|
Java 编译器 开发工具
Eclipse常用开发配置
有些导入Eclipse项目之后，会出现源码里面中文乱码问题，这时候需要我们修改一下Eclipse的编码设置。可能本地的JDK太高需要修改一下JDK进行再次开发，这时候修改一下JRE配置，最后别忘了修改一下Java编译的版本哟~
Jack魏
167 0
Eclipse常用开发配置
夜郎king
|
缓存 IDE Java
基于eclipse的源码阅读配置指南
本文主要阐述了在eclipse环境中如何配置加载jdk源码以及利用jad反编译技术加载不带源码的第三方源码，重点讲解了jad反编译技术的配置。
夜郎king
234 0
基于eclipse的源码阅读配置指南
明明如月
|
Java 数据库连接 应用服务中间件
怎样在eclipse里安装Hibernate / JBoss 工具【最新】
原文：http://www.mkyong.com/hibernate/how-to-install-hibernate-tools-in-eclipse-ide/
明明如月
234 0
怎样在eclipse里安装Hibernate / JBoss 工具【最新】
唐门没有糖
|
Linux
ubutu系统 安装eclipse
ubutu install eclipse
唐门没有糖
1239 0
凌浩雨
|
Web App开发 JavaScript Java
Eclipse 开发配置
1. Eclipse配置HTML/JS/CSS/JSP页面的自动提示 1.打开eclipse→Windows→Preferences→Java→Editor→Content Assist 修改Auto Activation triggers for java的值为：zjava 点击apply按钮 如图： 图1.
凌浩雨
1030 0
科技探索者
|
Android开发 Java
解决Eclipse不能启动的问题
科技探索者
911 0
科技小能手
|
Java 程序员 Android开发
Eclipse的一个重要功能
科技小能手
811 0
科技小能手
|
Java Linux Android开发
Linux配置支持C/C++项目的eclipse和支持java项目的eclipse
科技小能手
1541 0

热门文章

最新文章

  • 1
    ToC和ToB有啥区别
  • 2
    多中心容灾实践：如何实现真正的异地多活？
  • 3
    时间序列预测：CNN+LSTM+Attention模型实战
  • 4
    DSP_代码笔记（基于TMS320X281x）
  • 5
    Confluence 6 那些文件需要备份
  • 6
    区块链技术将占据全球金融系统核心地位
  • 7
    一个有味道的函数
  • 8
    ceph启动脚本
  • 9
    [CLR via C#]7. 常量和字段
  • 10
    JSP基础7
  • 1
    PsycoLLM：开源的中文心理大模型，免费 AI 心理医生，支持心理健康评估与多轮对话
    79
  • 2
    KAG：增强 LLM 的专业能力！蚂蚁集团推出专业领域知识增强框架，支持逻辑推理和多跳问答
    79
  • 3
    Gemini Coder：基于 Google Gemini API 的开源 Web 应用生成工具，支持实时编辑和预览
    51
  • 4
    AddressCLIP：一张照片就能准确定位！中科院联合阿里云推出街道级图像地理定位模型
    49
  • 5
    MiniPerplx：基于 Grok 2.0 的开源 AI 搜索引擎，支持网页、学术、视频搜索
    36
  • 6
    CreatiLayout：复旦与字节联合推出布局到图像生成技术，支持高质量图像生成与布局优化
    35
  • 7
    Cosmos：英伟达生成式世界基础模型平台，加速自动驾驶与机器人开发
    35
  • 8
    AIOpsLab：云服务自动化运维 AI，微软开源云服务 AI 框架，覆盖整个生命周期
    36
  • 9
    《docker基础篇：4.Docker镜像》包括是什么、分层的镜像、UnionFS（联合文件系统）、docker镜像的加载原理、为什么docker镜像要采用这种分层结构呢、docker镜像commit
    92
  • 10
    《鸿蒙安全沙箱机制——人工智能应用的安全护盾》
    23

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册

    • 相关实验场景

    更多
  • 基于 IntelliJ IDEA 插件部署微服务应用

    • 推荐镜像

    更多
  • eclipse
  • maven
  • libreoffice
    • 下一篇
    DataWorks智能交互式数据开发与分析之旅