专栏首页用户2442861的专栏ActiveMQ学习-Network connectors(1)

ActiveMQ学习-Network connectors(1)

http://blog.csdn.net/xiajun07061225/article/details/47068451

本文为network connectors的static connector学习笔记。

Network connectors

broker网络能够创建多个相互连接的ActiveMq实例组成的簇,以应对更加复杂的消息场景。Network connectors提供了broker之间的通信。 默认情况下,network connector是单向通道,它只会把收到的消息投递给与之建立连接的另一个broker。这通常称为forwarding bridge。ActiveMQ也支持双向通道,即duplex connector。下图是一个包含了这两者的复杂网络。

Network connector的XML配置如下:

[html] view plain copy

print?

  1. <networkConnectors>
  2. <networkConnector name="default-nc" uri="multicast://default"/>
  3. </networkConnectors>

一个重要的概念-discovery discovery:是一个检测远程broker服务的进程。client通常需要感知所有的broker。broker,需要感知其他存在的broker,以建立broker的网络。 当我们想配置一个broker网络时,首要问题是:我们知道每个broker的准确地址吗?如果是,可以以静态的方式配置,将客户端连接到提前定义好的broker URI,这在你想完全控制所有资源的生产环境中比较常见。 如果客户端以及broker相互不知道彼此的地址,那么必须使用一种discovery机制来发现已有的broker。这种设置在开发环境下比较常见,易于配置和维护。

static network

概念介绍

只要我们知道了想要使用的broker的地址,就可以使用static配置方式。

Static connector

用来创建网络中多个broker的静态配置。协议使用组合URI,即URI中包含其他URI。格式如下: static:(uri1,uri2,uri3,...) ?key=value XML中配置示例:

[html] view plain copy

print?

  1. <networkConnectors>
  2. <networkConnector name="local network"
  3. uri="static://(tcp://remotehost1:61616,tcp://remotehost2:61616)"/>
  4. </networkConnectors>

程序实例

为了更好的理解,可以通过一个发布者-订阅者的例子来进行说明。(demo来自ActiveMQ in action上的例子) 这个例子使用下图所示的broker拓扑结构:

BrokerA与brokerB单向相连,当生产者把消息发送给brokerA时,他们会被投递给有订阅需求的broker。这个时候,会被brokerA投递给brokerB。 详细代码如下。 brokerB配置(brokerB.xml):

[html] view plain copy

print?

  1. <beans
  2. xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:amq="http://activemq.org/config/1.0"
  4. xmlns:broker="http://activemq.apache.org/schema/core"
  5. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd  
  7.   http://activemq.org/config/1.0 http://activemq.apache.org/schema/activemq-core.xsd  
  8.   http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd  
  9.   http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
  10. <!-- Allows us to use system properties as variables in this configuration file -->
  11. <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  12. <!-- 定义一个broker -->
  13. <broker xmlns="http://activemq.apache.org/schema/core" brokerName="BrokerB" dataDirectory="${activemq.base}/data">
  14. <!-- The transport connectors ActiveMQ will listen to -->
  15. <transportConnectors>
  16. <transportConnector name="openwire" uri="tcp://localhost:61617" />
  17. </transportConnectors>
  18. </broker>
  19. </beans>

brokerA配置(brokerA.xml):

[html] view plain copy

print?

  1. <beans
  2. xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:amq="http://activemq.org/config/1.0"
  4. xmlns:broker="http://activemq.apache.org/schema/core"
  5. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd  
  7.   http://activemq.org/config/1.0 http://activemq.apache.org/schema/activemq-core.xsd  
  8.   http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd  
  9.   http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
  10. <!-- Allows us to use system properties as variables in this configuration file -->
  11. <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  12. <broker xmlns="http://activemq.apache.org/schema/core" brokerName="BrokerA" dataDirectory="${activemq.base}/data">
  13. <!-- The transport connectors ActiveMQ will listen to -->
  14. <transportConnectors>
  15. <transportConnector name="openwire" uri="tcp://localhost:61616" />
  16. </transportConnectors>
  17. <!-- 定义一个network连接器,连接到其他broker -->
  18. <networkConnectors>
  19. <networkConnector uri="static:(tcp://localhost:61617)" />
  20. </networkConnectors>
  21. </broker>
  22. </beans>

消息生产者(Publisher.java):

[java] view plain copy

print?

  1. /**
  2.  * XXX.com Inc.
  3.  * Copyright (c) 2004-2015 All Rights Reserved.
  4.  */
  5. package com.test.SpringTest.activemqinaction.ch4;  
  6. import java.util.Hashtable;  
  7. import java.util.Map;  
  8. import javax.jms.Connection;  
  9. import javax.jms.ConnectionFactory;  
  10. import javax.jms.Destination;  
  11. import javax.jms.JMSException;  
  12. import javax.jms.MapMessage;  
  13. import javax.jms.Message;  
  14. import javax.jms.MessageProducer;  
  15. import javax.jms.Session;  
  16. import org.apache.activemq.ActiveMQConnectionFactory;  
  17. import org.apache.activemq.command.ActiveMQMapMessage;  
  18. /**
  19.  * 消息产生者
  20.  * 
  21.  * @author jiangnan
  22.  * @version $Id: Publisher.java, v 0.1 2015年7月4日 下午4:48:48 jiangnan Exp $
  23.  */
  24. public class Publisher {  
  25. protected int                                MAX_DELTA_PERCENT = 1;  
  26. protected Map<String, Double>                LAST_PRICES       = new Hashtable<String, Double>();  
  27. protected static int                         count             = 10;  
  28. protected static int                         total;  
  29. protected static String                      brokerURL         = "tcp://localhost:61616";  
  30. protected static transient ConnectionFactory factory;  
  31. protected transient Connection               connection;  
  32. protected transient Session                  session;  
  33. protected transient MessageProducer          producer;  
  34. public Publisher() throws JMSException {  
  35.         factory = new ActiveMQConnectionFactory(brokerURL);  
  36.         connection = factory.createConnection();  
  37.         connection.start();  
  38.         session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
  39.         producer = session.createProducer(null);  
  40.     }  
  41. public void close() throws JMSException {  
  42. if (connection != null) {  
  43.             connection.close();  
  44.         }  
  45.     }  
  46. public static void main(String[] args) throws JMSException {  
  47.         String[] topics = { "topic1", "topic2" };  
  48.         Publisher publisher = new Publisher();  
  49. while (total < 1000) {  
  50. for (int i = 0; i < count; i++) {  
  51.                 publisher.sendMessage(topics);  
  52.             }  
  53.             total += count;  
  54.             System.out.println("Published '" + count + "' of '" + total + "' price messages");  
  55. try {  
  56.                 Thread.sleep(1000);  
  57.             } catch (InterruptedException x) {  
  58.             }  
  59.         }  
  60.         publisher.close();  
  61.     }  
  62. protected void sendMessage(String[] stocks) throws JMSException {  
  63. int idx = 0;  
  64. while (true) {  
  65.             idx = (int) Math.round(stocks.length * Math.random());  
  66. if (idx < stocks.length) {  
  67. break;  
  68.             }  
  69.         }  
  70.         String stock = stocks[idx];  
  71.         Destination destination = session.createTopic("STOCKS." + stock);  
  72.         Message message = createStockMessage(stock, session);  
  73.         System.out.println("Sending: " + ((ActiveMQMapMessage) message).getContentMap()  
  74.                            + " on destination: " + destination);  
  75.         producer.send(destination, message);  
  76.     }  
  77. protected Message createStockMessage(String stock, Session session) throws JMSException {  
  78.         Double value = LAST_PRICES.get(stock);  
  79. if (value == null) {  
  80.             value = new Double(Math.random() * 100);  
  81.         }  
  82. // lets mutate the value by some percentage
  83. double oldPrice = value.doubleValue();  
  84.         value = new Double(mutatePrice(oldPrice));  
  85.         LAST_PRICES.put(stock, value);  
  86. double price = value.doubleValue();  
  87. double offer = price * 1.001;  
  88. boolean up = (price > oldPrice);  
  89.         MapMessage message = session.createMapMessage();  
  90.         message.setStringProperty("stock", stock);//设置消息的属性
  91.         message.setString("stock", stock);  
  92.         message.setDouble("price", price);  
  93.         message.setDouble("offer", offer);  
  94.         message.setBoolean("up", up);  
  95. return message;  
  96.     }  
  97. protected double mutatePrice(double price) {  
  98. double percentChange = (2 * Math.random() * MAX_DELTA_PERCENT) - MAX_DELTA_PERCENT;  
  99. return price * (100 + percentChange) / 100;  
  100.     }  
  101. }  

消息订阅者(Consumer.java):

[java] view plain copy

print?

  1. /**
  2.  * XXX.com Inc.
  3.  * Copyright (c) 2004-2015 All Rights Reserved.
  4.  */
  5. package com.test.SpringTest.activemqinaction.ch4;  
  6. import javax.jms.Connection;  
  7. import javax.jms.ConnectionFactory;  
  8. import javax.jms.Destination;  
  9. import javax.jms.JMSException;  
  10. import javax.jms.MessageConsumer;  
  11. import javax.jms.Session;  
  12. import org.apache.activemq.ActiveMQConnectionFactory;  
  13. /**
  14.  * 消息消费者
  15.  * 
  16.  * @author jiangnan
  17.  * @version $Id: Consumer.java, v 0.1 2015年7月4日 下午4:37:48 jiangnan Exp $
  18.  */
  19. public class Consumer {  
  20. private static String                      brokerURL = "tcp://localhost:61617";  
  21. private static transient ConnectionFactory factory;  
  22. private transient Connection               connection;  
  23. private transient Session                  session;  
  24. public Consumer() throws JMSException {  
  25.         factory = new ActiveMQConnectionFactory(brokerURL);  
  26.         connection = factory.createConnection();  
  27.         connection.start();  
  28.         session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
  29.     }  
  30. public void close() throws JMSException {  
  31. if (connection != null) {  
  32.             connection.close();  
  33.         }  
  34.     }  
  35. public static void main(String[] args) throws JMSException {  
  36.         String[] topics = { "topic1", "topic2" };  
  37.         Consumer consumer = new Consumer();  
  38. for (String stock : topics) {  
  39.             Destination destination = consumer.getSession().createTopic("STOCKS." + stock);  
  40. //只接收部分消息的选择器
  41.             String selector = "stock = 'topic1'";  
  42.             MessageConsumer messageConsumer = consumer.getSession().createConsumer(destination,  
  43.                 selector);  
  44.             messageConsumer.setMessageListener(new Listener());  
  45.         }  
  46.     }  
  47. public Session getSession() {  
  48. return session;  
  49.     }  
  50. }  

消息监听器(Listener.java):

[java] view plain copy

print?

  1. /**
  2.  * XXX.com Inc.
  3.  * Copyright (c) 2004-2015 All Rights Reserved.
  4.  */
  5. package com.test.SpringTest.activemqinaction.ch4;  
  6. import java.text.DecimalFormat;  
  7. import javax.jms.MapMessage;  
  8. import javax.jms.Message;  
  9. import javax.jms.MessageListener;  
  10. /**
  11.  * 消息监听器
  12.  * 
  13.  * @author jiangnan
  14.  * @version $Id: Listener.java, v 0.1 2015年7月4日 下午4:40:25 jiangnan Exp $
  15.  */
  16. public class Listener implements MessageListener {  
  17. public void onMessage(Message message) {  
  18. try {  
  19.             MapMessage map = (MapMessage) message;  
  20.             String stock = map.getString("stock");  
  21. double price = map.getDouble("price");  
  22. double offer = map.getDouble("offer");  
  23. boolean up = map.getBoolean("up");  
  24.             DecimalFormat df = new DecimalFormat("#,###,###,##0.00");  
  25.             System.out.println(stock + "\t" + df.format(price) + "\t" + df.format(offer) + "\t"
  26.                                + (up ? "up" : "down"));  
  27.         } catch (Exception e) {  
  28.             e.printStackTrace();  
  29.         }  
  30.     }  
  31. }  

运行过程: 先启动brokerB: D:\apache-activemq-5.8.0\bin>activemq xbean:file:D:/code/test/SpringTest/src/main/resource/META-INF/spring/activemqinaction/ch4/brokerB.xml

再启动brokerA: D:\apache-activemq-5.8.0\bin>activemq xbean:file:D:/code/test/SpringTest/src/main/resource/META-INF/spring/activemqinaction/ch4/brokerA.xml

可以看到brokerA和brokerB建立连接成功。

然后启动消费者和生产者。在控制台可以观察到消息发送和接收的日志。

Static protocol的使用场景

考虑这样一种场景,多个远程客户端与本地的一个broker建立连接。考虑到每个远程区域的客户端数量,与本地broker关联的连接数会很多。这会给网络带来不必要的负担。为了减小连接数,可以在每个远程区域设置一个broker,然后在远程broker和本地broker之间建立静态链接。这不仅会减小网络连接数,也会提高客户端工作效率。同时也会减少延时,降低等待客户端的时间。

Failover connector

概念介绍

在之前的例子中,客户端仅仅连接到一个特定的broker。如果连接失败或中断,怎么办?有两个选择:客户端会消亡,或者是重新连接到这个broker或者其他broker然后恢复工作。failover可以实现自动重连。有两种方式可以为客户端提供可以连接的broker,一是提供一个静态列表,二是使用动态发现机制。

静态列表配置格式如下: failover:(uri1,...,uriN)?key=value 或者 failover:uri1,...,uriN 默认情况下,会随机挑选可使用的connector。如果连接失败,会挑选另一个URI尝试建立连接。默认配置实现了重连延迟逻辑:第一次重试失败后延迟10ms,之后延迟时间都在前一次的时间之上加倍,直至30000ms。 使用场景 强烈推荐为所有客户端使用failover,即时客户端只会连接到一个broker。这样做的好处是,broker挂掉之后不用手动重新连接,broker恢复后客户端会自动进行重连。简单的利用ActiveMQ的这一特性可以使应用更加稳定。

参考资料:

《ActiveMQ in Action》

附:demo的pom.xml配置

[html] view plain copy

print?

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3. <modelVersion>4.0.0</modelVersion>
  4. <groupId>com.test</groupId>
  5. <artifactId>SpringTest</artifactId>
  6. <version>0.0.1-SNAPSHOT</version>
  7. <packaging>jar</packaging>
  8. <name>SpringTest</name>
  9. <url>http://maven.apache.org</url>
  10. <properties>
  11. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  12. <org.springframework.version>3.1.2.RELEASE</org.springframework.version>
  13. </properties>
  14. <dependencies>
  15. <dependency>
  16. <groupId>junit</groupId>
  17. <artifactId>junit</artifactId>
  18. <version>4.11</version>
  19. <scope>test</scope>
  20. </dependency>
  21. <!-- JMX -->
  22. <dependency>
  23. <groupId>com.sun.jdmk</groupId>
  24. <artifactId>jmxtools</artifactId>
  25. <version>1.2.1</version>
  26. </dependency>
  27. <!-- ActiveMQ -->
  28. <dependency>
  29. <groupId>org.apache.activemq</groupId>
  30. <artifactId>activemq-all</artifactId>
  31. <version>5.6.0</version>
  32. </dependency>
  33. <dependency>
  34. <groupId>org.apache.activemq</groupId>
  35. <artifactId>activemq-core</artifactId>
  36. <version>5.5.0</version>
  37. </dependency>
  38. <!-- xbean (ActiveMQ dependency) -->
  39. <dependency>
  40. <groupId>org.apache.xbean</groupId>
  41. <artifactId>xbean-spring</artifactId>
  42. <version>3.7</version>
  43. </dependency>
  44. <!-- Spring -->
  45.     <!--  
  46.         Core utilities used by other modules.  
  47.         Define this if you use Spring Utility APIs (org.springframework.core.*/org.springframework.util.*)  
  48.     -->
  49. <dependency>
  50. <groupId>org.springframework</groupId>
  51. <artifactId>spring-core</artifactId>
  52. <version>${org.springframework.version}</version>
  53. </dependency>
  54.     <!--  
  55.         Expression Language (depends on spring-core)  
  56.         Define this if you use Spring Expression APIs (org.springframework.expression.*)  
  57.     -->
  58. <dependency>
  59. <groupId>org.springframework</groupId>
  60. <artifactId>spring-expression</artifactId>
  61. <version>${org.springframework.version}</version>
  62. </dependency>
  63.     <!--   
  64.         Bean Factory and JavaBeans utilities (depends on spring-core)  
  65.         Define this if you use Spring Bean APIs (org.springframework.beans.*)   
  66.     -->
  67. <dependency>
  68. <groupId>org.springframework</groupId>
  69. <artifactId>spring-beans</artifactId>
  70. <version>${org.springframework.version}</version>
  71. </dependency>
  72.     <!--  
  73.         Aspect Oriented Programming (AOP) Framework (depends on spring-core, spring-beans)  
  74.         Define this if you use Spring AOP APIs (org.springframework.aop.*)  
  75.     -->
  76. <dependency>
  77. <groupId>org.springframework</groupId>
  78. <artifactId>spring-aop</artifactId>
  79. <version>${org.springframework.version}</version>
  80. </dependency>
  81.     <!--  
  82.         Application Context (depends on spring-core, spring-expression, spring-aop, spring-beans)   
  83.         This is the central artifact for Spring's Dependency Injection Container and is generally always defined  
  84.     -->
  85. <dependency>
  86. <groupId>org.springframework</groupId>
  87. <artifactId>spring-context</artifactId>
  88. <version>${org.springframework.version}</version>
  89. </dependency>
  90.     <!--  
  91.         Various Application Context utilities, including EhCache, JavaMail, Quartz, and Freemarker integration  
  92.         Define this if you need any of these integrations  
  93.     -->
  94. <dependency>
  95. <groupId>org.springframework</groupId>
  96. <artifactId>spring-context-support</artifactId>
  97. <version>${org.springframework.version}</version>
  98. </dependency>
  99.     <!--  
  100.         Transaction Management Abstraction (depends on spring-core, spring-beans, spring-aop, spring-context)  
  101.         Define this if you use Spring Transactions or DAO Exception Hierarchy  
  102.         (org.springframework.transaction.*/org.springframework.dao.*)  
  103.     -->
  104. <dependency>
  105. <groupId>org.springframework</groupId>
  106. <artifactId>spring-tx</artifactId>
  107. <version>${org.springframework.version}</version>
  108. </dependency>
  109.     <!--  
  110.         JDBC Data Access Library (depends on spring-core, spring-beans, spring-context, spring-tx)  
  111.         Define this if you use Spring's JdbcTemplate API (org.springframework.jdbc.*)  
  112.     -->
  113. <dependency>
  114. <groupId>org.springframework</groupId>
  115. <artifactId>spring-jdbc</artifactId>
  116. <version>${org.springframework.version}</version>
  117. </dependency>
  118.     <!--  
  119.         Object-to-Relation-Mapping (ORM) integration with Hibernate, JPA, and iBatis.  
  120.         (depends on spring-core, spring-beans, spring-context, spring-tx)  
  121.         Define this if you need ORM (org.springframework.orm.*)  
  122.     -->
  123. <dependency>
  124. <groupId>org.springframework</groupId>
  125. <artifactId>spring-orm</artifactId>
  126. <version>${org.springframework.version}</version>
  127. </dependency>
  128.     <!--  
  129.         Object-to-XML Mapping (OXM) abstraction and integration with JAXB, JiBX, Castor, XStream, and XML Beans.  
  130.         (depends on spring-core, spring-beans, spring-context)  
  131.         Define this if you need OXM (org.springframework.oxm.*)  
  132.     -->
  133. <dependency>
  134. <groupId>org.springframework</groupId>
  135. <artifactId>spring-oxm</artifactId>
  136. <version>${org.springframework.version}</version>
  137. </dependency>
  138.     <!--  
  139.         Web application development utilities applicable to both Servlet and Portlet Environments  
  140.         (depends on spring-core, spring-beans, spring-context)  
  141.         Define this if you use Spring MVC, or wish to use Struts, JSF, or another web framework with Spring (org.springframework.web.*)  
  142.     -->
  143. <dependency>
  144. <groupId>org.springframework</groupId>
  145. <artifactId>spring-web</artifactId>
  146. <version>${org.springframework.version}</version>
  147. </dependency>
  148.     <!--  
  149.         Spring MVC for Servlet Environments (depends on spring-core, spring-beans, spring-context, spring-web)  
  150.         Define this if you use Spring MVC with a Servlet Container such as Apache Tomcat (org.springframework.web.servlet.*)  
  151.     -->
  152. <dependency>
  153. <groupId>org.springframework</groupId>
  154. <artifactId>spring-webmvc</artifactId>
  155. <version>${org.springframework.version}</version>
  156. </dependency>
  157.     <!--  
  158.         Spring MVC for Portlet Environments (depends on spring-core, spring-beans, spring-context, spring-web)  
  159.         Define this if you use Spring MVC with a Portlet Container (org.springframework.web.portlet.*)  
  160.     -->
  161. <dependency>
  162. <groupId>org.springframework</groupId>
  163. <artifactId>spring-webmvc-portlet</artifactId>
  164. <version>${org.springframework.version}</version>
  165. </dependency>
  166.     <!--  
  167.         Support for testing Spring applications with tools such as JUnit and TestNG  
  168.         This artifact is generally always defined with a 'test' scope for the integration testing framework and unit testing stubs  
  169.     -->
  170. <dependency>
  171. <groupId>org.springframework</groupId>
  172. <artifactId>spring-test</artifactId>
  173. <version>${org.springframework.version}</version>
  174. <scope>test</scope>
  175. </dependency>
  176. <dependency>
  177. <groupId>org.springframework</groupId>
  178. <artifactId>spring-jms</artifactId>
  179. <version>3.1.1.RELEASE</version>
  180. </dependency>
  181. </dependencies>
  182. </project>

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Idea SpringMVC+Spring+MyBatis+Maven整合

    http://blog.csdn.net/u011403655/article/details/46843331

    bear_fish
  • Spirng+SpringMVC+Maven+Mybatis+MySQL项目搭建

    http://www.kancloud.cn/digest/javaframe/125575

    bear_fish
  • 基于Spring + Spring MVC + Mybatis 高性能web构建

    http://blog.csdn.net/zoutongyuan/article/details/41379851#comments

    bear_fish
  • Spring 中的AOP的通知类型的示例(xml)

    版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。

    suveng
  • 使用idea2017搭建SSM框架

    我这里列出的是搭建完了之后所有的目录和文件,诸位先把目录文件建起来,然后我在给出文件内容

    Java学习
  • SpringCloud基础+基本框架

    SpringCloud极大的简化了分布式系统的开发,实现了微服务的快速部署和灵活应用

    用户3112896
  • Spring Boot + Spring Cloud 实现权限管理系统

    1. 使用 RestTemplate 进行服务调用,可以通过 Ribbon 注解 RestTemplate 模板,使其拥有负载均衡的功能。

    朝雨忆轻尘
  • 什么是Spring Boot

    logging.config= # Location of the logging configuration file. For instance class...

    海仔
  • Spring-Boot全局配置文件

    用户5927264
  • 大数据技术之_24_电影推荐系统项目_08_项目总结及补充

    一 数据加载服务1、目标2、步骤二 离线推荐服务2.1 基于统计性算法1、目标2、步骤2.2 基于隐语义模型(LFM)的协同过滤推荐算法(ALS)1、目标2、步...

    黑泽君

扫码关注云+社区

领取腾讯云代金券