Camel:构建基于消息的应用程序

这是一篇长文章,包含三个单独的主题:
  • Java的Apache Camel入门
  • 使用CamelRunner改善路线的启动
  • 使用Camel构建基于消息的应用程序

但是,由于我准备了包含所有这些材料的camel-demo-1.0.0-SNAPSHOT-project.zip ,因此我认为将它们组合并整体呈现会更容易。

Java的Apache Camel入门

用很少的Groovy行尝试Camel是一回事,但是用Java进行全面的项目则是另一回事。 今天,我将向您展示如何通过基于Maven的项目在Apache Camel上开始工作。 您也可以使用提供的camel-demo作为项目模板来启动您自己的Apache Camel项目。 您只需要重命名Java包,并重命名pom的组和工件ID即可满足您的需要。

准备具有Camel依赖关系的基于Maven的项目

解压缩camel-demo项目源代码,您将看到基本的目录布局。

camel-demo+- bin+- config+- data+- src+- pom.xml+- README.txt

使此演示成为基于Camel的项目的原因只是pom.xml的声明。 让我们看一下文件及其依赖项。

<?xml version='1.0' encoding='UTF-8'?>
<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/maven-v4_0_0.xsd'><modelVersion>4.0.0</modelVersion><groupId>deng.cameldemo</groupId><artifactId>camel-demo</artifactId><version>1.0.0-SNAPSHOT</version><packaging>jar</packaging><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><slf4j.version>1.6.6</slf4j.version><camel.version>2.10.1</camel.version></properties><build><plugins><plugin><artifactId>maven-compiler-plugin</artifactId><version>2.3.2</version><configuration><source>1.6</source><target>1.6</target></configuration></plugin><plugin><artifactId>maven-assembly-plugin</artifactId><version>2.3</version><configuration><descriptorRefs><descriptorRef>project</descriptorRef><descriptorRef>jar-with-dependencies</descriptorRef></descriptorRefs></configuration><executions><execution><id>make-assembly</id><phase>package</phase><goals><goal>single</goal></goals></execution></executions></plugin></plugins></build><dependencies><!-- Unit testing lib --><dependency><groupId>junit</groupId><artifactId>junit-dep</artifactId><version>4.10</version><scope>test</scope></dependency><dependency><groupId>org.hamcrest</groupId><artifactId>hamcrest-library</artifactId><version>1.2.1</version><scope>test</scope></dependency><!-- Logging lib --><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>${slf4j.version}</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>${slf4j.version}</version><scope>runtime</scope><optional>true</optional></dependency><!-- Apache Commons lib --><dependency><groupId>commons-lang</groupId><artifactId>commons-lang</artifactId><version>2.6</version></dependency><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.0.1</version></dependency><!-- Apache Camel --><dependency><groupId>org.apache.camel</groupId><artifactId>camel-core</artifactId><version>${camel.version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-spring</artifactId><version>${camel.version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-groovy</artifactId><version>${camel.version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-jackson</artifactId><version>${camel.version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-mina</artifactId><version>${camel.version}</version></dependency></dependencies></project>

pom.xml对基于Java的应用程序进行贴花处理,它将生成jar 。 它需要最少的JDK 6或更高版本。 除了用于单元测试的典型junithamcrest之外,我还添加了slf4j进行日志记录。 我也将Apache的commons-lang/io夫妇添加到了项目中。 我认为这些是任何基于Java的应用程序都应使用的基本设置。

我声明的maven-assembly-plugin仅用于此演示打包目的,您可以更改或删除以适合您自己的项目需求。

对于骆驼依赖性,您将需要最少的camel-core来构建路线。 然后,您可以添加计划在项目中使用的任何其他组件。 我添加了以下内容来构建基于消息的典型应用程序开发:

  1. camel-spring –我们希望可以选择在xml文件中声明骆驼路线作为配置。 有关camel-demo/config请参见camel-demo/config目录。
  2. camel-jackson –我们希望将应用程序中的消息传递数据处理为JSON格式。
  3. camel-mina -我们想通过TCP套接字在整个网络上发送消息传递数据。
  4. camel-groovy – [可选]我们希望即使在xml配置内部也可以添加动态脚本来路由。 这对于调试和POC非常有用。

请注意,由于我们使用了多个骆驼组件依赖关系,因此我选择设置Maven属性${camel.version}以便在升级Camel时,将pom.xml文件维护在一个位置更容易。

您应该能够进入项目目录并运行mvn compile来验证项目。 它应该编译没有错误。

使用CamelRunner改善路线的启动

准备好项目pom.xml文件后,就可以开始创建骆驼路线来处理自己的业务逻辑了。 在我们太兴奋之前,让我们尝试一个简单的HelloRoute ,看看它如何工作以及如何首先运行它。 这是src/main/java/deng/cameldemo/HelloRoute.java的路由定义代码。

package deng.cameldemo;import org.apache.camel.builder.RouteBuilder;public class HelloRoute extends RouteBuilder {@Overridepublic void configure() throws Exception {from('timer://helloTimer?period=3000').to('log:' + getClass().getName());}
}


体验骆驼之旅

要查看上面的内容,我们需要将其添加到CamelContext并启动上下文。 对于Java独立程序,我们将在Main类中编写此安装代码。 Camel实际上带有org.apache.camel.main.MainSupport抽象类,您可以用来扩展自己的Main 。 但是,我认为如果Camel提供一个可以像这样运行的CamelRunner会更好。

$ java CamelRunner deng.cameldemo.HelloRoute

这样的CamelRunner将非常具有用户友好性,并且可重复使用,所以我就是这样做的。 我这样写:

package deng.cameldemo;import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;/** * A main program to start Camel and run as a server using RouteBuilder class names or * Spring config files.* * <p>Usage:* * java deng.cameldemo.CamelRunner deng.cameldemo.HelloRoute* * or* * java -Dspring=true deng.cameldemo.CamelRunner /path/to/camel-spring.xml* * @author Zemian Deng*/
public class CamelRunner {public static void main(String[] args) throws Exception {CamelRunner runner = new CamelRunner();runner.run(args);}private static Logger logger = LoggerFactory.getLogger(CamelRunner.class);public void run(String[] args) throws Exception {if (Boolean.parseBoolean(System.getProperty('spring', 'false')))runWithSpringConfig(args);elserunWithCamelRoutes(args);// Wait for user to hit CRTL+C to stop the servicesynchronized(this) {this.wait();}}private void runWithSpringConfig(String[] args) {final ConfigurableApplicationContext springContext = new FileSystemXmlApplicationContext(args);// Register proper shutdown.Runtime.getRuntime().addShutdownHook(new Thread() { @Overridepublic void run() {try {springContext.close();logger.info('Spring stopped.');} catch (Exception e) {logger.error('Failed to stop Spring.', e);}}});// Start springlogger.info('Spring started.');}private void runWithCamelRoutes(String[] args) throws Exception {final CamelContext camelContext = new DefaultCamelContext();        // Register proper shutdown.Runtime.getRuntime().addShutdownHook(new Thread() { @Overridepublic void run() {try {camelContext.stop();logger.info('Camel stopped for {}', camelContext);} catch (Exception e) {logger.error('Failed to stop Camel.', e);}}});// Added RouteBuilder from argsfor (String className : args) {Class<?> cls = Class.forName(className);if (RouteBuilder.class.isAssignableFrom(cls)) {Object obj = cls.newInstance();RouteBuilder routeBuilder = (RouteBuilder)obj;camelContext.addRoutes(routeBuilder);} else {throw new RuntimeException('Unable to add Camel RouteBuilder ' + className);}}// Start camelcamelContext.start();logger.info('Camel started for {}', camelContext);}
}

为了帮助您运行主类,我在项目的bin目录下提供了一个run-java包装程序脚本,以便您无需设置类路径即可快速对其进行测试。

$ mvn package
$ bin/run-java deng.cameldemo.CamelRunner deng.cameldemo.HelloRoute

您将看到该程序将在DefaultCamelContext加载HelloRoute并将其作为服务器启动。 HelloRoute本身将生成3秒钟的计时器消息,并将其发送到记录器,该记录器应打印在控制台屏幕上。 这将一直持续下去,直到您按CTRL+C结束它为止。

注意:您只需要调用一次mvn package命令,这样它将打包所有依赖项jar,以便run-java自动检测到它们。 如果您在package阶段不打算使用maven-assembly-plugin ,那么显式使用mvn dependency:copy-dependencies命令也可以正常工作。

进行Camel测试,第2部分:使用Spring xml配置运行Camel

上面的HelloRoute示例将仅提供通过使用组件URI形成的路由定义。 如果我们可以以声明的方式配置路由,以便我们可以更改路由而无需重新编译类文件,那将是很好的。 这将非常方便,特别是如果您不熟悉每个组件的选项并且想探索并尝试的话。 好吧,这就是camel-spring用途。 除了为您提供在xml配置文件中加载路由的选项之外,它还提供了一种非常灵活的方式来在Spring IoC容器中注册自定义服务/处理器Bean。

如果您是一位敏锐的读者,您会在上面的CamelRunner代码中注意到它还有一个额外的runWithSpringConfig部分。 因此, CamelRunner实际上可以引导任何Spring xml文件并作为服务器启动上下文。 您可以这样使用它:

$ bin/run-java deng.cameldemo.CamelRunner -Dspring=true config/hellocamel-spring.xml

config/hellocamel-spring.xml等效于我们的HelloRoute代码,但形式为Spring xml:

<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.xsdhttp://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd'><camelContext id='helloCamel' xmlns='http://camel.apache.org/schema/spring'><route><from uri='timer://jdkTimer?period=3000'/><to uri='log://deng.cameldemo.HelloCamel'/></route></camelContext></beans>

这样就无需编译/重新编译HelloRoute来定义要运行的Camel路由。

使用Camel构建基于消息的应用程序

为了向您展示更实际的演示,我将进一步向您展示如何设置Camel来处理基于消息的应用程序。 在许多IT商店中,通常都有一台服务器将消息数据作为输入并进行处理。 一个实际的用例是获取任何JSON格式的消息并将其转换为对象并进行处理。 要在Camel中做到这一点,您想要构建的是一条路由,该路由将从TCP端口获取输入消息,然后使用可能具有的任何业务逻辑在管道流中对其进行处理。 您将把路由作为服务器运行,然后客户端可以使用任何方式将消息提交到TCP端口。 客户端甚至可能是另一个瘦的Camel客户端应用程序,也可以提交数据。 让我告诉您如何开始。

用骆驼路线写服务器端代码

服务器端将需要一个路由来侦听TCP端口,而这是由camel-mina组件提供的。 第一步是您需要一条路线。

package deng.cameldemo;import org.apache.camel.builder.RouteBuilder;public class TcpMsgRoute extends RouteBuilder {@Overridepublic void configure() throws Exception {String port = System.getProperty('port', '12345');from('mina:tcp://localhost:' + port + '?sync=false').to('log:' + getClass().getName());}
}

然后,下一步就完成了! 没办法,您的意思是服务器就这些了吗? 难以置信? 好吧,让我们尝试一下

$ bin/run-java deng.cameldemo.CamelRunner deng.cameldemo.TcpMsgRoute -Dport=12345
15:21:41 main INFO  org.apache.camel.impl.DefaultCamelContext:1391 | Apache Camel 2.10.1 (CamelContext: camel-1) is starting
15:21:41 main INFO  org.apache.camel.management.ManagementStrategyFactory:43 | JMX enabled.
15:21:42 main INFO  org.apache.camel.impl.converter.DefaultTypeConverter:45 | Loaded 172 type converters
15:21:42 main INFO  org.apache.camel.component.mina.MinaConsumer:59 | Binding to server address: localhost/127.0.0.1:12345 using acceptor: org.apache.mina.transport.socket.nio.SocketAcceptor@2ffad8fe
15:21:42 main INFO  org.apache.camel.impl.DefaultCamelContext:2045 | Route: route1 started and consuming from: Endpoint[mina://tcp://localhost:12345?sync=true]
15:21:42 main INFO  org.apache.camel.management.DefaultManagementLifecycleStrategy:859 | StatisticsLevel at All so enabling load performance statistics
15:21:42 main INFO  org.apache.camel.impl.DefaultCamelContext:1426 | Total 1 routes, of which 1 is started.
15:21:42 main INFO  org.apache.camel.impl.DefaultCamelContext:1427 | Apache Camel 2.10.1 (CamelContext: camel-1) started in 0.505 seconds
15:21:42 main INFO  deng.cameldemo.CamelRunner:93 | Camel started for CamelContext(camel-1)

瞧! 服务器已启动,正在等待用户通过端口12345发送消息。 几行代码还不错。

用Camel ProducerTemplate编写客户端代码

由于我们的服务器公开了一个TCP端口并接收任何文本内容消息,因此您可以创建任何能够写入TCP套接字的客户端。 在这里,我将向您展示如何使用Camel编写瘦客户机。

package deng.cameldemo.client;import java.io.FileReader;
import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.commons.io.IOUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class TcpMsgSender {public static void main(String[] args) throws Exception {TcpMsgSender runner = new TcpMsgSender();runner.run(args);}private static Logger logger = LoggerFactory.getLogger(TcpMsgSender.class);public void run(String[] args) throws Exception {String fileName = args.length > 0 ? args[0] : 'data/msg.txt';String[] hostPort = (args.length > 1 ? args[1] : 'localhost:12345').split(':');String host = hostPort[0];String port = hostPort.length > 1 ? hostPort[1] : '12345';logger.info('Sending tcp message {} to host={}, port={}', new Object[]{ fileName, host, port});String text = IOUtils.toString(new FileReader(fileName));logger.debug('File size={}', text.length());CamelContext camelContext = new DefaultCamelContext();ProducerTemplate producer = camelContext.createProducerTemplate();producer.sendBody('mina:tcp://' + host + ':' + port + '?sync=false', text);logger.info('Message sent.');}
}

TcpMsgSender可以将任何文本文件发送到您的服务器端点。 在服务器运行时尝试以下操作:

$ bin/run-java deng.cameldemo.client.TcpMsgSender data/test-msg.json localhost:12345
15:22:35 main INFO  deng.cameldemo.client.TcpMsgSender:24 | Sending tcp message data/test-msg.json to host=localhost, port=12345
15:22:35 main DEBUG deng.cameldemo.client.TcpMsgSender:27 | File size=47
15:22:35 main INFO  org.apache.camel.impl.converter.DefaultTypeConverter:45 | Loaded 172 type converters
15:22:35 main INFO  org.apache.camel.management.ManagementStrategyFactory:43 | JMX enabled.
15:22:35 main INFO  deng.cameldemo.client.TcpMsgSender:32 | Message sent.

您应该能够从服务器控制台输出中验证它是否收到了消息。 我发送的味精在data/test-msg.json ,其中包含以下简单文本:

{ 'firstName' : 'Zemian', 'lastName' : 'Deng' }

请注意,我们的服务器仅接收纯文本并将其记录。 接下来,我们将讨论如何处理消息。

使用Camel和Spring xml配置以JSON格式处理消息数据

您认为服务器代码从上面很容易,请再猜一次。 实际上,您可以仅用一些简单的xml行替换TcpMsgRoute

<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.xsdhttp://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd'><camelContext id='tcpMsgServer' xmlns='http://camel.apache.org/schema/spring'><route><from uri='mina:tcp://localhost:12345?sync=false'/><to uri='log://deng.cameldemo.TcpMsgServer'/></route></camelContext></beans>

将其另存为config/tcpmsgserver-spring.xml 。 然后重新运行服务器,您应该获得与上面相同的结果。

$ bin/run-java deng.cameldemo.CamelRunner -Dspring=true config/tcpmsgserver-spring.xml

现在让我们改进上面的xml,以进一步处理JSON消息数据。 我们希望将纯文本转换为Java对象,然后由自定义bean处理。 为此,我们首先需要在路线中添加解组组件。 这就是camel-jackson发挥作用的地方。 在我们的演示中,解组步骤会将JSON文本转换为java.util.Map ,然后将其传递给名为myMsgProcessor的处理器bean。 让我们创建一个名为config/tcpmsgserver-json-spring.xml的新xml文件,如下所示。

<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.xsdhttp://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd'><camelContext id='tcpMsgServer' xmlns='http://camel.apache.org/schema/spring'><route><from uri='mina:tcp://localhost:12345?sync=false'/><to uri='log://deng.cameldemo.TcpMsgServer'/><unmarshal><json library='Jackson'/></unmarshal><to uri='bean:myMsgProcessor?method=process'/></route></camelContext><bean id='myMsgProcessor' class='deng.cameldemo.MyMsgProcessor'></bean></beans>

myMsgProcessor是一个Spring bean,我们提供了自定义逻辑代码来处理数据。 至此,我们有一个完整的Java对象要操作。 处理器的内容可以是具有URI中指定的方法名称的任何POJO。 这是一个示例:

package deng.cameldemo;import org.apache.camel.builder.RouteBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Map;public class MyMsgProcessor {private static Logger logger = LoggerFactory.getLogger(MyMsgProcessor.class);public void process(Map<String, String> data) {logger.info('We should slice and dice the data: ' + data);}
}

尝试使用上面的新xml文件重新运行服务器,您应该能够重新调用相同的客户端命令进行测试。 这是服务器的示例输出:

$ bin/run-java deng.cameldemo.CamelRunner -Dspring=true config/tcpmsgserver-json-spring.xml
17:05:25 main INFO  org.springframework.context.support.FileSystemXmlApplicationContext:456 | Refreshing org.springframework.context.support.FileSystemXmlApplicationContext@4200309: startup date [Sat Sep 15 17:05:25 EDT 2012]; root of context hierarchy
17:05:25 main INFO  org.springframework.beans.factory.xml.XmlBeanDefinitionReader:315 | Loading XML bean definitions from file [/Users/zemian/projects/sandbox/camel-demo/config/tcpmsgserver-json-spring.xml]
17:05:27 main INFO  org.springframework.beans.factory.support.DefaultListableBeanFactory:557 | Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@27b75165: defining beans [template,consumerTemplate,tcpMsgServer:beanPostProcessor,tcpMsgServer,myMsgProcessor]; root of factory hierarchy
17:05:27 main INFO  org.apache.camel.spring.SpringCamelContext:1391 | Apache Camel 2.10.1 (CamelContext: tcpMsgServer) is starting
17:05:27 main INFO  org.apache.camel.management.ManagementStrategyFactory:43 | JMX enabled.
17:05:27 main INFO  org.apache.camel.impl.converter.DefaultTypeConverter:45 | Loaded 172 type converters
17:05:28 main INFO  org.apache.camel.component.mina.MinaConsumer:59 | Binding to server address: localhost/127.0.0.1:12345 using acceptor: org.apache.mina.transport.socket.nio.SocketAcceptor@5a3cae4a
17:05:28 main INFO  org.apache.camel.spring.SpringCamelContext:2045 | Route: route1 started and consuming from: Endpoint[mina://tcp://localhost:12345?sync=false]
17:05:28 main INFO  org.apache.camel.management.DefaultManagementLifecycleStrategy:859 | StatisticsLevel at All so enabling load performance statistics
17:05:28 main INFO  org.apache.camel.spring.SpringCamelContext:1426 | Total 1 routes, of which 1 is started.
17:05:28 main INFO  org.apache.camel.spring.SpringCamelContext:1427 | Apache Camel 2.10.1 (CamelContext: tcpMsgServer) started in 0.695 seconds
17:05:28 main INFO  deng.cameldemo.CamelRunner:61 | Spring started.
17:05:35 Camel (tcpMsgServer) thread #3 - MinaThreadPool INFO  deng.cameldemo.TcpMsgServer:96 | Exchange[ExchangePattern:InOnly, BodyType:String, Body:{ 'firstName' : 'Zemian', 'lastName' : 'Deng' }]
17:05:35 Camel (tcpMsgServer) thread #3 - MinaThreadPool INFO  deng.cameldemo.MyMsgProcessor:11 | We should slice and dice the data: {lastName=Deng, firstName=Zemian}

请注意,骆驼会自动转换您的路线中的数据格式! 我们的客户端仅以JSON格式发送纯文本,但是当服务器收到纯文本时,它将使用Jackson库将其解组,然后将其转换为Java Map对象。 然后,它将map对象传递到我们的处理器bean中。 另外,在此演示中,我选择使用通用的java.util.Map作为处理器方法参数(这是JSON unmarshal的输出),但是您可以轻松定义自己的业务数据类型,例如MyCustomerData 。 这显示了Camel的强大功能,因为您无需在流程中推送消息,而只需担心将“处理器”编写为POJO。 骆驼将组件“粘合”在一起以形成一条路线,并通过管道流携带消息数据。

同样,当您在一个或多个处理器中编写业务逻辑时,最好将POJO逻辑限制为尽可能小的单位。 当您这样做时,则可以最大程度地提高处理器的可重用性。 您制作的POJO较大,并且混合了许多业务逻辑,因此也很难进行测试。 因此,我建议您在开发这些处理器bean时,尝试将它们视为乐高积木-小POJO。 您想让骆驼定义路线并将LEGO块粘合在一起。 一旦习惯了这种thicking的习惯,便可以更有效地使用Camel来解决许多域问题。

好了,今天的人们就这些了。 我希望您喜欢骑骆驼。

祝您编程愉快,别忘了分享!

参考: A程序员杂志博客上的JCG合作伙伴 Zemian Deng 使用Camel构建基于消息的应用程序 。


翻译自: https://www.javacodegeeks.com/2012/09/camel-build-message-based-application.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/371499.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

android 网易item广告,Android仿网易严选商品详情页

仿照网易严选商品详情页面&#xff0c;整个页面分为两个部分&#xff0c;上面一部分是Native的ScrollView&#xff0c;下面一部分则是WebView&#xff0c;其目的是为了可以进行分步加载。滑动到ScrollView底部时&#xff0c;继续向上拖动&#xff0c;可以加载下面的WebView部分…

freemarker,数字,日期,布尔值常用的函数

${3.4?floor} ${3.4?ceiling} ${3.45?round} ${3.45?rtf} ${3.458?string("0.##")} ${3.42?string.percent} ${3.42?string.currency} ${date?string("yyyy-MM-dd")} ${date?date} ${date?time} ${date?datetime}${true?c} ${true?string} ${…

mysql联合索引与Where子句优化浅析

问题描述&#xff1a;把排序、条件等一个一个去除来做测试&#xff0c;结果发现问题就出在排序部分&#xff0c;去除排序时&#xff0c;执行时间由原来的48秒变成0.3x秒。于是&#xff0c;把涉及排序的字段组成一个联合索引alter table xx add index indexname(x1,x2,x3)&#…

有效使用Eclipse的热门提示

以下是一些技巧&#xff0c;可以帮助您避免潜在的问题并在使用Eclipse时提高工作效率。 避免安装问题 切勿在旧版本之上安装新版本的Eclipse。 首先重命名旧版本&#xff0c;将其移开&#xff0c;然后将新版本解压缩到干净的目录中。 恢复混乱的工作空间 对于许多开发人员来…

android拍照截图组件,Android截图命令screencap与视频录制命令screenrecord(示例代码)...

查看帮助命令[email protected] ~$ adb shell screencap -vscreencap: invalid option -- vusage: screencap [-hp] [-d display-id] [FILENAME]-h: this message-p: save the file as a png.-d: specify the display id to capture, default 0.If FILENAME ends with .png it …

usaco 2017 February platinum

1.一条路&#xff0c;两边都是一个1到n的全排列&#xff0c;可以把其中一个全排列的起始位置改变&#xff08;比如123可以变成231或者312&#xff09; 然后把相同的数连起来&#xff0c;求小交叉数。 先算一下交叉数&#xff0c;然后直接一步步移动&#xff0c;O1更新一下状态就…

Hessian 源码简单分析

Hessian 源码简单分析 Hessian 是一个rpc框架&#xff0c; 我们需要先写一个服务端&#xff0c; 然后在客户端远程的调用它即可。 服务端&#xff1a; 服务端通常和spring 做集成。 首先写一个接口&#xff1a; public interface HelloService { void sayHello(String n…

Java开发人员应该知道的三件事

对于那些长期关注JavaOne 2012会议的读者来说&#xff0c;这是一篇有趣的文章。 我最近对Java冠军Heinz Kabutz的采访引起了我的注意&#xff1b; 包括他的Java内存难题程序&#xff0c;从Java内存管理的角度来看&#xff0c;这很有启发性。 采访中有一个特别的部分吸引了我的注…

android怎么垂直居中且靠右,placeholder 靠右垂直居中/位置兼容

1.input输入框文字靠右垂直居中。2.placehoder提示同样靠右垂直居中。( placeholder是HTML5 input的新属性&#xff0c;英文意思是占位符&#xff0c;它一般表示input输入框的默认提示值。)css代码input {text-align: right;font-size:0.3rem;width:100%;height:0.78rem;line-…

Python-Matplotlib 18 注释

Python-Matplotlib 18 注释 EG1: import numpy as np import matplotlib.pyplot as plty np.arange(-5, 6,1) plt.plot(y, y*y) plt.annotate(Annotate , xy(0,1) , xytext(0,5) ,arrowpropsdict(facecolorr , frac0.2 ))plt.show()转载于:https://www.cnblogs.com/zsr0401/p/…

while和for循环

循环结构图&#xff1a; 循环结构主要分为两种&#xff1a;有while和for两种循环&#xff0c;while又分为do{...}while和while{...},do...while表示先执行后判断&#xff0c;而while循坏表示先判断后执行&#xff0c;如果循环条件都不满足的情况下&#xff0c;do...while至少执…

通过beforeClass和afterClass设置增强Spring Test Framework

如何允许实例方法作为JUnit BeforeClass行为运行 JUnit允许您在所有测试方法调用之前和之后一次在类级别上设置方法。 但是&#xff0c;通过有意设计&#xff0c;他们将其限制为仅使用BeforeClass和AfterClass批注的静态方法。 例如&#xff0c;此简单的演示显示了典型的Junit设…

华为鸿蒙出来正当时,关于华为鸿蒙操作系统,中兴率先表态

原标题&#xff1a;关于华为鸿蒙操作系统&#xff0c;中兴率先表态 来源&#xff1a;科技数码迷进入2021年之后中兴这个品牌的存在感越来越强了&#xff0c;并且还学会了借势营销。每当国内智能手机领域有大事之时总会看到中兴或红魔手机的身影。这说明在5G过渡期中兴要借个机会…

条件变量(Condition Variable)详解

转载于&#xff1a;http://blog.csdn.net/erickhuang1989/article/details/8754357 条件变量(Condtion Variable)是在多线程程序中用来实现“等待->唤醒”逻辑常用的方法。举个简单的例子&#xff0c;应用程序A中包含两个线程t1和t2。t1需要在bool变量test_cond为true时才能…

C++中的深拷贝和浅拷贝 QT中的深拷贝,浅拷贝和隐式共享

下面是C中定义的深&#xff0c;浅拷贝 当用一个已初始化过了的自定义类类型对象去初始化另一个新构造的对象的时候&#xff0c;拷贝构造函数就会被自动调用。也就是说&#xff0c;当类的对象需要拷贝时&#xff0c;拷贝构造函数将会被调用。以下情况都会调用拷贝构造函数&#…

使用PowerMock模拟构造函数

我认为&#xff0c;依赖项注入的主要好处之一是可以将模拟和/或存根对象注入代码中&#xff0c;以提高可测试性&#xff0c;增加测试覆盖率并编写更好&#xff0c;更有意义的测试。 但是&#xff0c;有时候您会遇到一些不使用依赖注入的传统代码&#xff0c;而是通过组合而不是…

Brackets (区间DP)

个人心得&#xff1a;今天就做了这些区间DP&#xff0c;这一题开始想用最长子序列那些套路的&#xff0c;后面发现不满足无后效性的问题&#xff0c;即&#xff08;&#xff0c;&#xff09;的配对 对结果有一定的影响&#xff0c;后面想着就用上一题的思想就慢慢的从小一步一步…

android生成aar无效,android studio生成aar包并在其他工程引用aar包的方法

1.aar包是android studio下打包android工程中src、res、lib后生成的aar文件&#xff0c;aar包导入其他android studio 工程后&#xff0c;其他工程可以方便引用源码和资源文件2.生成aar包步骤&#xff1a;①.用android studio打开一个工程&#xff0c;然后新建一个Module&#…

《剑指offer》— JavaScript(3)从尾到头打印链表

从尾到头打印链表 题目描述 输入一个链表&#xff0c;从尾到头打印链表每个节点的值。 实现代码 /*function ListNode(x){this.val x;this.next null; }*/ function printListFromTailToHead(head) {var res[];while(head){res.unshift(head.val);headhead.next;}return res;…

JUnit测试Spring Service和DAO(带有内存数据库)

这篇文章描述了如何为Spring Web Application的Services和DAO实现JUnit测试。 它建立在Spring MVC-Service-DAO-Persistence Architecture Example的基础上 。 从Github的Spring-Web-JPA-Testing目录中可以找到该示例。 提醒 测试装置 –固定状态&#xff0c;用作运行测试的基…