此例基于RDKafka实现同步消息服务，引用依赖composer require usualtool/ut-kafka。

预先启动1个消费者监听：php usualtool kafka 192.168.0.1:9020 test
其服务器为192.168.0.1:9020，主题名称为test
那么生产者向对应消费者发送消息时，其示例为：
use usualtool\Kafka\Producer; $kafka = new Producer("192.168.0.1:9020","test"); //消息队列与数据同步的区别在于数据同步必然以数组形式出现且包含data,sql元素。 //数据同步服务 //删除同步：$data=array("data"=>"mssql","sql"=>"delete from users where id=1") //更新同步：$data=array("data"=>"mssql","sql"=>"update users set sex=1 where id=1") //增加同步：$data=array("data"=>"mssql","sql"=>"insert into users (sex) VALUES ('0')") //$kafka->Send(json_encode($data)); //消息队列服务 $kafka->Send("Hello,Hanmeimei.");