AI 助理
备案控制台
开发者社区 云原生 中间件 文章 正文

Java中间件JMS之ActiveMQ入门

2017-11-15 786
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
Serverless 应用引擎免费试用套餐包，4320000 CU，有效期3个月
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper，118元/月
简介：

文章原文:http://blog.csdn.net/dengwanchuan/article/details/10241345


1.ActiveMQ概述

企业消息软件从80年代起就存在，它不只是一种应用间消息传递风格，也是一种集成风格。因此，消息传递可以满足应用间的通知和互相操作。但是开源的解决方案是到最近10年才出现的。Apache ActiveMQ就是其中一种。它使应用间能以异步，松耦合方式交流。ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。

‍   ActiveMQ是Apache软件基金下的一个开源软件，它遵循JMS规范（Java Message Service），是消息驱动中间件软件（MOM）。它为企业消息传递提供高可用，出色性能，可扩展，稳定和安全保障。ActiveMQ使用Apache许可协议。因此，任何人都可以使用和修改它而不必反馈任何改变。这对于商业上将ActiveMQ用在重要用途的人尤为关键。MOM的工作是在分布式的各应用之间调度事件和消息，使之到达指定的接收者。所以高可用，高性能，高可扩展性尤为关键。

2.ActiveMQ特性


   ⒈支持多种语言客户端,如:Java,C,C++,C#,Ruby,Perl,Python,PHP。应用协议有 OpenWire,Stomp REST,WS Notification,XMPP,AMQP。

   ⒉ 完全支持JMS1.1和J2EE1.4规范,它们包括同步和异步消息传递，一次和只有一次的消息传递，对于预订者的持久消息等等。依附于JMS规范意味着，不论JMS消息提供者是谁，同样的基本特性（持久化，XA消息，事务)都是有效的。

   ⒊ 对Spring的支持，ActiveMQ可以很容易内嵌到使用Spring的系统里面去。

   ⒋ 通过了常见J2EE服务器（如 Geronimo,JBoss 4,GlassFish,WebLogic)的测试，其中通过JCA 1.5 resource adaptors的配置，可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上。

   ⒌ ActiveMQ提供各种连接选择，包括HTTP，HTTPS，IP多点传送，SSL，STOMP，TCP，UDP，XMPP等。大量的连接协议支持使之具有更好的灵活性。很多现有的系统使用一种特定协议并且不能改变，所以一个支持多种协议的消息平台降低了使用的门槛。虽然连接很重要，但是和其他容器集成也同样重要。

   6.ActiveMQ提供多种持久性方案可供选择，也可以完全按自己需求定制验证和授权。例如，ActiveMQ通过KahaDB提供自己的超快速消息持久方案（ultra-fast message persistence），但也支持标准的JDBC方案。ActiveMQ可以通过配置文件提供简单的验证和授权，也提供标准的JAAS登陆模块。

   7.ActiveMQ是为开发者设计的。它并不需要专门的管理工具，因为它提供各种易用且强大的管理特性。有很多方法去监控ActiveMQ的各个方面，可以通过JMX使用JConsole或ActiveMQ web console；可以运行ActiveMQ消息报告；可以用命令行脚本；可以通过日志。

   8.代理器集群（Broker clustering）----为了利于扩展，多个ActiveMQ broker能够联合工作。这个方式就是network of brokers并且能支持多种拓扑结构;支持客户端-服务器，点对点。

   9.支持Ajax, 支持与Axis的整合


3.ActiveMQ优势

   1.与OpenJMS、JbossMQ等开源jms provider相比，ActiveMQ有Apache的支持，持续发展的优势明显。

   2.速度很快，JBossMQ的十倍(没有测试)


   3.提高系统资源的利用率，主要是任务的派发不是24小时平均的，而是高峰时期任务量很多，比如1秒1000多个，有的时候很低，比如十几秒钟才来一个。应用服务通过JMS队列一个一个的取任务，做完一个再领一个，使系统资源的运用趋于平均。而JMS，比如JMS接收消息的效率是很高的，比如ActiveMQ，在赛扬（2.40GHz）机器上能够达到2000/s，消息大小为1-2k。好一些的服务器可以达到2万以上/秒。


4.ActiveMQ安装

   首先去http://activemq.apache.org/download.html 下载最新版本ActiveMQ 5.8.0 Release， 解压apache-activemq-5.8.0-bin.zip(或者apache-activemq-5.8.0-bin.tar.gz)

目录如下：

  +bin (windows下面的bat和unix/linux下面的sh)

  +conf (activeMQ配置目录，包含最基本的activeMQ配置文件）

  +data （默认是空的）

  +docs (只有index.html）

  +example （几个例子)

  +lib (activemMQ使用到的lib)

  +webapps(后台管理页面)

+webapps-demo(后台管理消息发送页面)

  +activemq-all-5.8.0.jar (java开发的jar包)

  -LICENSE.txt

  -NOTICE.txt

  -README.txt

  -user-guide.html

你可以使用bin\activemq.bat(activemq)启动。

启动ActiveMQ以后，登陆：http://localhost:8161/admin/ 默认用户/密码为admin/admin。

注意:

⒈ 这个仅仅是最基础的ActiveMQ的配置，很多地方都没有配置因此不要直接使用这个配置用于生存环境。

⒉ 有的时候由于端口被占用，导致ActiveMQ错误，ActiveMQ可能需要以下端口1099(JMX),61616（默认的TransportConnector)。

⒊ 如果没有物理网卡，或者MS的LoopBackAdpater Multicast会报一个错误


5.运行附带的示例程序

  1、Queue消息示例：

    * 启动Queue消息消费者

      cd example


ant consumer

    * 启动Queue消息生产者

      cd example

      ant producer 
    简要说明：生产者（producer）发消息，消费者（consumer）接消息，发送/接收2000个消息后自动关闭

  2、Topic消息示例：

    * 启动Topic消息消费者

      cd example

      ant topic-listener

    * 启动Topic消息生产者

      cd example

      ant topic-publisher 
    简要说明：重复10轮，publisher每轮发送2000个消息，并等待获取listener的处理结果报告，然后进入下一轮      发送，最后

统计全局发送时间。

  3、Queue消息和Topic消息发送之后，可以通过后台点击Queues和Topics查看发送消息具体信息。

6.ActiveMQ类别及开发流程

1)、Point-to-Point (点对点)消息模式开发流程 ：
      1、生产者（producer）开发流程（ProducerTool.java）：

        1.1 创建Connection： 根据url，user和password创建一个jms Connection。

        1.2 创建Session： 在connection的基础上创建一个session，同时设置是否支持事务和ACKNOWLEDGE标识。

        1.3 创建Destination对象： 需指定其对应的主题（subject）名称，producer和consumer将根据subject来发送/接收对应的消息。

        1.4 创建MessageProducer： 根据Destination创建MessageProducer对象，同时设置其持久模式。

        1.5 发送消息到队列（Queue）： 封装TextMessage消息，使用MessageProducer的send方法将消息发送出去。

      2、消费者（consumer）开发流程（ConsumerTool.java）：

        2.1 实现MessageListener接口： 消费者类必须实现MessageListener接口，然后在onMessage()方法中监听消息的到达并处理。

        2.2 创建Connection： 根据url，user和password创建一个jms Connection，如果是durable模式，还需要给connection设置一个clientId。

        2.3 创建Session和Destination： 与ProducerTool.java中的流程类似，不再赘述。

        2.4 创建replyProducer【可选】：可以用来将消息处理结果发送给producer。

        2.5 创建MessageConsumer：  根据Destination创建MessageConsumer对象。

2.6 消费message：  在onMessage()方法中接收producer发送过来的消息进行处理，并可以通过replyProducer反馈信息给producer


[java] view plain copy

  1. if (message.getJMSReplyTo() != null) {    

  2.  replyProducer.send(message.getJMSReplyTo(),    

  3. session.createTextMessage("Reply: " + message.getJMSMessageID()));  



2)、Publisher/Subscriber(发布/订阅者)消息模式开发流程


      1、订阅者（Subscriber）开发流程（TopicListener.java）：

        1.1 实现MessageListener接口： 在onMessage()方法中监听发布者发出的消息队列，并做相应处理。

        1.2 创建Connection： 根据url，user和password创建一个jms Connection。

        1.3 创建Session： 在connection的基础上创建一个session，同时设置是否支持事务和ACKNOWLEDGE标识。

        1.4 创建Topic：  创建2个Topic， topictest.messages用于接收发布者发出的消息，topictest.control 用于向发布者发送消息，实现双方的交互。

        1.5 创建consumer和producer对象：根据topictest.messages创建consumer，根据topictest.control创建 producer。

        1.6 接收处理消息：在onMessage()方法中，对收到的消息进行处理，可直接简单在本地显示消息，或者根 据消息内容不同处理对应的业务逻辑（比如：数据库更新、文件操作等等），并且可以使用producer对象将处理结果返回给发布者。

      2、发布者（Publisher）开发流程（TopicPublisher.java）：

        2.1 实现MessageListener接口：在onMessage()方法中接收订阅者的反馈消息。

        2.2 创建Connection： 根据url，user和password创建一个jms Connection。

2.3 创建Session： 在connection的基础上创建一个session，同时设置是否支持事务和ACKNOWLEDGE标识。

        2.4 创建Topic： 创建2个Topic，topictest.messages用于向订阅者发布消息，topictest.control用于接 收订阅者反馈的消息。这2个topic与订阅者开发流程中的topic是一一对应的。

        2.5 创建consumer和producer对象： 根据topictest.messages创建publisher； 根据topictest.control 创建consumer，同时监听订阅者反馈的消息。

        2.6 给所有订阅者发送消息，并接收反馈消息：  示例代码中，一共重复10轮操作。 每轮先向所有订阅者 发送2000个消息； 然后堵塞线程，开始等待； 最后通过onMessage()方法，接收到订阅者反馈的“REPORT”类信息后，才print反馈信息并解除线程堵塞，进入下一轮。 
            注：可同时运行多个订阅者测试查看此模式效果

7.Eclipse代码开发

  1.建立一个Web Probject 项目,将activemq-all-5.8.0.jar放在lib里面


  2.Queue（点对点）方式：生产者

[java] view plain copy

  1. package jms;  

  3. import javax.jms.Connection;  

  4. import javax.jms.ConnectionFactory;  

  5. import javax.jms.DeliveryMode;  

  6. import javax.jms.Destination;  

  7. import javax.jms.MessageProducer;  

  8. import javax.jms.Queue;  

  9. import javax.jms.Session;  

  10. import javax.jms.TextMessage;  

  12. import org.apache.activemq.ActiveMQConnection;  

  13. import org.apache.activemq.ActiveMQConnectionFactory;  

  15. //Queue（点对点）方式  生存者Producer

  16. publicclass QueueProducer {  

  17. privatestatic String user = ActiveMQConnection.DEFAULT_USER;  

  18. privatestatic String password =ActiveMQConnection.DEFAULT_PASSWORD;  

  19. privatestatic String url =  "tcp://localhost:61616";  

  21. publicstaticvoid main(String[] args)throws Exception {  

  22. // ConnectionFactory ：连接工厂，JMS 用它创建连接

  23.        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,password,url);  

  24. // Connection ：JMS 客户端到JMS Provider 的连接

  25.        Connection connection = connectionFactory.createConnection();  

  26. // Connection 启动

  27.        connection.start();  

  28.        System.out.println("Connection is start...");  

  29. // Session： 一个发送或接收消息的线程

  30.        Session session = connection.createSession(Boolean.TRUE,Session.AUTO_ACKNOWLEDGE);  

  31. // Queue ：消息的目的地;消息发送给谁.

  32.        Queue  destination = session.createQueue("example.A");  

  33. // MessageProducer：消息发送者

  34.        MessageProducer producer = session.createProducer(destination);  

  35. // 设置不持久化，此处学习，实际根据项目决定

  36.        producer.setDeliveryMode(DeliveryMode.PERSISTENT);  

  37. // 构造消息，此处写死，项目就是参数，或者方法获取

  38.        sendMessage(session, producer);  

  39.        session.commit();  

  41.        connection.close();  

  42.        System.out.println("send text ok.");  

  43.    }  

  45. publicstaticvoid sendMessage(Session session, MessageProducer producer)  

  46. throws Exception {  

  47. for (int i = 1; i <= 100; i++) {//有限制,达到1000就不行

  48.            TextMessage message = session.createTextMessage("ActiveMq 发送的消息" + i);  

  49. // 发送消息到目的地方

  50.            System.out.println("发送消息：" + "ActiveMq 发送的消息" + i);  

  51.            producer.send(message);  

  52.        }  

  53.    }  

  54. }  

 3.Queue（点对点）方式：消费者


[java] view plain copy

  1. package jms;  

  3. import javax.jms.Connection;  

  4. import javax.jms.ConnectionFactory;  

  5. import javax.jms.Destination;  

  6. import javax.jms.JMSException;  

  7. import javax.jms.Message;  

  8. import javax.jms.MessageConsumer;  

  9. import javax.jms.MessageListener;  

  10. import javax.jms.Queue;  

  11. import javax.jms.Session;  

  12. import javax.jms.TextMessage;  

  14. import org.apache.activemq.ActiveMQConnection;  

  15. import org.apache.activemq.ActiveMQConnectionFactory;  

  17. //Queue（点对点）方式  消费这Consumer

  18. publicclass QueueConsumer {  

  19. privatestatic String user = ActiveMQConnection.DEFAULT_USER;  

  20. privatestatic String password =ActiveMQConnection.DEFAULT_PASSWORD;  

  21. privatestatic String url = "tcp://localhost:61616";  

  22. publicstaticvoid main(String[] args) throws Exception{  

  23. // ConnectionFactory ：连接工厂，JMS 用它创建连接

  24.        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,password,url);  

  25. // Connection ：JMS 客户端到JMS Provider 的连接

  26.        Connection connection = connectionFactory.createConnection();  

  27.        connection.start();  

  28. // Session： 一个发送或接收消息的线程

  29. final Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);  

  30. // Destination ：消息的目的地;消息发送给谁.

  31.        Queue destination=session.createQueue("example.A");  

  32. // 消费者，消息接收者

  33.        MessageConsumer consumer = session.createConsumer(destination);  

  34.        consumer.setMessageListener(new MessageListener(){//有事务限制

  35. @Override

  36. publicvoid onMessage(Message message) {  

  37. try {  

  38.                    TextMessage textMessage=(TextMessage)message;  

  39.                    System.out.println(textMessage.getText());  

  40.                } catch (JMSException e1) {  

  41.                    e1.printStackTrace();  

  42.                }  

  43. try {  

  44.                    session.commit();  

  45.                } catch (JMSException e) {  

  46.                    e.printStackTrace();  

  47.                }  

  48.            }  

  49.        });  

  51. /*  另外一种接受方式

  52. *    while (true) {

  53.              //设置接收者接收消息的时间，为了便于测试，这里谁定为100s

  54.              TextMessage message = (TextMessage) consumer.receive(100000);

  55.              if (null != message) {

  56.                  System.out.println("收到消息" + message.getText());

  57.              } else {

  58.                  break;

  59.              }

  60.          }*/

  61.    }  

  62. }  




4.Topic（发布/订阅）方式：发布者


[java] view plain copy

  1. package jms;  

  3. import java.util.Date;  

  5. import javax.jms.Connection;  

  6. import javax.jms.ConnectionFactory;  

  7. import javax.jms.DeliveryMode;  

  8. import javax.jms.JMSException;  

  9. import javax.jms.MapMessage;  

  10. import javax.jms.MessageProducer;  

  11. import javax.jms.Queue;  

  12. import javax.jms.Session;  

  13. import javax.jms.TextMessage;  

  14. import javax.jms.Topic;  

  16. import org.apache.activemq.ActiveMQConnection;  

  17. import org.apache.activemq.ActiveMQConnectionFactory;  

  19. //Topic（发布/订阅）方式  发布者Publisher

  20. publicclass TopicPublisher {  

  21. privatestatic String user = ActiveMQConnection.DEFAULT_USER;  

  22. privatestatic String password =ActiveMQConnection.DEFAULT_PASSWORD;  

  23. privatestatic String url =  "tcp://localhost:61616";  

  25. publicstaticvoid main(String[] args)throws Exception {  

  26. // ConnectionFactory ：连接工厂，JMS 用它创建连接

  27.        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,password,url);  

  28. // Connection ：JMS 客户端到JMS Provider 的连接

  29.        Connection connection = connectionFactory.createConnection();  

  30. // Connection 启动

  31.        connection.start();  

  32.        System.out.println("Connection is start...");  

  33. // Session： 一个发送或接收消息的线程

  34.        Session session = connection.createSession(Boolean.TRUE,Session.AUTO_ACKNOWLEDGE);  

  35. // Topicr ：消息的目的地;消息发送给谁.

  36.        Topic  destination = session.createTopic("example.A");  

  37. // MessageProducer：消息发送者

  38.        MessageProducer producer = session.createProducer(destination);  

  39. // 设置不持久化，此处学习，实际根据项目决定

  40.        producer.setDeliveryMode(DeliveryMode.PERSISTENT);  

  41. // 构造消息，此处写死，项目就是参数，或者方法获取

  42.        sendMessage(session, producer);  

  43.        session.commit();  

  45.        connection.close();  

  46.        System.out.println("send text ok.");  

  47.    }  

  49. publicstaticvoid sendMessage(Session session, MessageProducer producer)  

  50. throws Exception {  

  51. for (int i = 1; i <= 100; i++) {//有限制,达到1000就不行

  52.            TextMessage message = session.createTextMessage("ActiveMq 发送的消息" + i);  

  53. // 发送消息到目的地方

  54.            System.out.println("发送消息：" + "ActiveMq 发送的消息" + i);  

  55.            producer.send(message);  

  56.        }  

  57.    }  

  59. }  






5.Topic（发布/订阅）方式：订阅者



[java] view plain copy

  1. package jms;  

  3. import javax.jms.Connection;  

  4. import javax.jms.ConnectionFactory;  

  5. import javax.jms.JMSException;  

  6. import javax.jms.Message;  

  7. import javax.jms.MessageConsumer;  

  8. import javax.jms.MessageListener;  

  9. import javax.jms.Session;  

  10. import javax.jms.TextMessage;  

  11. import javax.jms.Topic;  

  13. import org.apache.activemq.ActiveMQConnection;  

  14. import org.apache.activemq.ActiveMQConnectionFactory;  

  16. //Topic（发布/订阅）方式  订阅者TopicSubscriber

  17. publicclass TopicSubscriber {  

  18. privatestatic String user = ActiveMQConnection.DEFAULT_USER;  

  19. privatestatic String password =ActiveMQConnection.DEFAULT_PASSWORD;  

  20. privatestatic String url = "tcp://localhost:61616";  

  21. publicstaticvoid main(String[] args) throws Exception{  

  22. // ConnectionFactory ：连接工厂，JMS 用它创建连接

  23.        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,password,url);  

  24. // Connection ：JMS 客户端到JMS Provider 的连接

  25.        Connection connection = connectionFactory.createConnection();  

  26.        connection.start();  

  27. // Session： 一个发送或接收消息的线程

  28. final Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);  

  29. // Destination ：消息的目的地;消息发送给谁.

  30.        Topic destination=session.createTopic("example.A");  

  31. // 消费者，消息接收者

  32.        MessageConsumer consumer = session.createConsumer(destination);  

  33.        consumer.setMessageListener(new MessageListener(){//有事务限制

  34. @Override

  35. publicvoid onMessage(Message message) {  

  36. try {  

  37.                    TextMessage textMessage=(TextMessage)message;  

  38.                    System.out.println(textMessage.getText());  

  39.                } catch (JMSException e1) {  

  40.                    e1.printStackTrace();  

  41.                }  

  42. try {  

  43.                    session.commit();  

  44.                } catch (JMSException e) {  

  45.                    e.printStackTrace();  

  46.                }  

  47.            }  

  48.        });  

  50. /*  另外一种接受方式

  51. *    while (true) {

  52.              //设置接收者接收消息的时间，为了便于测试，这里谁定为100s

  53.              TextMessage message = (TextMessage) consumer.receive(100000);

  54.              if (null != message) {

  55.                  System.out.println("收到消息" + message.getText());

  56.              } else {

  57.                  break;

  58.              }

  59.          }*/

  60.    }  

  61. }  




Queue（点对点）方式和Topic（发布/订阅）方式 的运行结果最明显的区别是：在Queue（点对点）方式中先运行生产者,再运行消费者,消费者还能接受到消息；

而Topic（发布/订阅）方式就不同了，先运行发布者，再运行订阅者，订阅者收到的消息

可能没有或者是不完全的。














本文转自yunlielai51CTO博客，原文链接： http://blog.51cto.com/4925054/1283320 ，如需转载请自行联系原作者
文章标签：
消息中间件
Java
中间件
网络协议
Apache
关键词：
Java入门
中间件activemq
Java中间件
Java jms
Java ActiveMQ
技术小美
目录
相关文章
m1a6
|
29天前
|
Java 开发者 微服务
Spring Boot 入门：简化 Java Web 开发的强大工具
Spring Boot 是一个开源的 Java 基础框架，用于创建独立、生产级别的基于Spring框架的应用程序。它旨在简化Spring应用的初始搭建以及开发过程。
m1a6
50 6
Spring Boot 入门：简化 Java Web 开发的强大工具
游客7ofzsdfcat7ls
|
25天前
|
监控 架构师 Java
Java虚拟机调优的艺术：从入门到精通####
本文作为一篇深入浅出的技术指南，旨在为Java开发者揭示JVM调优的神秘面纱，通过剖析其背后的原理、分享实战经验与最佳实践，引领读者踏上从调优新手到高手的进阶之路。不同于传统的摘要概述，本文将以一场虚拟的对话形式，模拟一位经验丰富的架构师向初学者传授JVM调优的心法，激发学习兴趣，同时概括性地介绍文章将探讨的核心议题——性能监控、垃圾回收优化、内存管理及常见问题解决策略。 ####
游客7ofzsdfcat7ls
46 7
ShaFaChuang-36210
|
1月前
|
监控 安全 Java
Java中的多线程编程：从入门到实践####
本文将深入浅出地探讨Java多线程编程的核心概念、应用场景及实践技巧。不同于传统的摘要形式，本文将以一个简短的代码示例作为开篇，直接展示多线程的魅力，随后再详细解析其背后的原理与实现方式，旨在帮助读者快速理解并掌握Java多线程编程的基本技能。 ```java // 简单的多线程示例：创建两个线程，分别打印不同的消息 public class SimpleMultithreading { public static void main(String[] args) { Thread thread1 = new Thread(() -> System.out.prin
ShaFaChuang-36210
58 1
游客gavtnh6pi64i6
|
1月前
|
Java 大数据 API
14天Java基础学习——第1天：Java入门和环境搭建
本文介绍了Java的基础知识，包括Java的简介、历史和应用领域。详细讲解了如何安装JDK并配置环境变量，以及如何使用IntelliJ IDEA创建和运行Java项目。通过示例代码“HelloWorld.java”，展示了从编写到运行的全过程。适合初学者快速入门Java编程。
游客gavtnh6pi64i6
80 2
bug菌
|
1月前
|
存储 安全 Java
🌟Java零基础-反序列化：从入门到精通
【10月更文挑战第21天】本文收录于「滚雪球学Java」专栏，专业攻坚指数级提升，希望能够助你一臂之力，帮你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！
bug菌
85 5
shuj
|
1月前
|
安全 Java 调度
Java中的多线程编程入门
【10月更文挑战第29天】在Java的世界中，多线程就像是一场精心编排的交响乐。每个线程都是乐团中的一个乐手，他们各自演奏着自己的部分，却又和谐地共同完成整场演出。本文将带你走进Java多线程的世界，让你从零基础到能够编写基本的多线程程序。
shuj
37 1
萝卜带泥
|
1月前
|
Java 数据处理 开发者
Java多线程编程的艺术：从入门到精通####
【10月更文挑战第21天】 本文将深入探讨Java多线程编程的核心概念，通过生动实例和实用技巧，引导读者从基础认知迈向高效并发编程的殿堂。我们将一起揭开线程管理的神秘面纱，掌握同步机制的精髓，并学习如何在实际项目中灵活运用这些知识，以提升应用性能与响应速度。 ####
萝卜带泥
51 3
游客5fdji2pvmf8888
|
2月前
|
Java
Java中的多线程编程：从入门到精通
本文将带你深入了解Java中的多线程编程。我们将从基础概念开始，逐步深入探讨线程的创建、启动、同步和通信等关键知识点。通过阅读本文，你将能够掌握Java多线程编程的基本技能，为进一步学习和应用打下坚实的基础。
游客5fdji2pvmf8888
49 2
历年考试不作弊
|
1月前
|
Java 程序员 数据库连接
Java中的异常处理：从入门到精通
在Java编程的海洋中，异常处理是一艘不可或缺的救生艇。它不仅保护你的代码免受错误数据的侵袭，还能确保用户体验的平稳航行。本文将带你领略异常处理的风浪，让你学会如何在Java中捕捉、处理和预防异常，从而成为一名真正的Java航海家。
历年考试不作弊
30 0
进步`于辰
|
2月前
|
Java
[Java]Socket套接字（网络编程入门）
本文介绍了基于Java Socket实现的一对一和多对多聊天模式。一对一模式通过Server和Client类实现简单的消息收发；多对多模式则通过Server类维护客户端集合，并使用多线程实现实时消息广播。文章旨在帮助读者理解Socket的基本原理和应用。
进步`于辰
34 1
云原生

中间件

热门文章

最新文章

  • 1
    阿里电商架构演变之路
  • 2
    阿里开源消息中间件RocketMQ的前世今生
  • 3
    阿里巴巴在应用性能测试场景设计和实现上的实践
  • 4
    2017双11技术揭秘—阿里数据库进入全网秒级实时监控时代
  • 5
    应用上云新模式，Aliware 全家桶亮相杭州云栖大会
  • 6
    阿里云中间件是什么？
  • 7
    在家运维不用慌 | 盘点那些远程运维中的云上利器
  • 8
    消息中间件系列三、JMS和activeMQ的简单使用
  • 9
    中间件技术及双十一实践·软负载篇
  • 10
    分布式协调服务中间件ZooKeeper 入门（1）-ZK的介绍与特性
  • 1
    Golang 里的 AES、DES、3DES 加解密，支持 ECB、CBC 等多种模式组合
    18
  • 2
    道旅科技借助云消息队列 Kafka 版加速旅游大数据创新发展
    28
  • 3
    日志服务 SQL 引擎全新升级
    27
  • 4
    杭州铭师堂的云原生升级实践
    68
  • 5
    活动速递丨AI 原生应用开发实战营·上海站邀您参会
    39
  • 6
    MSE Nacos 2.3.2.0 发布，性能最多提升三倍，支持操作审计等安全特性
    50
  • 7
    邀您参加云原生高可用技术沙龙丨云上高可用体系构建：从理论到实践
    42
  • 8
    Nacos 3.0 Alpha 发布，在安全、泛用、云原生更进一步
    68
  • 9
    云上数据安全保护：敏感日志扫描与脱敏实践详解
    111
  • 10
    SpringCloud 应用 Nacos 配置中心注解
    123

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 快速上手使用Dubbo进行远程调用
  • Spring-cloud-stream-binder-rocketmq入门与实践
  • Rocketmq-spring入门与实践
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
    • 下一篇
    手把手教你白嫖阿里云服务器(免费领服务器)