phpsocketssl

⑴ 请问一下，php配置SMTP怎么弄

PHPMailer的获取：

PHPMailer项目地址：PHPMailer 使用git命令克隆到本地，或直接在该项目页面的右下方点击“ Download ZIP ”即可获取到完整的PHPMailer代码包，再到本地解压即可。

步骤一：使我们的QQ邮箱能够发送邮件

这里怎么说能够发送邮件呢？其实我们的邮箱都是可以发送邮件的，但是要实现在我们的网站中发送邮件，那就要设置一下我们的QQ邮箱了，因为此时我们的网站现在是作为一个第三方客户端存在的。

步骤一：使我们的QQ邮箱能够发送邮件

这里怎么说能够发送邮件呢？其实我们的邮箱都是可以发送邮件的，但是要实现在我们的网站中发送邮件，那就要设置一下我们的QQ邮箱了，因为此时我们的网站现在是作为一个第三方客户端存在的

• 由于待会我们用到的是SMTP服务器来发送，在这里建议把前面的两项开启了！当你点击开启的时候，它会提示：

<?phprequire_once("./functions.php");$flag=sendMail('456789@qq.com','lsgo在线通知','恭喜你成功加入LSGO实验室，开启你的学习之旅吧！');if($flag){echo"发送邮件成功！";
}else{echo"发送邮件失败！";
}?>

⑵ php涓轰粈涔堜笉阃傚悎socket


浣滀负涓钖嶉潪搴曞眰绋嫔簭锻桡纴瑕佹兂娣卞叆浜呜Вsocket镄勫唴閮ㄥ疄鐜版満鍒舵槸寰埚汹闅剧殑锛屾垜浠鍙闇鏄庣槠socket鏄涓濂楁搷浣灭郴缁熷皝瑁呭ソ镄勫疄鐜拌繘绋嬮氢俊镄勫嚱鏁帮纴浼氩垱寤哄拰璋幂敤灏卞熶简銆

PHP镄勮瑷鐗规у拰镊韬瀹氢綅鍐冲畾浜嗗畠鍙阃傚悎锅歴ocket瀹㈡埛绔锛岃屼笉阃傚悎锅歴ocket链嶅姟鍣ㄧ銆
锲犱负socket涓昏侀溃钖戝簳灞傚拰缃戠粶链嶅姟寮鍙戯纴涓鑸链嶅姟鍣ㄧ閮芥槸鐢 C 鎴 java 绛夎瑷瀹炵幇锛岃繖镙疯兘镟村ソ鍦版搷浣滃簳灞傦纴瀵圭绣缁沧湇锷″紑鍙戜腑阆囧埌镄勯梾棰桡纸濡傚苟鍙戙侀樆濉炵瓑锛変篃链夋垚镡熷畬锽勭殑瑙ｅ喅鏂规堬纴钥孭HP鏄剧劧涓嶉傚悎杩欑嶅簲鐢ㄥ満鏅銆 锛堟帹钻愬︿範锛歅HP瑙嗛戞暀绋嬶级
瀹为檯涓婏纴PHP镎崭綔MySQL鏁版嵁搴扑篃鏄阃氲繃socket杩涜岀殑锛岃繖姝ｆ槸鐢变簬socket灞忚斀浜嗗簳灞傜殑鍗忚锛屼娇寰楃绣缁沧湇锷′箣闂寸殑浜掕仈浜挜氩彉寰楃亩鍗曘

闄や简浼犵粺镄勬湇锷″櫒绔璇瑷瀹炵幇镄剆ocket澶栵纴闅忕潃HTML5镄勬祦琛岋纴娴忚埚櫒瀹㈡埛绔瀹炵幇镄刉ebSocket涔熼愭笎鍏磋捣锛屽逛簬杩欎竴镣瑰煎缑鍏虫敞锛孎lashSocket涔熸槸涓涓涓嶉敊镄勮В鍐虫柟妗堛

瑕佸湪瀹㈡埛绔镎崭綔socket锛屽彲浣跨敤fsockopen銆乻ocket_create 鎴 stream_socket_client 绛夊嚱鏁板疄鐜帮纴濡傛灉鏄疨HP5锛屾帹钻愪娇鐢╯tream_socket_client銆

socket浜や簰搴旂敤瀹炰緥锛氢娇鐢╯ocket鎻愪氦琛ㄥ崟

鏂板缓涓涓 test.php 鏂囦欢锛屽悜 http://demo.com/index.php?id=1 鎻愪氦琛ㄥ崟鏁版嵁锛屼唬镰佸备笅锛
<?php
$data = array('comment'=>'this is a robot comment');
$data = http_build_query($data);

$out = "POST http://demo.com/index.php?id=1 HTTP/1.1 "; // 阃氲繃POST鏂瑰纺鍙戦佹暟鎹
$out .= "Host: demo.com ";
$out .= "Content-type: application/x-www-form-urlencoded; charset=UTF-8 ";
$out .= "Content-length: ".strlen($data)." ";
$out .= "User-Agent: Mozilla/5.0 (Windows NT 6.1; rv:48.0) Gecko/20100101 Firefox/48.0"." ";
$out .= "Connection: close"." "." "; // 娉ㄦ剰锛氭ゅ勬湁涓や釜

$out .= $data." "; // 姝ｆ枃鏁版嵁

$fp = fsockopen("demo.com", 80, $errno, $errstr, 30); // 鍒涘缓socket瀹㈡埛绔杩炴帴

// $fp = stream_socket_client("tcp://demo.com:80", $errno, $errstr, 30); 鎺ㄨ崘杩欑嶅啓娉

fwrite($fp, $out); // 钖戞湇锷″櫒鍙戦佹暟鎹

while (!feof($fp)) {
echo fgets($fp, 1280); // 璇诲彇链嶅姟鍣ㄥ搷搴旂殑鏁版嵁
}
fclose($fp); // 鍏抽棴socket杩炴帴
?>闇瑕佹敞镒忎互涓嫔嚑镣癸细
fsockopen镄勭涓涓鍙傛暟锛屼篃鍙浠ヤ娇鐢↖P鍦板潃锛屼笉瑕佸甫 http:// 瀛楃︿覆锛岄櫎闱炰娇鐢⊿SL绛
璇锋眰澶达纸headers锛変笉涓瀹氲佸甫涓婃墍链夌殑澶村烟锛屼竴鑸鍙闇甯︿笂鍑犱釜镙稿绩镄删eader鍗冲彲
鍦ㄦ渶钖庝竴涓猦eader澶勶纴鍗 Connection 钖庢湁涓や釜鎹㈣
娉ㄦ剰缂栫爜闂棰

⑶ php连接mysql数据库，报错Function mysql_connect() is deprecated

info.php在CentOS
64位虚拟机运行的时候，其中MySQL版本那一栏是空白信息。我查看了info.php源码，开始以为是MySQL数据库的用户名和密码填写错了，仔细检查没有错误之后,便查看了Apache的error_log，得到如下消息：
mysql_connect():
No
such
file
or
directory
在网上查了一下，说是本地socket设置与默认的不一样，导致php无法找到mysql的socket文件。根据网上提供的方法，需要做如下操作。
首先，在MySQL中用status查看数据库状态，如下所示：
mysql
Ver
14.14
Distrib
5.1.69,
for
redhat-linux-gnu
(x86_64)
using
readline
5.1
Connection
id:
10
Current
database:
Current
user:
root@localhost
SSL:
Not
in
use
Current
pager:
stdout
Using
outfile:
''
Using
delimiter:
;
Server
version:
5.1.69
Source
distribution
Protocol
version:
10
Connection:
Localhost
via
UNIX
socket
Server
characterset:
latin1
Db
characterset:
latin1
Client
characterset:
latin1
Conn.
characterset:
latin1
UNIX
socket:
/var/lib/mysql/mysql.sock
Uptime:
20
hours
55
min
30
sec
其中，标红的部分是我们需要的。然后打开php.ini文件，需要将mysql.default_socket、mysqli.default_socket、pdo_mysql.default_socket的值设置为标红后面的那个目录。重启apache服务器，后续info.php工作正常，MySQL的版本信息能够正常显示了。

⑷ PHP 连接数据库什么情况下才会用到持久链接 mysql_pconnect()

PHP 连接数据库有两种方式：mysql_connect() 和 mysql_pconnect() 。下面分别介绍使用的不同之处：

1、mysql_pconnect() 函数打开一个到 MySQL 服务器的持久连接。

2、mysql_pconnect() 和 mysql_connect() 非常相似，但有两个主要区别：

1.当连接的时候本函数将先尝试寻找一个在同一个主机上用同样的用户名和密码已经打开的（持久）连接，如果找到，则返回此连接标识而不打开新连接。
2.其次，当脚本执行完毕后到 SQL 服务器的连接不会被关闭，此连接将保持打开以备以后使用（mysql_close() 不会关闭由 mysql_pconnect() 建立的连接）。
语法
mysql_pconnect(server,user,pwd,clientflag)参数 描述
server 可选。规定要连接的服务器。

可以包括端口号，例如 "hostname:port"，或者到本地套接字的路径，例如对于 localhost 的 ":/path/to/socket"。

如果 PHP 指令 mysql.default_host 未定义（默认情况），则默认值是 'localhost:3306'。

user 可选。用户名。默认值是服务器进程所有者的用户名。
pwd 可选。密码。默认值是空密码。
clientflag 可选。client_flags 参数可以是以下常量的组合：

•MYSQL_CLIENT_SSL - 使用 SSL 加密
•MYSQL_CLIENT_COMPRESS - 使用压缩协议
•MYSQL_CLIENT_IGNORE_SPACE - 允许函数名后的间隔
•MYSQL_CLIENT_INTERACTIVE - 允许关闭连接之前的交互超时非活动时间


返回值

如果成功，则返回一个 MySQL 持久连接标识符，出错则返回 FALSE。
提示和注释
注释：可选参数 clientflag 自 PHP 4.3.0 版起可用。

提示：要创建一个非持久连接，请使用 mysql_connect() 函数。
例子如下：



主要使用场合：

当db操纵错杂， 耗时较长时， 因httpd会fork很多并发过程处理惩罚， 而先产生的httpd过程不开释db连接， 使得后产生的httpd过程无法连上db. 因为如许没有复用其它httpd过程的mysql连接. 于是会就产生很多连接超时。 在并发接见量不高时，应用pconnect可以简单进步接见速度， 但在并发量增大后， 是否再应用pconnect就要见地度员的选择了.

⑸ WIN下如何在PHP扩展里打开openssl支持

在windows系统中IIS环境的操作方式：

1、在c:\windows\php.ini中
将;extension=php_openssl.dll前面分号(注释)去掉
2、复制php安装目录中的：
libeay32.dll
ssleay32.dll
至c:\windows\system32
3、复制PHP\ext目录中的php_openssl.dll至c:\windows\system32
4、重启IIS
其他操作方式：
windows下php开启openssl
用ci的email类发邮件的时候发现来是出现这么一个错误：
unable to connect to ssl
(Unable to find the socket transport “ssl” – did you forget to enable it when you configured PHP?)
不过在php.ini里也没有发现ssl的扩展，去apache里倒是有个ssl的扩展，不过一打开就启动不成功（应该是需要配置一些东西才行），后来发现php文件夹下有openssl的扩展，只是安装不成功，于是上网搜原因，最后终于解决了，有用资料如下：
1，要想开启mcrypt支持，系统需要安装了libmcrypt.dll库。
这个一般用户是没有安装过的，但不用担心，PHP的windows发行包里已经给我们附带了此文件，在PHP压缩包的根目录下即可找到，然后将其复制到%system%/system32目录下即可。
2，要想开启OpenSSL支持，系统需要安装libeay32.dll和ssleay32.dll两个库。
如果你以前安装过OpenSSL，那么你的系统目录中应该已经存在这两个文件；如果没有安装，PHP的windows发行包里同样附带了这两个文件，将其复制到%system%/system32目录下即可。
—AppServ Win32如何打开openssl——————–
1.打开c:/windows，里面有一个php.ini文件（AppServ居然将php的配置文件移到这里来！），然后在里面搜索 ;extension=php_openssl.dll ，把前面的逗号去掉。

2.进入AppServ的安装目录，到php文件夹里面，分别搜索 libeay32.dll 和 ssleay32.dll ，把它们复制到 c:/windows/system32 下面

3.重新启动 Apache，就可以了，

您也可以向我们团队发出请求，会有更专业的人来为您解答。

⑹ php怎么响应客户端发送http请求

http请求有get，post。
php发送http请求有三种方式[我所知道的有三种,有其他的告诉我]。
1. file_get_contents();详情见：http://www.jb51.net/article/41833.htm
2. curl发送请求。
3. fsocket发送。
下面说使用curl发送。
首先环境需要配置好curl组件。
在windows中让php支持curl比较简单：
在php.ini中将extension=php_curl.dll前面的分号去掉，
有人说需要将php根目录的libeay32.dll和ssleay32.dll需要拷贝到系统目录下去。我实验不拷贝也可以。
在linux中，如果使用源码安装，需要在make 之前，./configure --with-curl=path，
其中，path是你的 libcurl库的位置，比如你安装libcurl库之后，
path可能就是/usr/local/，libcurl可以是静态库，也可以是动态库。
注意libcurl库configure的时候，可以将一些不需要的功能去掉，
比如ssl , ldap等。在php configure的时候，会去检查libcurl中某些功能是否被开启，进而去相应地调整生成的php。

⑺ 如何使用php通过smtp发送邮件步骤

由于php没有提供现成的smtp函数，却提供了一个功能不甚灵活的mail()函数，这个函数需要服务器配置上的支持，并且不支持smtp验证，在很多场合无法正常的工作，因此不建议使用。

• 首先是使用telnet来连接本地的25端口，稍微熟悉点网络的人都知道smtp协议使用25端口，这也就是说，现在在连接本地的smtp服务器。

  
  

  
  

  
  

  <?php
  require_once'Mail.php';
  
  $conf['mail']=array(
  'host'=>'xx.xx.xx.xx',//smtp服务器地址，可以用ip地址或者域名
  'auth'=>true,//true表示smtp服务器需要验证，false代码不需要
  'username'=>'tester',//用户名
  'password'=>'retset'//密码
  );
  
  /***
  *使用$headers数组，可以定义邮件头的内容，比如使用$headers['Reply-To']可以定义回复地址
  *通过这种方式，可以很方便的定制待发送邮件的邮件头
  ***/
  $headers['From']='tester@domain.com';//发信地址
  $headers['To']='tester@domain.com';//收信地址
  $headers['Subject']='testmailsendbyphp';//邮件标题
  $mail_object=&Mail::factory('smtp',$conf['mail']);
  
  $body=<<<MSG//邮件正文
  helloworld!!!
  MSG;
  
  $mail_res=$mail_object->send($headers['To'],$headers,$body);//发送
  
  if(Mail::isError($mail_res)){//检测错误
  die($mail_res->getMessage());
  }
  ?>

  ⑻ 大型的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）。
  一般应用在大数据日志处理或对实时性（少量延迟），可靠性（少量丢数据）要求稍低的场景使用。

  ⑼ 消息中间件（一）MQ详解及四大MQ比较

  一、消息中间件相关知识

  1、概述

  消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。

  2、消息中间件的组成

  2.1 Broker

  消息服务器，作为server提供消息核心服务

  2.2 Procer

  消息生产者，业务的发起方，负责生产消息传输给broker，

  2.3 Consumer

  消息消费者，业务的处理方，负责从broker获取消息并进行业务逻辑处理

  2.4 Topic

  2.5 Queue

  2.6 Message

  消息体，根据不同通信协议定义的固定格式进行编码的数据包，来封装业务数据，实现消息的传输

  3 消息中间件模式分类

  3.1 点对点

  PTP点对点:使用queue作为通信载体

  说明：

  消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。

  消息被消费以后，queue中不再存储，所以消息消费者不可能消费到已经被消费的消息。 Queue支持存在多个消费者，但是对一个消息而言，只会有一个消费者可以消费。

  说明：

  queue实现了负载均衡，将procer生产的消息发送到消息队列中，由多个消费者消费。但一个消息只能被一个消费者接受，当没有消费者可用时，这个消息会被保存直到有一个可用的消费者。

  4 消息中间件的优势

  4.1 系统解耦

  交互系统之间没有直接的调用关系，只是通过消息传输，故系统侵入性不强，耦合度低。

  4.2 提高系统响应时间

  例如原来的一套逻辑，完成支付可能涉及先修改订单状态、计算会员积分、通知物流配送几个逻辑才能完成；通过MQ架构设计，就可将紧急重要（需要立刻响应）的业务放到该调用方法中，响应要求不高的使用消息队列，放到MQ队列中，供消费者处理。

  4.3 为大数据处理架构提供服务

  通过消息作为整合，大数据的背景下，消息队列还与实时处理架构整合，为数据处理提供性能支持。

  4.4 Java消息服务——JMS

  Java消息服务（Java Message Service，JMS）应用程序接口是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。

  5 消息中间件应用场景

  5.1 异步通信

  有些业务不想也不需要立即处理消息。消息队列提供了异步处理机制，允许用户把一个消息放入队列，但并不立即处理它。想向队列中放入多少消息就放多少，然后在需要的时候再去处理它们。

  5.2 解耦

  降低工程间的强依赖程度，针对异构系统进行适配。在项目启动之初来预测将来项目会碰到什么需求，是极其困难的。通过消息系统在处理过程中间插入了一个隐含的、基于数据的接口层，两边的处理过程都要实现这一接口，当应用发生变化时，可以独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。

  5.3 冗余

  有些情况下，处理数据的过程会失败。除非数据被持久化，否则将造成丢失。消息队列把数据进行持久化直到它们已经被完全处理，通过这一方式规避了数据丢失风险。许多消息队列所采用的”插入-获取-删除”范式中，在把一个消息从队列中删除之前，需要你的处理系统明确的指出该消息已经被处理完毕，从而确保你的数据被安全的保存直到你使用完毕。

  5.4 扩展性

  因为消息队列解耦了你的处理过程，所以增大消息入队和处理的频率是很容易的，只要另外增加处理过程即可。不需要改变代码、不需要调节参数。便于分布式扩容。

  5.5 过载保护

  在访问量剧增的情况下，应用仍然需要继续发挥作用，但是这样的突发流量无法提取预知；如果以为了能处理这类瞬间峰值访问为标准来投入资源随时待命无疑是巨大的浪费。使用消息队列能够使关键组件顶住突发的访问压力，而不会因为突发的超负荷的请求而完全崩溃。

  5.6 可恢复性

  系统的一部分组件失效时，不会影响到整个系统。消息队列降低了进程间的耦合度，所以即使一个处理消息的进程挂掉，加入队列中的消息仍然可以在系统恢复后被处理。

  5.7 顺序保证

  在大多使用场景下，数据处理的顺序都很重要。大部分消息队列本来就是排序的，并且能保证数据会按照特定的顺序来处理。

  5.8 缓冲

  在任何重要的系统中，都会有需要不同的处理时间的元素。消息队列通过一个缓冲层来帮助任务最高效率的执行，该缓冲有助于控制和优化数据流经过系统的速度。以调节系统响应时间。

  5.9 数据流处理

  分布式系统产生的海量数据流，如：业务日志、监控数据、用户行为等，针对这些数据流进行实时或批量采集汇总，然后进行大数据分析是当前互联网的必备技术，通过消息队列完成此类数据收集是最好的选择。

  6 消息中间件常用协议

  6.1 AMQP协议

  AMQP即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件的限制。

  优点：可靠、通用

  6.2 MQTT协议

  MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和致动器（比如通过Twitter让房屋联网）的通信协议。

  优点：格式简洁、占用带宽小、移动端通信、PUSH、嵌入式系统

  6.3 STOMP协议

  STOMP（Streaming Text Orientated Message Protocol）是流文本定向消息协议，是一种为MOM(Message Oriented Middleware，面向消息的中间件)设计的简单文本协议。STOMP提供一个可互操作的连接格式，允许客户端与任意STOMP消息代理（Broker）进行交互。

  优点：命令模式（非topicqueue模式）

  6.4 XMPP协议

  XMPP（可扩展消息处理现场协议，Extensible Messaging and Presence Protocol）是基于可扩展标记语言（XML）的协议，多用于即时消息（IM）以及在线现场探测。适用于服务器之间的准即时操作。核心是基于XML流传输，这个协议可能最终允许因特网用户向因特网上的其他任何人发送即时消息，即使其操作系统和浏览器不同。

  优点：通用公开、兼容性强、可扩展、安全性高，但XML编码格式占用带宽大

  6.5 其他基于TCP/IP自定义的协议

  有些特殊框架（如：redis、kafka、zeroMq等）根据自身需要未严格遵循MQ规范，而是基于TCPIP自行封装了一套协议，通过网络socket接口进行传输，实现了MQ的功能。

  7 常见消息中间件MQ介绍

  7.1 RocketMQ

  阿里系下开源的一款分布式、队列模型的消息中间件，原名Metaq，3.0版本名称改为RocketMQ，是阿里参照kafka设计思想使用java实现的一套mq。同时将阿里系内部多款mq产品（Notify、metaq）进行整合，只维护核心功能，去除了所有其他运行时依赖，保证核心功能最简化，在此基础上配合阿里上述其他开源产品实现不同场景下mq的架构，目前主要多用于订单交易系统。

  具有以下特点：

  官方提供了一些不同于kafka的对比差异：

  https://rocketmq.apache.org/docs/motivation/

  7.2 RabbitMQ

  使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP, SMTP,STOMP，也正是如此，使的它变的非常重量级，更适合于企业级的开发。同时实现了Broker架构，核心思想是生产者不会将消息直接发送给队列，消息在发送给客户端时先在中心队列排队。对路由(Routing)，负载均衡(Load balance)、数据持久化都有很好的支持。多用于进行企业级的ESB整合。

  7.3 ActiveMQ

  Apache下的一个子项目。使用Java完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现，少量代码就可以高效地实现高级应用场景。可插拔的传输协议支持，比如：in-VM, TCP, SSL, NIO, UDP, multicast, JGroups and JXTA transports。RabbitMQ、ZeroMQ、ActiveMQ均支持常用的多种语言客户端 C++、Java、.Net,、Python、 Php、 Ruby等。

  7.4 Redis

  使用C语言开发的一个Key-Value的NoSQL数据库，开发维护很活跃，虽然它是一个Key-Value数据库存储系统，但它本身支持MQ功能，所以完全可以当做一个轻量级的队列服务来使用。对于RabbitMQ和Redis的入队和出队操作，各执行100万次，每10万次记录一次执行时间。测试数据分为128Bytes、512Bytes、1K和10K四个不同大小的数据。实验表明：入队时，当数据比较小时Redis的性能要高于RabbitMQ，而如果数据大小超过了10K，Redis则慢的无法忍受；出队时，无论数据大小，Redis都表现出非常好的性能，而RabbitMQ的出队性能则远低于Redis。

  7.5 Kafka

  Apache下的一个子项目，使用scala实现的一个高性能分布式Publish/Subscribe消息队列系统，具有以下特性：

  7.6 ZeroMQ

  号称最快的消息队列系统，专门为高吞吐量/低延迟的场景开发，在金融界的应用中经常使用，偏重于实时数据通信场景。ZMQ能够实现RabbitMQ不擅长的高级/复杂的队列，但是开发人员需要自己组合多种技术框架，开发成本高。因此ZeroMQ具有一个独特的非中间件的模式，更像一个socket library，你不需要安装和运行一个消息服务器或中间件，因为你的应用程序本身就是使用ZeroMQ API完成逻辑服务的角色。但是ZeroMQ仅提供非持久性的队列，如果down机，数据将会丢失。如：Twitter的Storm中使用ZeroMQ作为数据流的传输。

  ZeroMQ套接字是与传输层无关的：ZeroMQ套接字对所有传输层协议定义了统一的API接口。默认支持 进程内(inproc) ，进程间(IPC) ，多播，TCP协议，在不同的协议之间切换只要简单的改变连接字符串的前缀。可以在任何时候以最小的代价从进程间的本地通信切换到分布式下的TCP通信。ZeroMQ在背后处理连接建立，断开和重连逻辑。

  特性：

  二、主要消息中间件的比较