php slim skeleton 다운로드 php slim skeleton 소스 코드 다운로드

이벤트 중심 슬림 4 프레임 워크 골격

AMQP 및 CQRS를 사용한 이벤트 중심 슬림 4 프레임 워크 골격

설치

기본 설치 프로필

기본 설치 프로필에는 예제가 없습니다. 무슨 일인지 알고 깨끗한 슬레이트로 시작하려면이 프로필을 사용해야합니다.

 > composer create-project robiningelbrecht/php-slim-skeleton [app-name] --no-install --ignore-platform-reqs --stability=dev
# Build docker containers
> docker-compose up -d --build
# Install dependencies
> docker-compose run --rm php-cli composer install

전체 설치 프로필

전체 설치 프로필에는 완전한 작업 예제가 있습니다.

 > composer create-project robiningelbrecht/php-slim-skeleton:dev-master-with-examples [app-name] --no-install --ignore-platform-reqs --stability=dev
# Build docker containers
> docker-compose up -d --build
# Install dependencies
> docker-compose run --rm php-cli composer install
# Initialize example
> docker-compose run --rm php-cli composer example:init
# Start consuming the voting example queue
> docker-compose run --rm php-cli bin/console app:amqp:consume add-vote-command-queue

몇 가지 예

새 경로 등록

 namespace App  Controller ;

class UserOverviewRequestHandler
{
    public function __construct (
        private readonly UserOverviewRepository $ userOverviewRepository ,
    ) {
    }

    public function handle (
        ServerRequestInterface $ request ,
        ResponseInterface $ response ): ResponseInterface
    {
        $ users = $ this -> userOverviewRepository -> findonyBy ( /*...*/ );
        $ response -> getBody ()-> write ( /*...*/ );

        return $ response ;
    }
}

config/routes.php 로 가서 요청 처리기에 대한 경로를 추가하십시오.

 return function ( App $ app ) {
    // Set default route strategy.
    $ routeCollector = $ app -> getRouteCollector ();
    $ routeCollector -> setDefaultInvocationStrategy ( new RequestResponseArgs ());
    
    $ app -> get ( ' /user/overview ' , UserOverviewRequestHandler::class. ' :handle ' );
};

전체 문서

콘솔 명령

콘솔 응용 프로그램은 Symfony 콘솔 구성 요소를 사용하여 CLI 기능을 활용합니다.

#[AsCommand(name: ' app:user:create ' )]
class CreateUserConsoleCommand extends Command
{
    protected function execute ( InputInterface $ input , OutputInterface $ output ): int
    {
        // ...
        return Command:: SUCCESS ;
    }
}

전체 문서

도메인 명령 및 명령 처리기

골격을 사용하면 명령 및 명령 처리기를 사용하여 작업을 수행 할 수 있습니다. 이 2는 항상 쌍으로 제공되며, 쓰기 모델에서 새 명령을 만들 때 해당 명령 핸들러도 생성해야합니다.

새 명령 만들기

 namespace App  Domain  WriteModel  User  CreateUser ;

class CreateUser extends DomainCommand
{
 
}

해당 명령 핸들러 생성

 namespace App  Domain  WriteModel  User  CreateUser ;

#[AsCommandHandler]
class CreateUserCommandHandler implements CommandHandler
{
    public function __construct (
    ) {
    }

    public function handle ( DomainCommand $ command ): void
    {
        assert ( $ command instanceof CreateUser);

        // Do stuff.
    }
}

전체 문서

이벤트

이 프로젝트의 아이디어는 모든 것이 이벤트 중심이 될 수 있다는 것입니다. 이벤트 소싱은 기본적으로 제공되지 않습니다.

새 이벤트를 만듭니다

 class UserWasCreated extends DomainEvent
{
    public function __construct (
        private UserId $ userId ,
    ) {
    }

    public function getUserId (): UserId
    {
        return $ this -> userId ;
    }
}

이벤트를 녹음하십시오

 class User extends AggregateRoot
{
    private function __construct (
       private UserId $ userId ,
    ) {
    }

    public static function create (
        UserId $ userId ,
    ): self {
        $ user = new self ( $ userId );
        $ user -> recordThat ( new UserWasCreated ( $ userId ));

        return $ user ;
    }
}

이벤트를 게시하십시오

 class UserRepository extends DbalAggregateRootRepository
{
    public function add ( User $ user ): void
    {
        $ this -> connection -> insert ( /*...*/ );
        $ this -> publishEvents ( $ user -> getRecordedEvents ());
    }
}

이벤트를 들어보세요

#[AsEventListener(type: EventListenerType:: PROCESS_MANAGER )]
class UserNotificationManager extends ConventionBasedEventListener
{
   
    public function reactToUserWasCreated ( UserWasCreated $ event ): void
    {
        // Send out some notifications.
    }
}

전체 문서

RabbitMQ를 사용한 명령의 비동기 처리

이 프로젝트에서 선택한 AMQP 구현은 RabbitMQ이지만 Amazon의 AMQP 솔루션과 같은 쉽게 쉽게 전환 할 수 있습니다.

새 대기열 등록

#[AsEventListener(type: EventListenerType:: PROCESS_MANAGER )]
class UserCommandQueue extends CommandQueue
{
}

대기열 명령

 class YourService
{
    public function __construct (
        private readonly UserCommandQueue $ userCommandQueue
    ) {
    }

    public function aMethod (): void
    {
        $ this -> userCommandQueue -> queue ( new CreateUser ( /*...*/ ));
    }
}

대기열을 소비합니다

 > docker-compose run --rm php-cli bin/console app:amqp:consume user-command-queue

전체 문서

데이터베이스 마이그레이션

데이터베이스 마이그레이션을 관리하기 위해 교리/마이그레이션 패키지가 사용됩니다.

#[Entity]
class User extends AggregateRoot
{
    private function __construct (
        #[Id, Column(type: ' string ' , unique: true , nullable: false )]
        private readonly UserId $ userId ,
        #[Column(type: ' string ' , nullable: false )]
        private readonly Name $ name ,
    ) {
    }

    // ...
}

데이터베이스 스키마의 현재 상태를 ORM을 사용하여 정의 된 매핑 정보와 비교 한 다음 해당 마이그레이션을 실행하여 교리가 마이그레이션을 생성 할 수 있습니다.

 > docker-compose run --rm php-cli vendor/bin/doctrine-migrations diff
> docker-compose run --rm php-cli vendor/bin/doctrine-migrations migrate

전체 문서

템플릿 엔진

이 프로젝트에서 선택한 템플릿 엔진은 Twig이며 HTML과 관련된 모든 것을 렌더링하는 데 사용할 수 있습니다.

템플릿을 만듭니다

< h1 >Users</ h1 >
< ul >
    {% for user in users %}
        < li >{{ user . username | e }}</ li >
    {% endfor %}
</ ul >

템플릿을 렌더링하십시오

 class UserOverviewRequestHandler
{
    public function __construct (
        private readonly Environment $ twig ,
    ) {
    }

    public function handle (
        ServerRequestInterface $ request ,
        ResponseInterface $ response ): ResponseInterface
    {
        $ template = $ this -> twig -> load ( ' users.html.twig ' );
        $ response -> getBody ()-> write ( $ template -> render ( /*...*/ ));

        return $ response ;
    }
}