phpvhost

① 如何正确配置 Nginx 和 php

直接贴上代码逐行进行讲解，此处贴出一个能正常启动php脚本的最简nginx vhost配置：

[plain] view plain
server {
listen 8011;
server_name test.cn;
location ~ \.php?.*$ {
root /share/test;
fastcgi_pass 127.0.0.1:9000;
fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;
include fastcgi_params;
}
}

1、第一个大括号 server{ }：不必多说，代表一个独立的server，

2、listen 8011：代表该server监听8011端口

3、location ~ \.php?.*${
}：代表一个能匹配对应uri的location，用于匹配一类uri，并对所匹配的uri请求做自定义的逻辑、配置。这里的location，匹配了所有带.php的uri请求，例如：http://192.168.244.128:8011/test.php/asdasd
http://192.168.244.128:8011/index.php等

4、root /share/test：请求资源根目录，告诉匹配到该location下的uri到/share/teset文件夹下去寻找同名资源。

5、fastcgi_pass 127.0.0.1:9000：这行开始是本文的重点：这行代码的意思是，将进入到该location内的uri请求看做是cgi程序，并将请求发送到9000端口，交由php-fpm处理。

6、fastcgi_param SCRIPT_FILENAME
$document_root$fastcgi_script_name;
：这行配置意思是：动态添加了一行fastcgi配置，配置内容为SCRIPT_FILENAME，告知管理进程，cgi脚本名称。由于我的nginx中只有fastcgi_params文件，没有fastcgi.conf文件，所以要使php-fpm知道SCRIPT_FILENAME的具体值，就必须要动态的添加这行配置。

7、include fastcgi_params; 引入fastcgi配置文件

以上就是最简洁版的nginx启动php脚本的最简配置，当重启nginx之后，在/share/test目录下创建一个xx.php文件，输入<?php
echo "hello world"; ?>保存，然后在浏览器中访问localhost:8011/xx.php
就可以在网页上显示hello world了。

② 如何在Windows下配置搭建PHP环境

前言：网络上提供了各种版本名为wamp的组合包，就是下载下来一路点下一步就安装好了直接应用的那种人家配置好了的软件包，为了学习本人并不太建议此类方法。

一、首先下载php5.3组件(现在已经更新到7点几版本了)

1、下载软件包，建议直接到官网
2、下载时注意选择与你系统相配合的包：
下载完后解压到一个路径 例如 E:\LAMP\php5.3

3、在解压后的路径中找到php.ini-development，重命名为php.ini。

首先打开php.ini，找到：

; On windows:
;
extension_dir = "ext"

修改为：

; On windows:
extension_dir = " E:/LAMP/php5.3/ext"

即去掉extension_dir前面的分号（注意斜杠方向），表示指定PHP扩展包的具体目录，以便调用相应的DLL文件。

4、由于默认PHP并不支持自动连接Mysql，需开启相应的扩展库功能，比如php_mysql.dll等，即将：

extension=php_curl.dll //CURL，客户端 URL
库函数库
extension=php_gd2.dll
//GD绘图函数模块
extension=php_mbstring.dll
//多字节函数模块
extension=php_mysql.dll
//MySql函数模块
extension=php_mysqli.dll
//MySqli函数模块
extension=php_pdo_mysql.dll //PDO
MySql函数模块
extension=php_pdo_odbc.dll //PDO
ODBC函数模块
extension=php_xmlrpc.dll
//XML-RPC函数库
extension=php_xsl.dll
//XSL函数模块这些extension之前的分号(;)去除。
至此在Windows 7上php的环境配置就算完成了，但是光完成这些配置是不够的，我们需要Apache支持PHP，所以还需要在Apache配置文件中完成相应的PHP配置。以下是配置Apache以支持PHP：

二、安装与配置Apache2.2
(现在已经更新到2.4版本了，安装时稍有不同，见本站另一笔记http://www.itg123.com/a/softissue/2016/0320/114.html)

1、下载软件包，建议直接到官网 http://httpd.apache.org/上下载，因为这是开源软件的安全性问题，如果用于生产环境则强烈建议到官网下载。

2、下载时注意选择与你系统相配合的包，如.tar.gz的是用于Linux环境的，httpd-2.2.31-win32-src.zip用于windows环境，还有win32表示用于32位win7系统。双击默认安装，也自己可以自定义一个路径
例如 E:\LAMP\apache。
3、安装完后找到Apache安装目录下的conf文件夹下的httpd.conf，打开：

在#LoadMole
vhost_alias_mole
moles/mod_vhost_alias.so下添加如下（路径适你自己的情况而定）：

LoadMole php5_mole
"E:/LAMP/php5.3/php5apache2_2.dll"
PHPIniDir "E:/LAMP/php5.3"
AddType
application/x-httpd-php .php .html
.htm

我们在PHP目录下可以看到多个php5apache的DLL文件，由于我们使用的是Apache2.2.17，所以我们当然需要使php5apache2_2.dll，接着指定PHP的安装目录以及执行的程序扩展名。

4、我们应该知道默认Apache服务器执行WEB主程序的目录为Apache2.2/htdocs，所以如果当你的WEB主程序目录变更时，我们需要修改相应的Apache配置.
5、最后修改具体的index文件先后顺序：DirectoryIndex
index.html修改为：DirectoryIndex index.php index.html
6、重启Apache服务器
至此，在Apache服务器上PHP环境配置工作就完成了，你只需要在 Apache2.2/htdocs
目录下新建一个PHP文件，写入：
然后在游览器中输入12.0.0.1，就可以看到PHP的具体配置页面了，代表在Window
7上PHP环境配置工作就算完成了。

三、安装与配置Mysql 5.1数据库软件
(现在已经更新到5.5版本了，安装较简单，如果上面步骤都配置好了运行正常了的话可以下载一个对应版本的MyPhpAdmin程序包放到E:/www下然后在游览器中输入12.0.0.1登入后新建或管理数据库)

1、下载软件包，建议直接到官网
http://downloads.mysql.com/archives/installer/ 上下载，这个链接有各个版本，因为这是开源软件的安全性问题，如果用于生产环境则强烈建议到官网下载。

2、
验证PHP是否能连接Mysql，你可以在index.php中创建如下代码：

<?php
$connect=mysql_connect("127.0.0.1","root","你的数据库密码");
if(!$connect)
echo "Mysql Connect Error!";
else echo
"连接成功";
mysql_close();
?>

然后在游览器中输入127.0.0.1，看到：连接成功字样就说明PHP连接Mysql就算成功了。

③ wamp5集成php环境如何搭建

开启服务器后，它默认的配置好的是localhost（地址栏输入访问），访问的文件是放在www或者说是docs西面，在里面建立php文件即可，要么你自己整几个虚拟主机，不用它配的localhost域名，在httpd.conf里面打开包含有vhost的那项，把此包含打开，即把#去掉。然后在它的辅助配置文件，vhosts.conf里添加你要访问的域名，本地位置。当然，要这样能访问到，你还得配置hosts文件，

④ php中vhosts.conf怎么写

Apache配置localhost虚拟主机步骤 1、打开apache目录下httpd文件(如：C:\wamp\bin\apache\Apache2.2.17\conf\httpd.conf)找到如下模块： #Virtual hosts #Include conf/extra/httpd-vhosts.conf 去掉前面的#，这样就开启了httpd-vhosts虚拟主机....

⑤ 大型的PHP应用，通常使用什么应用做消息队列

一、消息队列概述
消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。
目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等。
二、消息队列应用场景
以下介绍消息队列在实际应用中常用的使用场景。异步处理，应用解耦，流量削锋和消息通讯四个场景。
2.1异步处理
场景说明：用户注册后，需要发注册邮件和注册短信。传统的做法有两种1.串行的方式；2.并行方式。
（1）串行方式：将注册信息写入数据库成功后，发送注册邮件，再发送注册短信。以上三个任务全部完成后，返回给客户端。（架构KKQ：466097527，欢迎加入）
（2）并行方式：将注册信息写入数据库成功后，发送注册邮件的同时，发送注册短信。以上三个任务完成后，返回给客户端。与串行的差别是，并行的方式可以提高处理的时间。
假设三个业务节点每个使用50毫秒钟，不考虑网络等其他开销，则串行方式的时间是150毫秒，并行的时间可能是100毫秒。
因为CPU在单位时间内处理的请求数是一定的，假设CPU1秒内吞吐量是100次。则串行方式1秒内CPU可处理的请求量是7次（1000/150）。并行方式处理的请求量是10次（1000/100）。
小结：如以上案例描述，传统的方式系统的性能（并发量，吞吐量，响应时间）会有瓶颈。如何解决这个问题呢？
引入消息队列，将不是必须的业务逻辑，异步处理。改造后的架构如下：
按照以上约定，用户的响应时间相当于是注册信息写入数据库的时间，也就是50毫秒。注册邮件，发送短信写入消息队列后，直接返回，因此写入消息队列的速度很快，基本可以忽略，因此用户的响应时间可能是50毫秒。因此架构改变后，系统的吞吐量提高到每秒20 QPS。比串行提高了3倍，比并行提高了两倍。
2.2应用解耦
场景说明：用户下单后，订单系统需要通知库存系统。传统的做法是，订单系统调用库存系统的接口。如下图：
传统模式的缺点：
1） 假如库存系统无法访问，则订单减库存将失败，从而导致订单失败；
2） 订单系统与库存系统耦合；
如何解决以上问题呢？引入应用消息队列后的方案，如下图：
订单系统：用户下单后，订单系统完成持久化处理，将消息写入消息队列，返回用户订单下单成功。
库存系统：订阅下单的消息，采用拉/推的方式，获取下单信息，库存系统根据下单信息，进行库存操作。
假如：在下单时库存系统不能正常使用。也不影响正常下单，因为下单后，订单系统写入消息队列就不再关心其他的后续操作了。实现订单系统与库存系统的应用解耦。
2.3流量削锋
流量削锋也是消息队列中的常用场景，一般在秒杀或团抢活动中使用广泛。
应用场景：秒杀活动，一般会因为流量过大，导致流量暴增，应用挂掉。为解决这个问题，一般需要在应用前端加入消息队列。
可以控制活动的人数；
可以缓解短时间内高流量压垮应用；
用户的请求，服务器接收后，首先写入消息队列。假如消息队列长度超过最大数量，则直接抛弃用户请求或跳转到错误页面；
秒杀业务根据消息队列中的请求信息，再做后续处理。
2.4日志处理
日志处理是指将消息队列用在日志处理中，比如Kafka的应用，解决大量日志传输的问题。架构简化如下：
日志采集客户端，负责日志数据采集，定时写受写入Kafka队列；
Kafka消息队列，负责日志数据的接收，存储和转发；
日志处理应用：订阅并消费kafka队列中的日志数据；
以下是新浪kafka日志处理应用案例：
(1)Kafka：接收用户日志的消息队列。
(2)Logstash：做日志解析，统一成JSON输出给Elasticsearch。
(3)Elasticsearch：实时日志分析服务的核心技术，一个schemaless，实时的数据存储服务，通过index组织数据，兼具强大的搜索和统计功能。
(4)Kibana：基于Elasticsearch的数据可视化组件，超强的数据可视化能力是众多公司选择ELK stack的重要原因。
2.5消息通讯
消息通讯是指，消息队列一般都内置了高效的通信机制，因此也可以用在纯的消息通讯。比如实现点对点消息队列，或者聊天室等。
点对点通讯：
客户端A和客户端B使用同一队列，进行消息通讯。
聊天室通讯：
客户端A，客户端B，客户端N订阅同一主题，进行消息发布和接收。实现类似聊天室效果。
以上实际是消息队列的两种消息模式，点对点或发布订阅模式。模型为示意图，供参考。
三、消息中间件示例
3.1电商系统
消息队列采用高可用，可持久化的消息中间件。比如Active MQ，Rabbit MQ，Rocket Mq。（1）应用将主干逻辑处理完成后，写入消息队列。消息发送是否成功可以开启消息的确认模式。（消息队列返回消息接收成功状态后，应用再返回，这样保障消息的完整性）
（2）扩展流程（发短信，配送处理）订阅队列消息。采用推或拉的方式获取消息并处理。
（3）消息将应用解耦的同时，带来了数据一致性问题，可以采用最终一致性方式解决。比如主数据写入数据库，扩展应用根据消息队列，并结合数据库方式实现基于消息队列的后续处理。
3.2日志收集系统
分为Zookeeper注册中心，日志收集客户端，Kafka集群和Storm集群（OtherApp）四部分组成。
Zookeeper注册中心，提出负载均衡和地址查找服务；
日志收集客户端，用于采集应用系统的日志，并将数据推送到kafka队列；
四、JMS消息服务
讲消息队列就不得不提JMS 。JMS（Java Message Service,Java消息服务）API是一个消息服务的标准/规范，允许应用程序组件基于JavaEE平台创建、发送、接收和读取消息。它使分布式通信耦合度更低，消息服务更加可靠以及异步性。
在EJB架构中，有消息bean可以无缝的与JM消息服务集成。在J2EE架构模式中，有消息服务者模式，用于实现消息与应用直接的解耦。
4.1消息模型
在JMS标准中，有两种消息模型P2P（Point to Point）,Publish/Subscribe(Pub/Sub)。
4.1.1 P2P模式
P2P模式包含三个角色：消息队列（Queue），发送者(Sender)，接收者(Receiver)。每个消息都被发送到一个特定的队列，接收者从队列中获取消息。队列保留着消息，直到他们被消费或超时。
P2P的特点
每个消息只有一个消费者（Consumer）(即一旦被消费，消息就不再在消息队列中)
发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列
接收者在成功接收消息之后需向队列应答成功
如果希望发送的每个消息都会被成功处理的话，那么需要P2P模式。（架构KKQ：466097527，欢迎加入）
4.1.2 Pub/sub模式
包含三个角色主题（Topic），发布者（Publisher），订阅者（Subscriber） 。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。
Pub/Sub的特点
每个消息可以有多个消费者
发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息。
为了消费消息，订阅者必须保持运行的状态。
为了缓和这样严格的时间相关性，JMS允许订阅者创建一个可持久化的订阅。这样，即使订阅者没有被激活（运行），它也能接收到发布者的消息。
如果希望发送的消息可以不被做任何处理、或者只被一个消息者处理、或者可以被多个消费者处理的话，那么可以采用Pub/Sub模型。
4.2消息消费
在JMS中，消息的产生和消费都是异步的。对于消费来说，JMS的消息者可以通过两种方式来消费消息。
（1）同步
订阅者或接收者通过receive方法来接收消息，receive方法在接收到消息之前（或超时之前）将一直阻塞；
（2）异步
订阅者或接收者可以注册为一个消息监听器。当消息到达之后，系统自动调用监听器的onMessage方法。
JNDI：Java命名和目录接口,是一种标准的Java命名系统接口。可以在网络上查找和访问服务。通过指定一个资源名称，该名称对应于数据库或命名服务中的一个记录，同时返回资源连接建立所必须的信息。
JNDI在JMS中起到查找和访问发送目标或消息来源的作用。（架构KKQ：466097527，欢迎加入）
4.3JMS编程模型
(1) ConnectionFactory
创建Connection对象的工厂，针对两种不同的jms消息模型，分别有QueueConnectionFactory和TopicConnectionFactory两种。可以通过JNDI来查找ConnectionFactory对象。
(2) Destination
Destination的意思是消息生产者的消息发送目标或者说消息消费者的消息来源。对于消息生产者来说，它的Destination是某个队列（Queue）或某个主题（Topic）;对于消息消费者来说，它的Destination也是某个队列或主题（即消息来源）。
所以，Destination实际上就是两种类型的对象：Queue、Topic可以通过JNDI来查找Destination。
(3) Connection
Connection表示在客户端和JMS系统之间建立的链接（对TCP/IP socket的包装）。Connection可以产生一个或多个Session。跟ConnectionFactory一样，Connection也有两种类型：QueueConnection和TopicConnection。
(4) Session
Session是操作消息的接口。可以通过session创建生产者、消费者、消息等。Session提供了事务的功能。当需要使用session发送/接收多个消息时，可以将这些发送/接收动作放到一个事务中。同样，也分QueueSession和TopicSession。
(5) 消息的生产者
消息生产者由Session创建，并用于将消息发送到Destination。同样，消息生产者分两种类型：QueueSender和TopicPublisher。可以调用消息生产者的方法（send或publish方法）发送消息。
(6) 消息消费者
消息消费者由Session创建，用于接收被发送到Destination的消息。两种类型：QueueReceiver和TopicSubscriber。可分别通过session的createReceiver(Queue)或createSubscriber(Topic)来创建。当然，也可以session的creatDurableSubscriber方法来创建持久化的订阅者。
(7) MessageListener
消息监听器。如果注册了消息监听器，一旦消息到达，将自动调用监听器的onMessage方法。EJB中的MDB（Message-Driven Bean）就是一种MessageListener。
深入学习JMS对掌握JAVA架构，EJB架构有很好的帮助，消息中间件也是大型分布式系统必须的组件。本次分享主要做全局性介绍，具体的深入需要大家学习，实践，总结，领会。
五、常用消息队列
一般商用的容器，比如WebLogic，JBoss，都支持JMS标准，开发上很方便。但免费的比如Tomcat，Jetty等则需要使用第三方的消息中间件。本部分内容介绍常用的消息中间件（Active MQ,Rabbit MQ，Zero MQ,Kafka）以及他们的特点。
5.1 ActiveMQ
ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现，尽管JMS规范出台已经是很久的事情了，但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。
ActiveMQ特性如下：
⒈ 多种语言和协议编写客户端。语言: Java,C,C++,C#,Ruby,Perl,Python,PHP。应用协议： OpenWire,Stomp REST,WS Notification,XMPP,AMQP
⒉ 完全支持JMS1.1和J2EE 1.4规范 （持久化，XA消息，事务)
⒊ 对spring的支持，ActiveMQ可以很容易内嵌到使用Spring的系统里面去，而且也支持Spring2.0的特性
⒋ 通过了常见J2EE服务器（如 Geronimo,JBoss 4,GlassFish,WebLogic)的测试，其中通过JCA 1.5 resource adaptors的配置，可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上
⒌ 支持多种传送协议：in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA
⒍ 支持通过JDBC和journal提供高速的消息持久化
⒎ 从设计上保证了高性能的集群，客户端-服务器，点对点
⒏ 支持Ajax
⒐ 支持与Axis的整合
⒑ 可以很容易得调用内嵌JMS provider，进行测试
5.2 RabbitMQ
RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX，持久化。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。
几个重要概念：
Broker：简单来说就是消息队列服务器实体。
Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。
Queue：消息队列载体，每个消息都会被投入到一个或多个队列。
Binding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key：路由关键字，exchange根据这个关键字进行消息投递。
vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。
procer：消息生产者，就是投递消息的程序。
consumer：消息消费者，就是接受消息的程序。
channel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务。
消息队列的使用过程，如下：
（1）客户端连接到消息队列服务器，打开一个channel。
（2）客户端声明一个exchange，并设置相关属性。
（3）客户端声明一个queue，并设置相关属性。
（4）客户端使用routing key，在exchange和queue之间建立好绑定关系。
（5）客户端投递消息到exchange。
exchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里。
5.3 ZeroMQ
号称史上最快的消息队列，它实际类似于Socket的一系列接口，他跟Socket的区别是：普通的socket是端到端的（1:1的关系），而ZMQ却是可以N：M 的关系，人们对BSD套接字的了解较多的是点对点的连接，点对点连接需要显式地建立连接、销毁连接、选择协议（TCP/UDP）和处理错误等，而ZMQ屏蔽了这些细节，让你的网络编程更为简单。ZMQ用于node与node间的通信，node可以是主机或者是进程。
引用官方的说法： “ZMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层，像框架一样的一个socket library，他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。ZMQ的明确目标是“成为标准网络协议栈的一部分，之后进入Linux内核”。现在还未看到它们的成功。但是，它无疑是极具前景的、并且是人们更加需要的“传统”BSD套接字之上的一 层封装。ZMQ让编写高性能网络应用程序极为简单和有趣。”
特点是：
高性能，非持久化；
跨平台：支持Linux、Windows、OS X等。
多语言支持； C、C++、Java、.NET、Python等30多种开发语言。
可单独部署或集成到应用中使用；
可作为Socket通信库使用。
与RabbitMQ相比，ZMQ并不像是一个传统意义上的消息队列服务器，事实上，它也根本不是一个服务器，更像一个底层的网络通讯库，在Socket API之上做了一层封装，将网络通讯、进程通讯和线程通讯抽象为统一的API接口。支持“Request-Reply “，”Publisher-Subscriber“，”Parallel Pipeline”三种基本模型和扩展模型。
ZeroMQ高性能设计要点：
1、无锁的队列模型
对于跨线程间的交互（用户端和session）之间的数据交换通道pipe，采用无锁的队列算法CAS；在pipe两端注册有异步事件，在读或者写消息到pipe的时，会自动触发读写事件。
2、批量处理的算法
对于传统的消息处理，每个消息在发送和接收的时候，都需要系统的调用，这样对于大量的消息，系统的开销比较大，zeroMQ对于批量的消息，进行了适应性的优化，可以批量的接收和发送消息。
3、多核下的线程绑定，无须CPU切换
区别于传统的多线程并发模式，信号量或者临界区， zeroMQ充分利用多核的优势，每个核绑定运行一个工作者线程，避免多线程之间的CPU切换开销。
5.4 Kafka
Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。 这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。 对于像Hadoop的一样的日志数据和离线分析系统，但又要求实时处理的限制，这是一个可行的解决方案。Kafka的目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理，也是为了通过集群机来提供实时的消费。
Kafka是一种高吞吐量的分布式发布订阅消息系统，有如下特性：
通过O(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。（文件追加的方式写入数据，过期的数据定期删除）
高吞吐量：即使是非常普通的硬件Kafka也可以支持每秒数百万的消息。
支持通过Kafka服务器和消费机集群来分区消息。
支持Hadoop并行数据加载。
Kafka相关概念
Broker
Kafka集群包含一个或多个服务器，这种服务器被称为broker[5]
Topic
每条发布到Kafka集群的消息都有一个类别，这个类别被称为Topic。（物理上不同Topic的消息分开存储，逻辑上一个Topic的消息虽然保存于一个或多个broker上但用户只需指定消息的Topic即可生产或消费数据而不必关心数据存于何处）
Partition
Parition是物理上的概念，每个Topic包含一个或多个Partition.
Procer
负责发布消息到Kafka broker
Consumer
消息消费者，向Kafka broker读取消息的客户端。
Consumer Group
每个Consumer属于一个特定的Consumer Group（可为每个Consumer指定group name，若不指定group name则属于默认的group）。
一般应用在大数据日志处理或对实时性（少量延迟），可靠性（少量丢数据）要求稍低的场景使用。

⑥ 如何配置php服务器

一、Apache安装
版本解释：openssl是表示带有openssl模块，利用openssl就可以给Apache配置SSL安全链接的，也就是使用https://方式进行访问。
nossl则表示不带OpenSSL模块，无法用于SSL安全链接，在这里我们下载带OpenSSL的。
选择版本：apache_2.2.14-win32-x86-openssl-0.9.8k.msi
下载地址：http://www.apache.org/dist/httpd/binaries/win32/
首先我们在D盘(盘符根据实际情况自己选择)新建一个目录，
并且命名为“WAMP”其意义为“Wdindows Apache Mysql PhpMyAdmin” 之后安装的一些内容，也都将安装在该目录下。
1.安装说明：
运行apache安装程序，方法非常简单，弹安装界面后一直“next”
接着会出现一个界面，需要填写3个内容，分别为：Network Domain、Server Name、Administrator’s Email Address 随便填写就好，不影响内容。
在下面还有2个选项，默认选择为80端口，第二个为8080端口，根据个人需求选择，一般为默认80端口。
我们继续安装，选择Custom(自定义安装)-“next”
其中有打着红X的组件，我们单击这个组件容，选择“This feature, and all subfeatures, will be installed on local hard drive.”，即“此部分，及下属子部分内容，全部安装在本地硬盘上”。-“next”
然后选择右下角的“change ”改变安装路径，安装到刚才建立的目录中“D:\WAMP\Apache\”-“next”
安装完毕后，电脑右下角会多出一个图标，双击打开，选择start或restart，能正常运行，至此安装完毕。
2.修改配置：
打开安装录下D:\WAMP\Apache\conf\httpd.conf 文件(修改配置文件时，不建议使用记事本，可能会对其造成影响，推荐使用Notepad++或其他编辑软件打开修改)
打开以后Ctrl+F查找所要修改的内容
在#LoadMole vhost_alias_mole moles/mod_vhost_alias.so下添加：
LoadMole php5_mole “D:/WAMP/PHP/php5apache2_2.dll”
PHPIniDir “D:/WAMP/PHP”
AddType application/x-httpd-php .php
AddType application/x-httpd-php .htm
AddType application/x-httpd-php .html
DocumentRoot “E:/WAMP/Apache/htdocs”
修改成(这里的路径和IIS中wwwroot目录一样，用于存放网页，自定义或不做修改默认)：DocumentRoot “D:/WAMP/www”
修改成(自定义或不做修改默认)：
DirectoryIndex index.html
修改成：DirectoryIndex index.php default.php index.html index.htm default.html default.htm
3.测试
在D:/WAMP/www目录下 建立个index.html页面
在浏览器中输入 http://localhost/
如果能正常显示，Apache配置完毕，已经正常运行。
二、MySql安装
版本解释：The Essentials Package：不包含 embedded server and benchmark suite，有自动安装程序和配置向导，没有MySQL Documentation。
The Complete Package：包含 embedded server and benchmark suite，有自动安装程序和配置向导，有MySQL Documentation。
The Noinstall Archive：包含 embedded server and benchmark suite，没有自动安装程序和配置向导，有MySQL Documentation。
选择版本：mysql-essential-5.1.44-win32.msi
下载地址：http://www.mysql.com/downloads/mysql/
1.安装说明：
打开安装程序，单击“next”
选择custom，组件为默认选择，我们不做改动-“next”
路径设置为“D:\WAMP\Mysql”-“next”
安装好以后点击“finish”
跟着会出现一个配置向导-“next”
选择“Detailed Configuration(详细配置)”-“next”
这里有3个选项：
Developer Machine，将只用尽量少的内存;
Server Machine，将使用中等数量内存;
Dedicated MySQL Server Machine，这台服务器上面只跑mysql数据库，将占用全部的内存。
可以根据自己需求选择，这里我们选择第二种“Server Machine”-“next”
选择数据库用途，同样有3个选项：
Mutltifunctional Database多功能用途，将把数据库优化成很好的innodb存储类型和高效率的myisam存储类型;
Transactional Database Only只用于事务处理类型，最好的优化innodb，但同时也支持myisam;
Non-Transactional Databse Only非事务处理类型，适合于简单的应用，只有不支持事务的myisam类型是被支持的。
一般选择第一种多功能的，同样我们也是。-“next”
选择InnodDB的数据存放位置，一般默认就行，为了统一我填写了“WAMP/MySQL Datafiles”-“next”
选择mysql允许的最大连接数，第一种是最大20个连接并发数，第二种是最大500个并发连接数，最后一种是自定义，自己可以根据需求选择，我选择第二个-“next”
下面是选择数据库监听的端口，一般默认是3306，如果改成其他端口，以后连接数据库的时候都要记住修改的端口，否则不能连接mysql数据库，比较麻烦，这里不做修改，用mysq的默认端口：3306-“next”
这一步设置mysql的默认编码，我们选择第三个，并在Character Set菜单中，选择“gbk”编码-“next”
(注：如果要用原来数据库的数据，最好能确定原来数据库用的是什么编码，如果这里设置的编码和原来数据库数据的编码不一致，在使用的时候可能会出现乱码。)
这一步是是否要把mysql设置成windows的，一般选择设成服务，这样以后就可以通过服务中启动和关闭mysql数据库。下面的复选框也勾选上，这样，在cmd模式下，不必非到mysql的bin目录下执行命令。也就是把上下2个勾都打上，中间默认-“next”
这一步是设置mysql的超级用户密码，这个超级用户非常重要，对mysql拥有全部的权限，请设置好并牢记超级用户的密码，下面有个复选框是选择是否允许远程机器用root用户连接到你的mysql服务器上面，如果有这个需求，也请勾选。这里我们使用默认选择，在New root password和Confirm中输入密码。“next”
点击“execute”进行配置，稍微等待一会，圆点上的勾全部打上，就代表配置完毕。
2.修改配置：
打开D:\WAMP\MySQL\my.ini
设置datadir为D:/WAMP/MySQL/data/或你所要存放数据位置的目录即可。
三、PHP安装
版本解释：VC9 专门为IIS定值的脚本，使用Visual Studio 2008编译器编译，支持最新的微软组建，从而提高效率。
VC6 是为了其他WEB服务软件提供的脚本 如 Apache。
Thread Safe 现成安全，之星时会进行线程 安全检查，以防止有心要求就启动新线程(Thread)的CGI执行方式而耗尽系统资源。
Non Thread Safe是非线程安全，在执行时不进行线程(Thread)安全检查
选择版本：PHP5.3(5.3.1)中VC6 x86 Thread Safe下 ZIP下载
下载地址：http://windows.php.net/download/
1.安装说明
由于我们下载的的是ZIP压缩包，只需要将文件解压到“D:\WAMP\PHP”目录下即可
2.修改配置
将E:\WAMP\PHP\php.ini-development 文件修改成php.ini
打开php.ini
; extension_dir = “ext”
修改成：extension_dir = “E:\WAMP\PHP\ext”
将947行下，这些文件前面的“;”去除
extension=php_curl.dll
extension=php_gd2.dll
extension=php_mbstring.dll
extension=php_mysql.dll
extension=php_mysqli.dll
extension=php_pdo_mysql.dll
extension=php_xmlrpc.dll
;date.timezone =
修改成(很多网站没提到这里要修改，默认为美国时间，如果不修改会报错)：date.timezone = Asia/Shanghai
3.测试
重启Apache(修改过配置文件 必须重启Apache才会生效)
新建个index.php 页面，代码中输入，保存文件放到“D:\WMAP\www\”目录下
打开浏览器输入：http://localhost/index.php 如果能正常显示，说明PHP配置完毕，可以查看该页面的PHP信息是否正确。
(注：在改文件中输入函数可输出大量的有关PHP当前状态的信息，如PHP版本，服务器信息和环境等。)
(注：)
接着我们测试下，是否能连接到Mysql
再新建个link.php，下代码中输入
$link=mysql_connect(“127.0.0.1″,”root”,”Mysql安装时填写的密码”);
if(!$link) echo “Mysql数据库连接失败!”;
else echo “Mysql数据库连接成功!”;
mysql_close();
?>
也保存文件放到“D:\WMAP\www\”目录下
打开浏览器输入：http://localhost/link.php 查看
四、PhpMyAdmin安装
版本解释：phpMyAdmin-3.2.5
选择版本：phpMyAdmin-3.2.5-all-languages.zip
下载地址：http://www.phpmyadmin.net/home_page/downloads.php
1.安装说明
解压到D:\WAMP\phpMyAdmin
2.修改配置
打开D:\WAMP\phpMyAdmin\libraries\config.default.php
$cfg['PmaAbsoluteUri'] = ”;
修改成(填写访问phpMyAdmin的绝对URL)：$cfg['PmaAbsoluteUri'] = ‘http://localhost/PHPMyadmin/’;
$cfg['Servers'][$i]['host'] = ‘localhost’;
修改成(填写服务器地址，通常默认，不需要修改)：$cfg['Servers'][$i]['host'] = ‘localhost’;
$cfg['Servers'][$i]['user'] = ‘root’;
修改成(填写Mysql用户名，这里我们默认)：$cfg['Servers'][$i]['user'] = ‘root’;
$cfg['Servers'][$i]['password'] = ”;
修改成(填写Mysql密码)：$cfg['Servers'][$i]['password'] = ‘Mysql PWD;
$cfg['Servers'][$i]['auth_type'] = ‘cookie’;
修改成(设置认证方法，安全因素考虑，填写成cookie)：$cfg['Servers'][$i]['auth_type'] = ‘cookie’;
$cfg['blowfish_secret'] = ”;
修改成(设置短语密码，如果上面设置成cookie，那这里不能留空，不然登陆会提示错误)：$cfg['blowfish_secret'] = ‘cookie’;
3.测试
打开浏览器输入：http://localhost/phpmyadmin/ 访问和登陆

⑦ 如何将php5.2升级为php5.3

简单的步骤：
下载
php5
.3文件（最好是免安装版）
替换php5.3文件，或者放到别的地方
配置php5.3
配置文件
配置apache配置文件
配置系统
环境变量
重启apache
OK了
1
下载php5.3
下载地址：
我的原来的php文件放在D:\phpEnv\php5.2
如果其他版本我也都放在phpEnv目录下，只需要修改apache配置文件就可以调用相应的php版本文件了
2
配置php5.3
在d:\php目录下把php.ini-development文件改名为php.ini
这是PHP
5.3的一个改变，另外一个文件php.ini-proction是用于产品运行的典型配置。
接着我们打开php.
ini文件
，定义扩展包的路径。
查找“extension_dir”，修改为：
extension_dir
=
“d:\php\ext”
下面的配置可以根据自己所需来配置，这里不多说了：
extension=php_curl.dll
extension=php_gd2.dll
extension=php_mbstring.dll
extension=php_mysql.dll
extension=php_mysqli.dll
extension=php_pdo_mysql.dll
extension=php_xmlrpc.dll
3
配置Apache2.2
打开Apache的httpd.conf文件，因为是5.2系统的时候已经把apache配置好了，这里就不多说了。现在直接替换下面配置就行了。如果还不知道如何配置apache，
请参考：Apache2.2.x+PHP5.3.x+MySQL5.1.x
搭建WMAP运行环境
找到原来的配置文件，在126行左右：
#LoadMole
vhost_alias_mole
moles/mod_vhost_alias.so下面
LoadMole
php5_mole
D:/phpEnv/php5.2/php5
apache2
_2.dll
PHPIniDir
"D:/phpEnv/php5.2"
改成
LoadMole
php5_mole
D:/phpEnv/php5.3/php5apache2_2.dll
PHPIniDir
"D:/phpEnv/php5.3"
这样apache的配置文件就改好了
4
修改
系统环境
变量
这里因为没有把php的
dll文件
拷贝到
系统盘
，所以还需要配置一下系统的环境变量
右击
我的电脑：属性-高级系统设置-环境变量-
系统变量
-双击Path
找到D:\phpEnv\php5.2;D:\phpEnv\php5.2\ext;
因为原来是php5.2的，现在只需将5.2改为5.3即可，如下：
D:\phpEnv\php5.3;D:\phpEnv\php5.3\ext;
保存一下；
5
测试完成
在apache的htdocs目录中新建index.php
输入内容：

phpinfo();
?>
然后重启Apache2。输入http://
localhost
即可访问

⑧ php配置虚拟主机怎么还是localhost

在phpmyadmin中创建用户时,如果主机选本机就可以用localhost;

如果选文本域,就是用一串字符域名,指定的.

⑨ 大型的PHP应用，通常使用什么应用做消息队列

一、消息队列概述x0dx0a消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。x0dx0a目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等。x0dx0a二、消息队列应用场景x0dx0a以下介绍消息队列在实际应用中常用的使用场景。异步处理，应用解耦，流量削锋和消息通讯四个场景。x0dx0a2.1异步处理x0dx0a场景说明：用户注册后，需要发注册邮件和注册短信。传统的做法有两种1.串行的方式；2.并行方式。x0dx0a（1）串行方式：将注册信息写入数据库成功后，发送注册邮件，再发送注册短信。以上三个任务全部完成后，返回给客户端。（架构KKQ：466097527，欢迎加入）x0dx0a（2）并行方式：将注册信息写入数据库成功后，发送注册邮件的同时，发送注册短信。以上三个任务完成后，返回给客户端。与串行的差别是，并行的方式可以提高处理的时间。x0dx0a假设三个业务节点每个使用50毫秒钟，不考虑网络等其他开销，则串行方式的时间是150毫秒，并行的时间可能是100毫秒。x0dx0a因为CPU在单位时间内处理的请求数是一定的，假设CPU1秒内吞吐量是100次。则串行方式1秒内CPU可处理的请求量是7次（1000/150）。并行方式处理的请求量是10次（1000/100）。x0dx0a小结：如以上案例描述，传统的方式系统的性能（并发量，吞吐量，响应时间）会有瓶颈。如何解决这个问题呢？x0dx0a引入消息队列，将不是必须的业务逻辑，异步处理。改造后的架构如下：x0dx0a按照以上约定，用户的响应时间相当于是注册信息写入数据库的时间，也就是50毫秒。注册邮件，发送短信写入消息队列后，直接返回，因此写入消息队列的速度很快，基本可以忽略，因此用户的响应时间可能是50毫秒。因此架构改变后，系统的吞吐量提高到每秒20 QPS。比串行提高了3倍，比并行提高了两倍。x0dx0a2.2应用解耦x0dx0a场景说明：用户下单后，订单系统需要通知库存系统。传统的做法是，订单系统调用库存系统的接口。如下图：x0dx0a传统模式的缺点：x0dx0a1） 假如库存系统无法访问，则订单减库存将失败，从而导致订单失败；x0dx0a2） 订单系统与库存系统耦合；x0dx0a如何解决以上问题呢？引入应用消息队列后的方案，如下图：x0dx0a订单系统：用户下单后，订单系统完成持久化处理，将消息写入消息队列，返回用户订单下单成功。x0dx0a库存系统：订阅下单的消息，采用拉/推的方式，获取下单信息，库存系统根据下单信息，进行库存操作。x0dx0a假如：在下单时库存系统不能正常使用。也不影响正常下单，因为下单后，订单系统写入消息队列就不再关心其他的后续操作了。实现订单系统与库存系统的应用解耦。x0dx0a2.3流量削锋x0dx0a流量削锋也是消息队列中的常用场景，一般在秒杀或团抢活动中使用广泛。x0dx0a应用场景：秒杀活动，一般会因为流量过大，导致流量暴增，应用挂掉。为解决这个问题，一般需要在应用前端加入消息队列。x0dx0a可以控制活动的人数；x0dx0a可以缓解短时间内高流量压垮应用；x0dx0a用户的请求，服务器接收后，首先写入消息队列。假如消息队列长度超过最大数量，则直接抛弃用户请求或跳转到错误页面；x0dx0a秒杀业务根据消息队列中的请求信息，再做后续处理。x0dx0a2.4日志处理x0dx0a日志处理是指将消息队列用在日志处理中，比如Kafka的应用，解决大量日志传输的问题。架构简化如下：x0dx0a日志采集客户端，负责日志数据采集，定时写受写入Kafka队列；x0dx0aKafka消息队列，负责日志数据的接收，存储和转发；x0dx0a日志处理应用：订阅并消费kafka队列中的日志数据；x0dx0a以下是新浪kafka日志处理应用案例：x0dx0a(1)Kafka：接收用户日志的消息队列。x0dx0a(2)Logstash：做日志解析，统一成JSON输出给Elasticsearch。x0dx0a(3)Elasticsearch：实时日志分析服务的核心技术，一个schemaless，实时的数据存储服务，通过index组织数据，兼具强大的搜索和统计功能。x0dx0a(4)Kibana：基于Elasticsearch的数据可视化组件，超强的数据可视化能力是众多公司选择ELK stack的重要原因。x0dx0a2.5消息通讯x0dx0a消息通讯是指，消息队列一般都内置了高效的通信机制，因此也可以用在纯的消息通讯。比如实现点对点消息队列，或者聊天室等。x0dx0a点对点通讯：x0dx0a客户端A和客户端B使用同一队列，进行消息通讯。x0dx0a聊天室通讯：x0dx0a客户端A，客户端B，客户端N订阅同一主题，进行消息发布和接收。实现类似聊天室效果。x0dx0a以上实际是消息队列的两种消息模式，点对点或发布订阅模式。模型为示意图，供参考。x0dx0a三、消息中间件示例x0dx0a3.1电商系统x0dx0a消息队列采用高可用，可持久化的消息中间件。比如Active MQ，Rabbit MQ，Rocket Mq。（1）应用将主干逻辑处理完成后，写入消息队列。消息发送是否成功可以开启消息的确认模式。（消息队列返回消息接收成功状态后，应用再返回，这样保障消息的完整性）x0dx0a（2）扩展流程（发短信，配送处理）订阅队列消息。采用推或拉的方式获取消息并处理。x0dx0a（3）消息将应用解耦的同时，带来了数据一致性问题，可以采用最终一致性方式解决。比如主数据写入数据库，扩展应用根据消息队列，并结合数据库方式实现基于消息队列的后续处理。x0dx0a3.2日志收集系统x0dx0a分为Zookeeper注册中心，日志收集客户端，Kafka集群和Storm集群（OtherApp）四部分组成。x0dx0aZookeeper注册中心，提出负载均衡和地址查找服务；x0dx0a日志收集客户端，用于采集应用系统的日志，并将数据推送到kafka队列；x0dx0a四、JMS消息服务x0dx0a讲消息队列就不得不提JMS 。JMS（Java Message Service,Java消息服务）API是一个消息服务的标准/规范，允许应用程序组件基于JavaEE平台创建、发送、接收和读取消息。它使分布式通信耦合度更低，消息服务更加可靠以及异步性。x0dx0a在EJB架构中，有消息bean可以无缝的与JM消息服务集成。在J2EE架构模式中，有消息服务者模式，用于实现消息与应用直接的解耦。x0dx0a4.1消息模型x0dx0a在JMS标准中，有两种消息模型P2P（Point to Point）,Publish/Subscribe(Pub/Sub)。x0dx0a4.1.1 P2P模式x0dx0aP2P模式包含三个角色：消息队列（Queue），发送者(Sender)，接收者(Receiver)。每个消息都被发送到一个特定的队列，接收者从队列中获取消息。队列保留着消息，直到他们被消费或超时。x0dx0aP2P的特点x0dx0a每个消息只有一个消费者（Consumer）(即一旦被消费，消息就不再在消息队列中)x0dx0a发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列x0dx0a接收者在成功接收消息之后需向队列应答成功x0dx0a如果希望发送的每个消息都会被成功处理的话，那么需要P2P模式。（架构KKQ：466097527，欢迎加入）x0dx0a4.1.2 Pub/sub模式x0dx0a包含三个角色主题（Topic），发布者（Publisher），订阅者（Subscriber） 。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。x0dx0aPub/Sub的特点x0dx0a每个消息可以有多个消费者x0dx0a发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息。x0dx0a为了消费消息，订阅者必须保持运行的状态。x0dx0a为了缓和这样严格的时间相关性，JMS允许订阅者创建一个可持久化的订阅。这样，即使订阅者没有被激活（运行），它也能接收到发布者的消息。x0dx0a如果希望发送的消息可以不被做任何处理、或者只被一个消息者处理、或者可以被多个消费者处理的话，那么可以采用Pub/Sub模型。x0dx0a4.2消息消费x0dx0a在JMS中，消息的产生和消费都是异步的。对于消费来说，JMS的消息者可以通过两种方式来消费消息。x0dx0a（1）同步x0dx0a订阅者或接收者通过receive方法来接收消息，receive方法在接收到消息之前（或超时之前）将一直阻塞；x0dx0a（2）异步x0dx0a订阅者或接收者可以注册为一个消息监听器。当消息到达之后，系统自动调用监听器的onMessage方法。x0dx0aJNDI：Java命名和目录接口,是一种标准的Java命名系统接口。可以在网络上查找和访问服务。通过指定一个资源名称，该名称对应于数据库或命名服务中的一个记录，同时返回资源连接建立所必须的信息。x0dx0aJNDI在JMS中起到查找和访问发送目标或消息来源的作用。（架构KKQ：466097527，欢迎加入）x0dx0a4.3JMS编程模型x0dx0a(1) ConnectionFactoryx0dx0a创建Connection对象的工厂，针对两种不同的jms消息模型，分别有QueueConnectionFactory和TopicConnectionFactory两种。可以通过JNDI来查找ConnectionFactory对象。x0dx0a(2) Destinationx0dx0aDestination的意思是消息生产者的消息发送目标或者说消息消费者的消息来源。对于消息生产者来说，它的Destination是某个队列（Queue）或某个主题（Topic）;对于消息消费者来说，它的Destination也是某个队列或主题（即消息来源）。x0dx0a所以，Destination实际上就是两种类型的对象：Queue、Topic可以通过JNDI来查找Destination。x0dx0a(3) Connectionx0dx0aConnection表示在客户端和JMS系统之间建立的链接（对TCP/IP socket的包装）。Connection可以产生一个或多个Session。跟ConnectionFactory一样，Connection也有两种类型：QueueConnection和TopicConnection。x0dx0a(4) Sessionx0dx0aSession是操作消息的接口。可以通过session创建生产者、消费者、消息等。Session提供了事务的功能。当需要使用session发送/接收多个消息时，可以将这些发送/接收动作放到一个事务中。同样，也分QueueSession和TopicSession。x0dx0a(5) 消息的生产者x0dx0a消息生产者由Session创建，并用于将消息发送到Destination。同样，消息生产者分两种类型：QueueSender和TopicPublisher。可以调用消息生产者的方法（send或publish方法）发送消息。x0dx0a(6) 消息消费者x0dx0a消息消费者由Session创建，用于接收被发送到Destination的消息。两种类型：QueueReceiver和TopicSubscriber。可分别通过session的createReceiver(Queue)或createSubscriber(Topic)来创建。当然，也可以session的creatDurableSubscriber方法来创建持久化的订阅者。x0dx0a(7) MessageListenerx0dx0a消息监听器。如果注册了消息监听器，一旦消息到达，将自动调用监听器的onMessage方法。EJB中的MDB（Message-Driven Bean）就是一种MessageListener。x0dx0a深入学习JMS对掌握JAVA架构，EJB架构有很好的帮助，消息中间件也是大型分布式系统必须的组件。本次分享主要做全局性介绍，具体的深入需要大家学习，实践，总结，领会。x0dx0a五、常用消息队列x0dx0a一般商用的容器，比如WebLogic，JBoss，都支持JMS标准，开发上很方便。但免费的比如Tomcat，Jetty等则需要使用第三方的消息中间件。本部分内容介绍常用的消息中间件（Active MQ,Rabbit MQ，Zero MQ,Kafka）以及他们的特点。x0dx0a5.1 ActiveMQx0dx0aActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现，尽管JMS规范出台已经是很久的事情了，但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。x0dx0aActiveMQ特性如下：x0dx0a⒈ 多种语言和协议编写客户端。语言: Java,C,C++,C#,Ruby,Perl,Python,PHP。应用协议： OpenWire,Stomp REST,WS Notification,XMPP,AMQPx0dx0a⒉ 完全支持JMS1.1和J2EE 1.4规范 （持久化，XA消息，事务)x0dx0a⒊ 对spring的支持，ActiveMQ可以很容易内嵌到使用Spring的系统里面去，而且也支持Spring2.0的特性x0dx0a⒋ 通过了常见J2EE服务器（如 Geronimo,JBoss 4,GlassFish,WebLogic)的测试，其中通过JCA 1.5 resource adaptors的配置，可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上x0dx0a⒌ 支持多种传送协议：in-VM,TCP,SSL,NIO,UDP,JGroups,JXTAx0dx0a⒍ 支持通过JDBC和journal提供高速的消息持久化x0dx0a⒎ 从设计上保证了高性能的集群，客户端-服务器，点对点x0dx0a⒏ 支持Ajaxx0dx0a⒐ 支持与Axis的整合x0dx0a⒑ 可以很容易得调用内嵌JMS provider，进行测试x0dx0a5.2 RabbitMQx0dx0aRabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX，持久化。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。x0dx0a几个重要概念：x0dx0aBroker：简单来说就是消息队列服务器实体。x0dx0aExchange：消息交换机，它指定消息按什么规则，路由到哪个队列。x0dx0aQueue：消息队列载体，每个消息都会被投入到一个或多个队列。x0dx0aBinding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来。x0dx0aRouting Key：路由关键字，exchange根据这个关键字进行消息投递。x0dx0avhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。x0dx0aprocer：消息生产者，就是投递消息的程序。x0dx0aconsumer：消息消费者，就是接受消息的程序。x0dx0achannel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务。x0dx0a消息队列的使用过程，如下：x0dx0a（1）客户端连接到消息队列服务器，打开一个channel。x0dx0a（2）客户端声明一个exchange，并设置相关属性。x0dx0a（3）客户端声明一个queue，并设置相关属性。x0dx0a（4）客户端使用routing key，在exchange和queue之间建立好绑定关系。x0dx0a（5）客户端投递消息到exchange。x0dx0aexchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里。x0dx0a5.3 ZeroMQx0dx0a号称史上最快的消息队列，它实际类似于Socket的一系列接口，他跟Socket的区别是：普通的socket是端到端的（1:1的关系），而ZMQ却是可以N：M 的关系，人们对BSD套接字的了解较多的是点对点的连接，点对点连接需要显式地建立连接、销毁连接、选择协议（TCP/UDP）和处理错误等，而ZMQ屏蔽了这些细节，让你的网络编程更为简单。ZMQ用于node与node间的通信，node可以是主机或者是进程。x0dx0a引用官方的说法： “ZMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层，像框架一样的一个socket library，他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。ZMQ的明确目标是“成为标准网络协议栈的一部分，之后进入Linux内核”。现在还未看到它们的成功。但是，它无疑是极具前景的、并且是人们更加需要的“传统”BSD套接字之上的一 层封装。ZMQ让编写高性能网络应用程序极为简单和有趣。”x0dx0a特点是：x0dx0a高性能，非持久化；x0dx0a跨平台：支持Linux、Windows、OS X等。x0dx0a多语言支持； C、C++、Java、.NET、Python等30多种开发语言。x0dx0a可单独部署或集成到应用中使用；x0dx0a可作为Socket通信库使用。x0dx0a与RabbitMQ相比，ZMQ并不像是一个传统意义上的消息队列服务器，事实上，它也根本不是一个服务器，更像一个底层的网络通讯库，在Socket API之上做了一层封装，将网络通讯、进程通讯和线程通讯抽象为统一的API接口。支持“Request-Reply “，”Publisher-Subscriber“，”Parallel Pipeline”三种基本模型和扩展模型。x0dx0aZeroMQ高性能设计要点：x0dx0a1、无锁的队列模型x0dx0a对于跨线程间的交互（用户端和session）之间的数据交换通道pipe，采用无锁的队列算法CAS；在pipe两端注册有异步事件，在读或者写消息到pipe的时，会自动触发读写事件。x0dx0a2、批量处理的算法x0dx0a对于传统的消息处理，每个消息在发送和接收的时候，都需要系统的调用，这样对于大量的消息，系统的开销比较大，zeroMQ对于批量的消息，进行了适应性的优化，可以批量的接收和发送消息。x0dx0a3、多核下的线程绑定，无须CPU切换x0dx0a区别于传统的多线程并发模式，信号量或者临界区， zeroMQ充分利用多核的优势，每个核绑定运行一个工作者线程，避免多线程之间的CPU切换开销。x0dx0a5.4 Kafkax0dx0aKafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。 这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。 对于像Hadoop的一样的日志数据和离线分析系统，但又要求实时处理的限制，这是一个可行的解决方案。Kafka的目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理，也是为了通过集群机来提供实时的消费。x0dx0aKafka是一种高吞吐量的分布式发布订阅消息系统，有如下特性：x0dx0a通过O(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。（文件追加的方式写入数据，过期的数据定期删除）x0dx0a高吞吐量：即使是非常普通的硬件Kafka也可以支持每秒数百万的消息。x0dx0a支持通过Kafka服务器和消费机集群来分区消息。x0dx0a支持Hadoop并行数据加载。x0dx0aKafka相关概念x0dx0aBrokerx0dx0aKafka集群包含一个或多个服务器，这种服务器被称为broker[5]x0dx0aTopicx0dx0a每条发布到Kafka集群的消息都有一个类别，这个类别被称为Topic。（物理上不同Topic的消息分开存储，逻辑上一个Topic的消息虽然保存于一个或多个broker上但用户只需指定消息的Topic即可生产或消费数据而不必关心数据存于何处）x0dx0aPartitionx0dx0aParition是物理上的概念，每个Topic包含一个或多个Partition.x0dx0aProcerx0dx0a负责发布消息到Kafka brokerx0dx0aConsumerx0dx0a消息消费者，向Kafka broker读取消息的客户端。x0dx0aConsumer Groupx0dx0a每个Consumer属于一个特定的Consumer Group（可为每个Consumer指定group name，若不指定group name则属于默认的group）。x0dx0a一般应用在大数据日志处理或对实时性（少量延迟），可靠性（少量丢数据）要求稍低的场景使用。