EventSource - GitLite

KO | EN

gitlite — search

#javascript #python #hacktoberfest #typescript #llm #linux #macos #nodejs #java #awesome #kubernetes #vue #ios #open-source

EventSource

(★ 104)

A PHP 5.3 library for creating an EventSource stream.

파일 탐색기

최종 버전 다운로드 (.zip)

- - .gitignore
  - client.html
  - composer.json
  - README.md
  - stream.php
- bootstrap.php
.gitignore
.travis.yml
composer.json
LICENSE
phpunit.xml.dist
README.md

# 설치 가이드

1. 코드 내려받기

git clone https://github.com/igorw/EventSource

깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.

cd EventSource

방금 내려받은 프로젝트 폴더 안으로 이동합니다.

2. PHP (Composer)

쉬움 추천

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
PHP PHP 실행 환경이 필요합니다.
Composer PHP 라이브러리 설치를 위한 패키지 매니저입니다.

$ php composer.phar install

이 명령어를 터미널에 그대로 입력해 실행하세요.

✅ php -S localhost:8000 같은 내장 서버로 실행한 뒤 브라우저에서 http://localhost:8000 으로 접속해보세요.

이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# EventSource

A PHP 5.3 library for creating an [EventSource](http://dev.w3.org/html5/eventsource/) stream.

EventSource or Server-Sent-Events is a W3C specification that defines a protocol and an API
for pushing data from the server to the client. This library is a server-side implementation
of this protocol.

It is designed to be transport agnostic, allowing you to use it with apache directly or with
other webservers, such as mongrel2.

[![Build Status](https://secure.travis-ci.org/igorw/EventSource.png?branch=master)](http://travis-ci.org/igorw/EventSource)

## Fetch

The recommended way to install EventSource is [through composer](http://packagist.org).

Just create a composer.json file for your project:

```JSON
{
    "require": {
        "igorw/event-source": "1.0.*"
    }
}
```

And run these two commands to install it:

$ curl -s http://getcomposer.org/installer | php
    $ php composer.phar install

Now you can add the autoloader, and you will have access to the library:

```php
<?php
require 'vendor/autoload.php';
```

## Usage

The first thing you need to do is output the EventSource headers, so that the
client knows it's talking to an EventSource server.

```php
<?php

use Igorw\EventSource\Stream;

foreach (Stream::getHeaders() as $name => $value) {
    header("$name: $value");
}
```

After that you create a ``Stream`` which provides a nice API for creating events.
Once you call flush, all queued events are sent to the client.

This example will send a new event every 2 seconds.

```php
<?php

use Igorw\EventSource\Stream;

$stream = new Stream();

while (true) {
    $stream
        ->event()
            ->setData("Hello World")
        ->end()
        ->flush();
    
    sleep(2);
}
```

And an example JavaScript client:

```JavaScript
var stream = new EventSource('stream.php');

stream.addEventListener('message', function (event) {
    console.log(event.data);
});
```

## Advanced

### Last event id

When your events have ids, the client will send a `Last-Event-ID` header on
reconnection. You can read this value and re-send any events that occured after
the one provided by the user.

```php
<?php

$lastId = filter_input(INPUT_SERVER, 'HTTP_LAST_EVENT_ID');

if ($lastId) {
    $buffer = getMessagesAfter($lastId);

foreach ($buffer as $message) {
        $stream->event()
            ->setId($message['id'])
            ->setData($message['data']);
    }

$stream->flush();
}
```

### Event namespacing

You can namespace events by using the `setEvent` method on the event. This
allows you to bind to those event types specifically on the client side.

Here is a stream that sends two events. One of type `foo` and one of type
`bar`.

```php
<?php

$stream
    ->event()
        ->setEvent('foo')
        ->setData($message['data']);
    ->end()
    ->event()
        ->setEvent('bar')
        ->setData($message['data']);
    ->end()
    ->flush();
```

On the client you bind to that event instead of the generic `message` one.
Do note that the `message` event will not catch these messages.

```JavaScript
var stream = new EventSource('stream.php');

stream.addEventListener('foo', function (event) {
    console.log('Received event foo!');
});

stream.addEventListener('bar', function (event) {
    console.log('Received event bar!');
});
```

### Sending JSON

In most applications you will want to send more complex data as opposed to
simple strings. The recommended way of doing this is to use the JSON format.
It can encode and decode nested structures quite well.

On the server side, simply use the `json_encode` function to encode a value:

```php
<?php

$data = array('userIds' => array(21, 43, 127));

$stream
    ->event()
        ->setData(json_encode($data));
    ->end()
    ->flush();
```

On the client side, you can use `JSON.parse` to decode it. For old browsers,
where `JSON` is not available, see [json2.js](https://github.com/douglascrockford/JSON-js).

```JavaScript
var stream = new EventSource('stream.php');

stream.addEventListener('message', function (event) {
    var data = JSON.parse(event.data);
    console.log('User IDs: '+data.userIds.join(', '));
});
```

### Custom handler

By default the library will assume you are running in a traditional apache-like
environment. This means that output happens through echo. If you are using a
server that handles web output in a different way (eg. app server), then you
will want to change this.

A handler is simply a function that takes a chunk (a single event) and sends it
to the client. You can define it as a lambda. Here is the default handler:

```php
<?php

$handler = function ($chunk) {
    echo $chunk;
    ob_flush();
    flush();
};
```

You just pass it to the constructor of the stream:

```php
<?php

$stream = new Stream($handler);
```

### PHP time limit

In some setups it may be required to remove the time limit of the script.
If you are having problems with your script dying after 30 or 60 seconds,
add this line.

```php
<?php
set_time_limit(0);
```

### Polyfill

Most old browsers have not implemented EventSource yet. Luckily there is a
[polyfill](https://github.com/Yaffle/EventSource) available, that allows them
to be used in a wider range of browsers.

Tests
-----

$ phpunit

License
-------
MIT, see LICENSE.