amqp rabbitmq_通过Spring Integration和RabbitMQ获得高可用性的AMQP支持的消息通道

amqp rabbitmq

Spring Integration消息通道默认情况下将消息存储在内存中。 这是因为内存速度快,易于实现,并且不会增加网络成本。 但是,在某些情况下,这可能会引起问题,因为如果应用程序崩溃或服务器意外关闭,所有消息都将丢失。 对于这种情况,Spring Integration引入了JMS&AMQP支持的消息通道,因此消息存储在JMS&AMQP代理中而不是存储在内存中。

高级消息队列协议(AMQP)是消息协议的开放标准。 它允许应用程序异步,可靠和安全地进行通信。 RabbitMQ是支持AMQP标准的开源消息代理。 RabbitMQ最重要的功能之一就是高可用性队列。

在本文中,通过创建两个消息传递节点和一个覆盖两个RabbitMQ服务器的RabbitMQ集群来说明Spring Integration的AMQP支持的点对点消息通道方法。 两个消息传递节点开始使用RabbitMQ集群处理Order消息。 如果意外关闭了第一消息节点和第一RabbitMQ服务器,第二消息节点和第二RabbitMQ服务器将继续处理Order消息,因此可以通过使用高可用性AMQP支持的通道来防止潜在的消息丢失和服务中断问题。

还建议使用Spring Integration进行消息处理文章介绍一下Spring Integration的主要组件。

订单消息系统的Spring集成流程如下:

si_flow

订单列表通过Order Gateway发送到Order Splitter的输入通道。 订单拆分器将订单列表拆分为订单消息,并将其发送到“订单流程服务激活器”。 processChannel是点对点AMQP支持的消息通道。 它创建了RabbitMQ集群管理的ha.rabbit.channel队列,并将订单消息发送到ha.rabbit.channel Rabbit队列,以实现高可用性。

让我们看看示例订单消息传递实现。

二手技术:

  • JDK 1.8.0_25
  • Spring4.1.4
  • Spring Integration 4.1.2
  • RabbitMQ服务器3.4.2
  • Maven 3.2.2
  • Ubuntu 14.04

项目层次结构如下:

蚀

步骤1:依存关系

Spring和Spring Integration Framework的依赖关系如下:

<properties><spring.version>4.1.4.RELEASE</spring.version><spring.integration.version>4.1.2.RELEASE</spring.integration.version></properties><dependencies><!-- Spring 4 dependencies --><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>${spring.version}</version></dependency><!-- Spring Integration dependencies --><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-core</artifactId><version>${spring.integration.version}</version></dependency><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-amqp</artifactId><version>${spring.integration.version}</version><scope>compile</scope></dependency><dependencies>

第2步:rabbitmq.config

第一RabbitMQ Server的配置文件(rabbitmq.config)如下。 它应该放在../rabbitmq_server-version/etc/rabbitmq/下

[{rabbit, [ {tcp_listeners, [5672]},{collect_statistics_interval, 10000},{heartbeat,30},{cluster_partition_handling, pause_minority},{cluster_nodes, {[ 'rabbit@master','rabbit2@master'],disc}} ] },{rabbitmq_management, [ {http_log_dir,"/tmp/rabbit-mgmt"},{listener, [{port, 15672}]} ] },{rabbitmq_management_agent, [ {force_fine_statistics, true} ] }
].

第二个RabbitMQ服务器的rabbitmq.config文件:

[{rabbit, [ {tcp_listeners, [5673]},{collect_statistics_interval, 10000},{heartbeat,30},{cluster_partition_handling, pause_minority},{cluster_nodes, {[ 'rabbit@master','rabbit2@master'],disc}} ] },{rabbitmq_management, [ {http_log_dir,"/tmp/rabbit-mgmt"},{listener, [{port, 15673}]} ] },{rabbitmq_management_agent, [ {force_fine_statistics, true} ] }
].

步骤3:集成上下文

Spring Integration Context的创建如下。 订单列表通过Order Gateway发送到Order Splitter的输入通道。 订单拆分器将订单列表拆分为订单消息,并将其发送到“订单流程服务激活器”。 processChannel是点对点AMQP支持的消息通道。 它创建了RabbitMQ集群管理的ha.rabbit.channel队列,并将订单消息发送到ha.rabbit.channel RabbitMQ队列以实现高可用性。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:int="http://www.springframework.org/schema/integration"xmlns:int-amqp="http://www.springframework.org/schema/integration/amqp"xmlns:rabbit="http://www.springframework.org/schema/rabbit"xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/integrationhttp://www.springframework.org/schema/integration/spring-integration.xsdhttp://www.springframework.org/schema/integration/amqp http://www.springframework.org/schema/integration/amqp/spring-integration-amqp.xsdhttp://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"><!-- Configuration for Component Scan --><context:component-scan base-package="com.onlinetechvision" /><context:property-placeholder location="classpath*:rabbitmq.properties"/><int:channel id="inputChannel"/><int:gateway id="orderGateway" service-interface="com.onlinetechvision.integration.OrderGateway" default-request-channel="inputChannel" /><int-amqp:channel id="processChannel"connection-factory="connectionFactory" message-driven="true"queue-name="ha.rabbit.channel" /><!-- RabbitMQ Connection Factory --><rabbit:connection-factory id="connectionFactory"addresses="${rabbitmq.addresses}" username="${rabbitmq.username}"password="${rabbitmq.password}" /><int:splitter id="orderSplitter" input-channel="inputChannel" output-channel="processChannel" /><int:service-activator input-channel="processChannel" ref="orderProcessService" method="process" /></beans>

第4步:rabbitmq.properties

rabbitmq.properties的创建如下。 如果第一个RabbitMQ服务器意外关闭,第二个RabbitMQ将继续侦听Order消息。

rabbitmq.addresses=localhost:5672,localhost:5673
rabbitmq.username=guest
rabbitmq.password=guest

步骤5:订单模型

订购Bean模型订购消息。

import java.io.Serializable;public class Order implements Serializable {private static final long serialVersionUID = -2138235868650860555L;private int id;private String name;public Order(int id, String name) {this.id = id;this.name = name;}//Getter and Setter Methods...@Overridepublic String toString() {return "Order [id=" + id + ", name=" + name + "]";}}

步骤6:OrderGateway

OrderGateway接口提供应用程序对Order消息系统的访问。 它的默认请求通道是inputChannel。

import java.util.List;import org.springframework.messaging.Message;import com.onlinetechvision.model.Order;public interface OrderGateway {/*** Processes Order Request** @param message SI Message covering Order payload.*/void processOrderRequest(Message<List<Order>> message);
}

步骤7:OrderSplitter

OrderSplitter监听inputChannel并将传入的Order List分解为Order消息。 订单消息将发送到AMQP支持的processChannel。

import java.util.List;import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;import com.onlinetechvision.model.Order;@Component("orderSplitter")
public class OrderSplitter {/*** Splits Order List to Order message(s)** @param message SI Message covering Order List payload.* @return order list*/public List<Order> splitOrderList(Message<List<Order>> message) {return message.getPayload();}
}

步骤8:ProcessService

通用流程服务接口向消息系统公开流程服务功能。

import org.springframework.messaging.Message;public interface ProcessService<T> {/*** Processes incoming message(s)** @param message SI Message.*/void process(Message<T> message);}

步骤9:OrderProcessService

订单流程服务激活器侦听AMQP支持的processChannel并记录传入的订单消息。 添加睡眠以填充ha.rabbit.channel RabbitMQ队列。

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;import com.onlinetechvision.model.Order;@Component("orderProcessService")
public class OrderProcessService implements ProcessService<Order> {private final Logger logger = LoggerFactory.getLogger(OrderProcessService.class);private final static long SLEEP_DURATION = 1_000;@Overridepublic void process(Message<Order> message) {try {Thread.sleep(SLEEP_DURATION);} catch (InterruptedException e) {Thread.currentThread().interrupt();}logger.debug("Node 1 - Received Message : " + message.getPayload());}}

步骤10:申请

应用程序类通过初始化应用程序上下文来运行应用程序,并将订单消息发送到消息传递系统。 仅第一个消息传递节点创建Order消息,而两个消息传递节点处理它们。 请找到第一和第二个消息传递节点的应用程序类,如下所示:

第一消息节点的应用程序类:

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executors;import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;import com.onlinetechvision.integration.OrderGateway;
import com.onlinetechvision.model.Order;public class Application {private final static int MESSAGE_LIMIT = 1_000;private final static int ORDER_LIST_SIZE = 10;private final static long SLEEP_DURATION = 50;private static OrderGateway orderGateway;/*** Starts the application** @param  String[] args**/public static void main(String[] args) {ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");orderGateway = context.getBean(OrderGateway.class);Executors.newSingleThreadExecutor().execute(new Runnable() {@Overridepublic void run() {try {int firstIndex = 0, lastIndex = ORDER_LIST_SIZE;while(lastIndex <= MESSAGE_LIMIT) {Message<List<Order>> message = MessageBuilder.withPayload(getOrderList(firstIndex, lastIndex)).build();orderGateway.processOrderRequest(message);firstIndex += ORDER_LIST_SIZE;lastIndex += ORDER_LIST_SIZE;Thread.sleep(SLEEP_DURATION);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}}});}/*** Creates a sample order list and returns.** @return order list*/private static List<Order> getOrderList(final int firstIndex, final int lastIndex) {List<Order> orderList = new ArrayList<>(lastIndex);for(int i = firstIndex; i < lastIndex; i++) {orderList.add(new Order(i, "Sample_Order_" + i));}return orderList;}}

第二个消息节点的应用程序类:

import org.springframework.context.support.ClassPathXmlApplicationContext;public class Application {/*** Starts the application** @param  String[] args**/public static void main(String[] args) {new ClassPathXmlApplicationContext("applicationContext.xml");}}

步骤11:RabbitMQ群集Bash脚本

First RabbitMQ Server的示例bash脚本如下。 另外,请查看RabbitMQ Cluster文档以了解其他配置步骤。

#!/bin/bash
echo "*** First RabbitMQ Server is setting up ***"export RABBITMQ_HOSTNAME=rabbit@master
export RABBITMQ_NODE_PORT=5672
export RABBITMQ_NODENAME=rabbit@master
export RABBITMQ_SERVER_START_ARGS="-rabbitmq_management listener [{port,15672}]"/DEV_TOOLS/rabbitmq_server-3.4.2/sbin/rabbitmq-server &echo "*** Second RabbitMQ Server is set up succesfully. ***"sleep 5echo "*** First RabbitMQ Server' s status : ***"/DEV_TOOLS/rabbitmq_server-3.4.2/sbin/rabbitmqctl status

第二个RabbitMQ Server的示例bash脚本如下:

#!/bin/bash
echo "*** Second RabbitMQ Server is setting up ***"export RABBITMQ_HOSTNAME=rabbit2@master
export RABBITMQ_NODE_PORT=5673
export RABBITMQ_NODENAME=rabbit2@master
export RABBITMQ_SERVER_START_ARGS="-rabbitmq_management listener [{port,15673}]"/DEV_TOOLS/rabbitmq_server-3.4.2_2/sbin/rabbitmq-server &echo "*** Second RabbitMQ Server is set up succesfully. ***"sleep 5echo "*** Second RabbitMQ Server' s status : ***"/DEV_TOOLS/rabbitmq_server-3.4.2_2/sbin/rabbitmqctl statussleep 5echo "*** Second RabbitMQ Server is being added to cluster... ***"/DEV_TOOLS/rabbitmq_server-3.4.2_2/sbin/rabbitmqctl -n rabbit2@master stop_app
/DEV_TOOLS/rabbitmq_server-3.4.2_2/sbin/rabbitmqctl -n rabbit2@master join_cluster rabbit@master
/DEV_TOOLS/rabbitmq_server-3.4.2_2/sbin/rabbitmqctl -n rabbit2@master start_app
/DEV_TOOLS/rabbitmq_server-3.4.2/sbin/rabbitmqctl -n rabbit@master set_policy ha-all "^ha\." '{"ha-mode":"all"}'echo "*** Second RabbitMQ Server is added to cluster successfully... ***"sleep 5echo "*** Second RabbitMQ Server' s cluster status : ***"/DEV_TOOLS/rabbitmq_server-3.4.2_2/sbin/rabbitmqctl cluster_status

步骤12:建立并执行专案

订单消息的操作结果如下:

  1. 第一个RabbitMQ服务器启动。
  2. 第二台RabbitMQ服务器已启动并添加到集群中。

    RabbitMQ群集概述如下:

    rabbitmq_cluster_overview1

  3. 设置第一台RabbitMQ Server的高可用性(HA)策略。
  4. 第一个消息传递节点已启动。 它创建订单消息和流程。

    启动第一个消息传递节点后,Spring Integration上下文会自动创建一个ha.rabbit.channel RabbitMQ队列,如下所示:

    ha_rabbit_channel

  5. 第二个消息传递节点已启动。 它不会创建Order消息,而只是处理。
  6. 订单列表开始处理。

    在第一个和第二个消息节点连接到RabbitMQ集群之后,ha.rabbit.channel队列详细信息如下:

    第一台RabbitMQ服务器上的ha.rabbit.channel队列:

    ha_rabbit_channel_details1

    第二台RabbitMQ服务器上的ha.rabbit.channel队列:

    ha_rabbit_channel_details_21

  7. 第一个消息节点关闭。
  8. 首先,RabbitMQ Server关闭并离开集群。
  9. 第二消息节点第二RabbitMQ服务器处理传入的Order消息以实现高可用性,因此不会中断服务。 第二个RabbitMQ节点的屏幕快照如下:

    ha_rabbit_channel_details_2_after_first_node_is_down1

    也将看到以下控制台输出日志:

    第一个消息节点控制台:

    ...22:32:51.838 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 1 - Received Message : Order [id=260, name=Sample_Order_260]
    22:32:52.842 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 1 - Received Message : Order [id=261, name=Sample_Order_261]
    22:32:53.847 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 1 - Received Message : Order [id=263, name=Sample_Order_263]
    22:32:54.852 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 1 - Received Message : Order [id=264, name=Sample_Order_264]

    在消息ID:264被传递到第一个消息节点之后,它和第一个RabbitMQ节点被关闭,第二个消息节点和第二个RabbitMQ节点按以下方式处理剩余的订单消息:

    第二个消息节点控制台:

    ...22:32:54.211 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=262, name=Sample_Order_262]
    22:32:56.214 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=265, name=Sample_Order_265]
    22:32:58.219 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=266, name=Sample_Order_266]
    22:33:00.223 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=267, name=Sample_Order_267]
    22:33:02.229 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=268, name=Sample_Order_268]
    22:33:04.234 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=269, name=Sample_Order_269]
    22:33:06.239 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=270, name=Sample_Order_270]
    22:33:08.241 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=271, name=Sample_Order_271]
    22:33:10.247 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=272, name=Sample_Order_272]
    22:33:12.252 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=273, name=Sample_Order_273]
    22:33:14.255 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=274, name=Sample_Order_274]
    22:33:16.258 [SimpleAsyncTaskExecutor-1] DEBUG c.o.p.s.OrderProcessService - Node 2 - Received Message : Order [id=275, name=Sample_Order_275]...

源代码

  • 源代码在Github上可用

参考资料

企业整合模式
Spring集成参考手册
Spring Integration 4.1.2.RELEASE API Pro Spring整合 RabbitMQ服务器文档

翻译自: https://www.javacodegeeks.com/2015/01/high-available-amqp-backed-message-channels-via-spring-integration-and-rabbitmq.html

amqp rabbitmq

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

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

相关文章

虚函数和纯虚函数的区别是什么?

虚函数(impure virtual)  C 的虚函数主要作用是“运行时多态”&#xff0c;父类中提供虚函数的实现&#xff0c;为子类提供默认的函数实现。  子类可以重写父类的虚函数实现子类的特殊化。  如下就是一个父类中的虚函数&#xff1a;class A{public: virtual void ss(…

java 编译 器 ide_Java 8发布一年后,IDE和编译器尚未完全就绪

java 编译 器 ide一年前&#xff0c; 2014年3月18日 &#xff0c;发布了Java SE 8&#xff0c;并通过lambda表达式和streams API带来了功能性编程的幸福。 这对于我们所有的Java生态系统都是个好消息&#xff0c;许多人已经升级到Java8。Stack Overflow已经提出了将近2500个有关…

windows.h有哪些函数

C语言windows.h库的常用函数1&#xff1a;FindWindow函数该函数可以通过窗口类名或者窗口标题名来查找特定窗口句柄&#xff0c;返回值是窗口的句柄&#xff08;在Windows中&#xff0c;句柄是一个系统内部数据结构的引用。例如当你操作一个窗口&#xff0c;或说是一个Delphi窗…

yxcms安装环境php,Windows7下PHP开发环境安装配置图文方法

操作系统&#xff1a;Windows 7 UltimateWEB服务器&#xff1a;IIS 6.1(内部版本7600)。数据库&#xff1a;MySql5.0.67PHP版本&#xff1a;5.2.13我还担心Win7下可能会不兼容&#xff0c;结果是一点问题都没有。一、安装MySql数据库客户端工具Navicat(导航猫)在这里下载&#…

apache camel_您的Apache Camel应用程序现在包括现成的文档

apache camel几个月前&#xff0c;我在博客中发布了有关即将发布的2.15版本的功能&#xff0c;该功能包括获取有关在端点上配置的每个属性的详细信息的功能-Apache Camel&#xff0c;请向我解释这些端点选项的含义 。 我们继续沿着这条道路前进&#xff0c;今天我们将其从端点…

C语言的三种基本程序结构是什么

一、顺序结构表达式语句、空语句、函数调用语句、复合语句程序举例&#xff1a;从键盘输入一个大写字母&#xff0c;要求改用小写字母输出。#includeint main(){ char x,y; scanf("%c",&x); if(x > A && x < Z) { …

C语言中的指针有什么作用

C语言中的指针的作用是&#xff1a;通过指针不仅可以对数据本身&#xff0c;还可以对存储数据的变量地址进行操作。指针就是内存地址&#xff0c;指针变量是用来存放内存地址的变量。指针定义&#xff1a;指针&#xff0c;是C语言中的一个重要概念及其特点&#xff0c;也是掌握…

rsa php openssl,openssl rsa 使用简介

openssl命令的用法密钥的生成a. 生成非对称密钥对openssl genrsa -out rsa.keyb. 指定生成的密钥的位数,默认512openssl genrsa -out rsa_2048.key 2048c. 为私钥添加密码 (一般都不用)openssl genrsa -out rsa_des3.key -des3密钥的查看d. 查看私钥openssl rsa -in rsa.keye. …

C语言标识符有哪三类

C语言标识符有关键字、用户标识符、预定义标识符三类。C语言规定&#xff0c;标识符只能由字母、数字和下划线组成&#xff0c;并且第一个字符必须是字母或下划线&#xff0c;不能是数字。C语言中的标识符可分为关键字、用户标识符、预定义标识符三类。C语言规定&#xff0c;标…

Hibernate锁定模式– PESSIMISTIC_FORCE_INCREMENT锁定模式如何工作

介绍 在上 一篇 文章中 &#xff0c;我介绍了OPTIMISTIC_FORCE_INCREMENT锁定模式&#xff0c;并将其应用于将子实体版本更改传播到锁定的父实体。 在本文中&#xff0c;我将介绍PESSIMISTIC_FORCE_INCREMENT锁定模式&#xff0c;并将其与乐观的锁定模式进行比较。 相像多于不…

C语言中字符串的结束标志是什么

C语言中字符串的结束标志是【\0】。C语言中没有专门的字符串变量&#xff0c;通常用一个字符数组来存放一个字符串&#xff0c;字符串总是以【\0】作为结束符。\0就是8位的00000000&#xff0c;因为字符类型中并没有对应的这个字符&#xff0c;所以这么写。\0就是 字符串结束标…

php 5.6.27 在某些机器上正常,在 Windows 10 64、PHP 5.6 下重命名中文名文件,提示错误的解决...

1、重命名某个目录中的文件名&#xff0c;其代码&#xff0c;如图1图12、报错&#xff1a;rename(E:/wwwroot/avatar/BEIJI/侯森.jpg,E:/wwwroot/avatar/BEIJI/378477.jpg): ϵͳ&#xfffd;Ҳ&#xfffd;&#xfffd;&#xfffd;ָ&#xfffd;&#xfffd;&#xfffd;&am…

c语言中字符常量是什么?

c语言中字符常量是什么&#xff1f;字符常量&#xff1a;一个用单引号括起来的单个字符&#xff08;或字符转义序列或三字母词&#xff09;实质&#xff08;含义&#xff09;&#xff1a;是一个整形值。属于四大基本数据类型&#xff08;分别是整型&#xff0c;浮点型&#xff…

Hibernate锁定模式– OPTIMISTIC_FORCE_INCREMENT锁定模式如何工作

介绍 在我以前的文章中 &#xff0c;我解释了OPTIMISTIC锁定模式是如何工作的&#xff0c;以及它如何帮助我们同步外部实体状态更改。 在本文中&#xff0c;我们将介绍OPTIMISTIC_FORCE_INCREMENT锁定模式的使用模式。 使用LockModeType.OPTIMISTIC &#xff0c;将在当前正在运…

c语言的输入输出语句有哪些?

c语言的输入输出语句有&#xff1a;“getchar(void);”和“putchar(int c);”、“scanf("格式控制字符串",地址列表);”和“printf("格式控制字符串",输出列表);”、“gets()”和“puts()”等等。一&#xff1a;控制台输入输出(1)字符数据的输入/输出字符输…

primefaces_PrimeFaces:在动态生成的对话框中打开外部页面

primefaces我已经在即将出版的PrimeFaces Cookbook版本2中写过一篇食谱的博客。 在这篇文章中&#xff0c;我想发表第二篇关于一个名为Dialog Framework的小型框架的文章。 我个人喜欢它&#xff0c;因为我记得我为使用Struts框架付出同样的代价。 当您想将外部页面加载到弹出窗…

c语言源文件经过编译后生成文件的后缀是什么?

c语言源文件经过编译后&#xff0c;生成文件的后缀是“.obj”。C语言源文件后缀名是“.c”&#xff0c;编译生成的文件后缀名是“.obj”&#xff0c;连接后可执行文件的后缀名是“.exe”。C语言创建程序的步骤&#xff1a;编辑&#xff1a;就是创建和修改C程序的源代码-我们编写…

java编译器jdk版本_以编程方式确定Java类的JDK编译版本

java编译器jdk版本当需要确定使用哪个JDK版本来编译特定的Java .class文件时&#xff0c; 通常使用的方法是使用javap并在javap输出中查找列出的“主要版本”。 我在我的博客文章Autoboxing&#xff0c;Unboxing和NoSuchMethodError中引用了这种方法&#xff0c;但是在继续以编…

c语言指针用法有哪些

c语言指针用法&#xff1a;一&#xff0c;指针定义&#xff1a;指针变量的取值范围取值0~4G,是一种数据类型&#xff08;无符号整数&#xff0c;代表了内存编号&#xff09;。它可以用来定义变量&#xff08;与int、long一样&#xff09;&#xff0c;与int、long不同的它存储整…

ogm session_带有Hibernate OGM的NoSQL –第一部分:持久化您的第一个实体

ogm sessionHibernate OGM的第一个最终版本已经发布 &#xff0c;团队从发布狂潮中恢复了一些。 因此&#xff0c;他们考虑开设一系列教程风格的博客&#xff0c;使您有机会轻松地从Hibernate OGM重新开始。 感谢Gunnar Morling&#xff08; gunnarmorling &#xff09;创建了本…