appserver-io/stomp-mq-adapter

Stomp 消息队列适配器

v0.9-beta 2015-03-24 18:05 UTC

This package is auto-updated.

Last update: 2024-08-29 03:20:58 UTC


README

Build Status Scrutinizer Code Quality Code Coverage

可以接收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

待办事项

  • 更好的文档
  • 示例(教程)