appserver-io / stomp-mq-adapter
Stomp 消息队列适配器
v0.9-beta
2015-03-24 18:05 UTC
Requires
- php: >=5.4.0
- appserver-io-psr/epb: ~1.0
- appserver-io-psr/mop: ~1.0
- appserver-io-psr/naming: ~1.0
- appserver-io-psr/pms: ~1.0
- appserver-io/lang: ~1.0
- appserver-io/messaging: ~1.0
- appserver-io/server: ~1.0
- psr/log: ~1.0
Requires (Dev)
- appserver-io/build: ~1.0
This package is auto-updated.
Last update: 2024-08-29 03:20:58 UTC
README
可以接收stomp消息并将其发送到"Appserver.io消息队列"。
Mac安装
- 克隆仓库或下载ZIP文件
- 将以下行添加到 /opt/appserver/composer.json 中
"repositories": [ { "type":"vcs", "url":"/YOUR/PATH/stomp" } ], "require": { "appserver-io/stomp" : "dev-master" }
- 在 /opt/appserver 中运行命令 "sudo bin/php bin/composer.phar update"
- 将新的服务器节点添加到 /opt/appserver/etc/appserver/appserver.xml 中
<server name="stomp" type="\AppserverIo\Server\Servers\MultiThreadedServer" worker="\AppserverIo\Server\Workers\ThreadWorker" socket="\AppserverIo\Server\Sockets\StreamSocket" requestContext="\AppserverIo\Server\Contexts\RequestContext" serverContext="\AppserverIo\Server\Contexts\ServerContext" loggerName="System"> <params> <param name="admin" type="string">info@appserver.io</param> <param name="transport" type="string">tcp</param> <param name="address" type="string">127.0.0.1</param> <param name="port" type="integer">61613</param> <param name="workerNumber" type="integer">64</param> <param name="workerAcceptMin" type="integer">3</param> <param name="workerAcceptMax" type="integer">8</param> <param name="documentRoot" type="string">webapps</param> <param name="directoryIndex" type="string">index.pc</param> <param name="keepAliveMax" type="integer">64</param> <param name="keepAliveTimeout" type="integer">5</param> <param name="errorsPageTemplatePath" type="string">var/www/errors/error.phtml</param> </params> <environmentVariables> <environmentVariable condition="" definition="LOGGER_ACCESS=Access" /> </environmentVariables> <connectionHandlers> <connectionHandler type="\AppserverIo\Stomp\StompConnectionHandler" /> </connectionHandlers> <accesses> <!-- per default allow everything --> <access type="allow"> <params> <param name="X_REQUEST_URI" type="string">.*</param> </params> </access> </accesses> <!-- include of virtual host configurations --> <xi:include href="conf.d/virtual-hosts.xml"/> <modules> <!-- REQUEST_POST hook --> <module type="\AppserverIo\WebServer\Modules\AuthenticationModule"/> <module type="\AppserverIo\WebServer\Modules\VirtualHostModule"/> <module type="\AppserverIo\WebServer\Modules\EnvironmentVariableModule" /> <module type="\AppserverIo\WebServer\Modules\RewriteModule"/> <module type="\AppserverIo\WebServer\Modules\DirectoryModule"/> <module type="\AppserverIo\WebServer\Modules\AccessModule"/> <module type="\AppserverIo\WebServer\Modules\CoreModule"/> <module type="\AppserverIo\Appserver\PersistenceContainer\PersistenceContainerModule" /> <!-- RESPONSE_PRE hook --> <module type="\AppserverIo\WebServer\Modules\DeflateModule"/> <!-- RESPONSE_POST hook --> <module type="\AppserverIo\Appserver\Core\Modules\ProfileModule"/> </modules> </server>
- 重启Apserver
开发/部署
- 运行单元测试 => ant run-tests
待办事项
- 更好的文档
- 示例(教程)