opens.kr

elephant.io - https://github.com/Wisembly/elephant.io

1. elephantio.php -  elephant.io 다운로드 src폴더 데이터에 대한 include 또는 require 파일 만들기

1. <?php
2. $___ELEPHANTIO_DIR = dirname(__FILE__);
3. require $___ELEPHANTIO_DIR.'/Client.php';
4. require $___ELEPHANTIO_DIR.'/AbstractPayload.php';
5. require $___ELEPHANTIO_DIR.'/EngineInterface.php';
6. require $___ELEPHANTIO_DIR.'/Engine/AbstractSocketIO.php';
7. require $___ELEPHANTIO_DIR.'/Engine/SocketIO/Session.php';
8. require $___ELEPHANTIO_DIR.'/Engine/SocketIO/Version1X.php';
9. require $___ELEPHANTIO_DIR.'/Exception/MalformedUrlException.php';
10. require $___ELEPHANTIO_DIR.'/Exception/ServerConnectionFailureException.php';
11. require $___ELEPHANTIO_DIR.'/Exception/SocketException.php';
12. require $___ELEPHANTIO_DIR.'/Exception/UnsupportedActionException.php';
13. require $___ELEPHANTIO_DIR.'/Exception/UnsupportedTransportException.php';
14. require $___ELEPHANTIO_DIR.'/Payload/Decoder.php';
15. require $___ELEPHANTIO_DIR.'/Payload/Encoder.php';
16. ?>

2. client.php

1. <?php
2. include 'lib/elephantio/elephantio.php';
3. /*
4. * Version1X arg2 Option : ['context'=>[], 'debug'=>false,'wait'=>100*1000,'timeout'=>ini_get("default_socket_timeout")];
5. */
6. $EIO = new ElephantIO\Client(
7. new ElephantIO\Engine\SocketIO\Version1X('http://127.0.0.1:8001',['timeout'=>5])
8. );
9. $EIO->initialize();
10. $EIO->emit('msgIn', array('data1','data2') );
11. $EIO->close();
12. ?>

3. nodejs server

1. var io = require('socket.io').listen(8001);
2. io.sockets.on('connection', function (socket){
3. socket.on('msgIn',function(msg){
4. console.log('Msg In : ',msg);
5. });
6. socket.on('disconnect', function(){
7. console.log('NOT USER DISCONNECT : ', socket.id);
8. });
9. });
11. /*
12. * debug
13. * Msg In : [ 'data1', 'data2' ]
14. * NOT USER DISCONNECT : NPmXDQpuVM9OFYl0AAAA
15. */

Github 주소

https://github.com/msgpack/msgpack-php

소스설치방법

$ wget https://github.com/msgpack/msgpack-php/zipball/master -O msgpack-php.zip
$ unzip msgpack-php.zip 
$ cd msgpack-msgpack-php-da24be3/
$ phpize
Configuring for:
PHP Api Version:         20121113
Zend Module Api No:      20121212
Zend Extension Api No:   220121212

$ ./configure
$ make && make install
Installing shared extensions:     /usr/lib64/php/modules/
Installing header files:          /usr/include/php/


$ cd /usr/lib64/php/modules/
$ ll | grep msgpack
-rwxr-xr-x 1 root root  388516 Sep 18 14:27 msgpack.so


##### php.conf 디렉토리에 맞게 ini 에 extension 등록하기! 안되면 php.ini등록해도됨
$ echo extension=msgpack.so > /etc/php.d/msgpack.ini 

##### 웹서버종류에 따라서 Apache Restart 또는 php-fpm restart
$ /etc/init.d/php-fpm restart

##### 최종확인
$ php -i | grep 'MessagePack Support'
MessagePack Support => enabled

<?php phpinfo() ?> 
MessagePack Support enabled
Session Support enabled
extension Version   0.5.6-dev
header Version  0.5.4
Directive   Local Value Master Value
msgpack.error_display   On  On
msgpack.illegal_key_insert  Off Off
msgpack.php_only    On  On

1. Redis List 데이터 사용 샘플소스

1. <?php
2. $redis = new Redis();
3. try {
4. $redis->connect('127.0.0.1', 6379, 2.5);//2.5 sec timeout
5. //Auth Password(redis.conf requirepass)
6. //$redis->auth('foobared');
7. } catch (Exception $e) {
8. exit( "Cannot connect to redis server : ".$e->getMessage() );
9. }
11. // //DB Select
12. if ( !$redis->select(0) ){
13. exit( "NOT DB Select");
14. }
16. $redis->delete('weblog:ws1');
17. //rPush 맨아래 배열로 입력
18. $redis->rPush('weblog:ws1', 'log1');
19. $redis->rPush('weblog:ws1', 'log2');
20. $redis->rPush('weblog:ws1', 'log3');
21. $redis->rPush('weblog:ws1', 'log4');
22. //lPush 첫번째 배열로 입력
23. $redis->lPush('weblog:ws1', 'log5');
24. //0~2번까지배열 가져오기
25. var_dump($redis->lRange('weblog:ws1', 0, 2));
26. //전체배열데이터 가져오기
27. var_dump($redis->lRange('weblog:ws1', 0, -1));
28. ?>

2. Redis 들어있는 데이터

3. 추가명령어 메뉴얼참조

- https://github.com/nicolasff/phpredis#lists

blPop, brPop - Remove and get the first/last element in a list

brpoplpush - Pop a value from a list, push it to another list and return it

lIndex, lGet - Get an element from a list by its index

lInsert - Insert an element before or after another element in a list

lLen, lSize - Get the length/size of a list

lPop - Remove and get the first element in a list

lPush - Prepend one or multiple values to a list

lPushx - Prepend a value to a list, only if the list exists

lRange, lGetRange - Get a range of elements from a list

lRem, lRemove - Remove elements from a list

lSet - Set the value of an element in a list by its index

lTrim, listTrim - Trim a list to the specified range

rPop - Remove and get the last element in a list

rpoplpush - Remove the last element in a list, append it to another list and return it (redis >= 1.1)

rPush - Append one or multiple values to a list

rPushx - Append a value to a list, only if the list exists

1. Redis Hash 데이터 사용 샘플 소스

1. <?php
2. $redis = new Redis();
3. try {
4. $redis->connect('127.0.0.1', 6379, 2.5);//2.5 sec timeout
5. //Auth Password(redis.conf requirepass)
6. //$redis->auth('foobared');
7. } catch (Exception $e) {
8. exit( "Cannot connect to redis server : ".$e->getMessage() );
9. }
11. // //DB Select
12. if ( !$redis->select(0) ){
13. exit( "NOT DB Select");
14. }
16. $redis->delete('user_list');
17. $redis->hSet('user_list', 'uid1', 1);
18. $redis->hSet('user_list', 'uid2', 2);
19. $redis->hSet('user_list', 'uid3', 3);
20. if ( $redis->hExists('user_list','uid1') ){
21. echo "uid1 : ".$redis->hGet('user_list','uid1')."\n";
22. }else{
23. echo 'NOT_DATA';
24. }
25. //여러개 HASH 데이터 한번에 입력
26. $redis->hMset('user_list', array('uid4' => 4, 'uid5' =>5));
27. //여러개 HASH 데이터를 한번에 가져옴
28. var_dump($redis->hMGet('user_list', array('uid4', 'uid5')));
29. var_dump($redis->hGetAll('user_list'));
30. /*
31. * Print
32. uid1 : 1
33. array(2) {
34. ["uid4"]=>
35. string(1) "4"
36. ["uid5"]=>
37. string(1) "5"
38. }
39. array(5) {
40. ["uid1"]=>
41. string(1) "1"
42. ["uid2"]=>
43. string(1) "2"
44. ["uid3"]=>
45. string(1) "3"
46. ["uid4"]=>
47. string(1) "4"
48. ["uid5"]=>
49. string(1) "5"
50. }
51. */
52. ?>

2. Redis 들어있는 데이터

3. 추가 명령어 메뉴얼 참조

- https://github.com/nicolasff/phpredis#hashes

hDel - Delete one or more hash fields

hExists - Determine if a hash field exists

hGet - Get the value of a hash field

hGetAll - Get all the fields and values in a hash

hIncrBy - Increment the integer value of a hash field by the given number

hIncrByFloat - Increment the float value of a hash field by the given amount

hKeys - Get all the fields in a hash

hLen - Get the number of fields in a hash

hMGet - Get the values of all the given hash fields

hMSet - Set multiple hash fields to multiple values

hSet - Set the string value of a hash field

hSetNx - Set the value of a hash field, only if the field does not exist

hVals - Get all the values in a hash

hScan - Scan a hash key for members

Connect와 기본 keys-and-strings 샘플자료

1. <?php
2. $redis = new Redis();
3. try {
4. $redis->connect('127.0.0.1', 6379, 2.5);//2.5 sec timeout
5. //Auth Password(redis.conf requirepass)
6. //$redis->auth('foobared');
7. } catch (Exception $e) {
8. exit( "Cannot connect to redis server : ".$e->getMessage() );
9. }
11. // //DB Select
12. if ( !$redis->select(0) ){
13. exit( "NOT DB Select");
14. }
16. $redis->set('key1','value1',10); //유효기간 10초
17. echo $redis->get('key1');
18. /*
19. * print : value1
20. */
21. ?>

자세한 명령어 사용법은 아래 메뉴얼참조

https://github.com/nicolasff/phpredis#keys-and-strings

Strings

append - Append a value to a key

bitcount - Count set bits in a string

bitop - Perform bitwise operations between strings

decr, decrBy - Decrement the value of a key

get - Get the value of a key

getBit - Returns the bit value at offset in the string value stored at key

getRange - Get a substring of the string stored at a key

getSet - Set the string value of a key and return its old value

incr, incrBy - Increment the value of a key

incrByFloat - Increment the float value of a key by the given amount

mGet, getMultiple - Get the values of all the given keys

mSet, mSetNX - Set multiple keys to multiple values

set - Set the string value of a key

setBit - Sets or clears the bit at offset in the string value stored at key

setex, psetex - Set the value and expiration of a key

setnx - Set the value of a key, only if the key does not exist

setRange - Overwrite part of a string at key starting at the specified offset

strlen - Get the length of the value stored in a key

Keys

del, delete - Delete a key

dump - Return a serialized version of the value stored at the specified key.

exists - Determine if a key exists

expire, setTimeout, pexpire - Set a key's time to live in seconds

expireAt, pexpireAt - Set the expiration for a key as a UNIX timestamp

keys, getKeys - Find all keys matching the given pattern

scan - Scan for keys in the keyspace (Redis >= 2.8.0)

migrate - Atomically transfer a key from a Redis instance to another one

move - Move a key to another database

object - Inspect the internals of Redis objects

persist - Remove the expiration from a key

randomKey - Return a random key from the keyspace

rename, renameKey - Rename a key

renameNx - Rename a key, only if the new key does not exist

type - Determine the type stored at key

sort - Sort the elements in a list, set or sorted set

ttl, pttl - Get the time to live for a key

restore - Create a key using the provided serialized value, previously obtained with dump.

Memcached는 써보았는데 Redis는 아직 테스트를 안해봐서 아래 설명만 우선링크

phpredis 설치방법은 아래 글 참조

http://opens.kr/53

세션 서버 사용 설명- https://github.com/nicolasff/phpredis#php-session-handler

phpredis can be used to store PHP sessions. To do this, configure session.save_handler andsession.save_path in your php.ini to tell phpredis where to store the sessions:

session.save_handler = redis
session.save_path = "tcp://host1:6379?weight=1, tcp://host2:6379?weight=2&timeout=2.5, tcp://host3:6379?weight=2"

php.ini에서 위에 처럼 config 수정하는 방법도 있고 소스상에서 ini_set 으로 하는 방법도 있다.

Sessions have a lifetime expressed in seconds and stored in the INI variable "session.gc_maxlifetime". You can change it with ini_set(). The session handler requires a version of Redis with the SETEXcommand (at least 2.0). phpredis can also connect to a unix domain socket: session.save_path = "unix:///var/run/redis/redis.sock?persistent=1&weight=1&database=0.

아래 처럼 테스트 하니까 잘 된다. 

1. <?php
2. ini_set('session.save_handler', 'redis');
3. ini_set('session.save_path', 'tcp://127.0.0.1:6379');
4. //unix sock의 경우 아래처럼 그리고 & 파라미터로 database등 지정할수있는듯함
5. //ini_set('session.save_path', 'unix:///var/run/redis/redis.sock?persistent=1&weight=1&database=0');
6. ?>

http://redis.io/clients 

=> 공식 사이트 들어가보면  아래 두가지를 추천하는 듯함

Predis ☺ ★ Repository JoL1hAHN Mature and supported

phpredis ☺ ★ Repository yowgi This is a client written in C as a PHP module.

$ wget https://github.com/nicolasff/phpredis/zipball/master -O phpredis.zip
$ unzip phpredis.zip 
$ ll
drwxr-xr-x  5 root root   4096 Sep  3 04:27 nicolasff-phpredis-4c1f1bc

$ cd nicolasff-phpredis-4c1f1bc/
$ phpize 
Can't find PHP headers in /usr/include/php
The php-devel package is required for use of this command.

$ yum install php-devel #PHP devel 미설치시 설치하기!
$ phpize
Configuring for:
PHP Api Version:         20121113
Zend Module Api No:      20121212
Zend Extension Api No:   220121212

$ ./configure
$ make && make install
Installing shared extensions:     /usr/lib64/php/modules/

$ cd /usr/lib64/php/modules/
$ ll | grep redis
-rwxr-xr-x 1 root root  942112 Sep 16 12:11 redis.so

##### php.conf 디렉토리에 맞게 ini 에 extension 등록하기! 안되면 php.ini등록해도됨
$ echo extension=redis.so > /etc/php.d/redis.ini 


##### 웹서버종류에 따라서 Apache Restart 또는 php-fpm restart
$ /etc/init.d/php-fpm restart

##### 최종확인
$ php -i | grep 'Redis Version'
Redis Version => 2.2.5

<?php phpinfo() ?> 
redis
Redis Support => enabled
Redis Version => 2.2.5

$ wget http://download.redis.io/releases/redis-2.8.15.tar.gz
$ tar xvfz redis-2.8.15.tar.gz 
$ cd redis-2.8.15

$ make -j4
$ make install  -j4


###### /etc/init.d/ 추가되도록 install#############################
###### vi /etc/init.d/redis_6379 열어보면 실행방식 자세히 알 수 있음

$ cd utils/
$ ./install_server.sh 

Welcome to the redis service installer
This script will help you easily set up a running redis server

Please select the redis port for this instance: [6379]  ###포트지정하면됨
Selecting default: 6379
Please select the redis config file name [/etc/redis/6379.conf] 
Selected default - /etc/redis/6379.conf
Please select the redis log file name [/var/log/redis_6379.log] 
Selected default - /var/log/redis_6379.log
Please select the data directory for this instance [/var/lib/redis/6379] 
Selected default - /var/lib/redis/6379
Please select the redis executable path [/usr/local/bin/redis-server] 
Selected config:
Port           : 6379
Config file    : /etc/redis/6379.conf ##설정파일
Log file       : /var/log/redis_6379.log ##로그파일
Data dir       : /var/lib/redis/6379     
Executable     : /usr/local/bin/redis-server
Cli Executable : /usr/local/bin/redis-cli
Is this ok? Then press ENTER to go on or Ctrl-C to abort.
Copied /tmp/6379.conf => /etc/init.d/redis_6379
Installing service...
Successfully added to chkconfig!
Successfully added to runlevels 345!
Starting Redis server...
Installation successful!
######################################################

### redis 실행########################################
$ /etc/init.d/redis_6379 start
Starting Redis server...

### redis 중지########################################
$ /etc/init.d/redis_6379 stop
Stopping ...
Redis stopped

### 커맨드라인 콘솔모드 접속 #########################
$ redis-cli 
127.0.0.1:6379> 

$ yum install gcc gcc-c++
$ yum install openssl-devel make

$ wget http://nodejs.org/dist/v0.10.31/node-v0.10.31.tar.gz
※ http://nodejs.org/download/ 최신버젼받기

$ tar xvfz node-v0.10.31.tar.gz
$ cd node-v0.10.31

$ ./configure --prefix=/data/nodejs
{ 'target_defaults': { 'cflags': [],
                       'default_configuration': 'Release',
                       'defines': [],
                       'include_dirs': [],
                       'libraries': []},
  'variables': { 'clang': 0,
                 'gcc_version': 44,
                 'host_arch': 'x64',
                 'node_install_npm': 'true',
                 'node_prefix': '/data/nodejs',
                 'node_shared_cares': 'false',
                 'node_shared_http_parser': 'false',
                 'node_shared_libuv': 'false',
                 'node_shared_openssl': 'false',
                 'node_shared_v8': 'false',
                 'node_shared_zlib': 'false',
                 'node_tag': '',
                 'node_unsafe_optimizations': 0,
                 'node_use_dtrace': 'false',
                 'node_use_etw': 'false',
                 'node_use_openssl': 'true',
                 'node_use_perfctr': 'false',
                 'node_use_systemtap': 'false',
                 'python': '/usr/bin/python',
                 'target_arch': 'x64',
                 'v8_enable_gdbjit': 0,
                 'v8_no_strict_aliasing': 1,
                 'v8_use_snapshot': 'true',
                 'want_separate_host_toolset': 0}}
creating  ./config.gypi
creating  ./config.mk

$ make && make install

##### bin Path는 계정 및 shell환경에 맞게 profile 에 등록하기##
$ vi /root/.bash_profile
PATH=$PATH:$HOME/bin
PATH=$PATH:/data/nodejs/bin ##nodjs bin등록
export PATH
source /root/.bash_profile
##############################################################

$ /data/nodejs/bin/node -v
v0.10.31


## npm 이용한 forever 데몬프로그램 설치########################
$ /data/nodejs/bin/npm install -g forever 

## npm 이용한 socket.io 설치###################################
$ /data/nodejs/bin/npm install -g socket.io

Node.js 책 잠시 보고 만든 샘플입니다.

그냥 참고용으로!!ㅎㅎ

1. Server Side Node.js Socket.io

1. var io = require('socket.io').listen(80);
2. var clients = {};
3. io.sockets.on('connection', function (socket){
4. //입장 및 닉네임체크
5. socket.on('create_nickname',function(nickname,returnFunction){
6. //닉네임중복체크
7. var returnCode = 1;
8. for ( var i in clients ){
9. if ( clients[i] == nickname ){
10. returnCode = -1;
11. break;
12. }
13. }
14. //닉네임체크확인 결과 전달
15. returnFunction(returnCode);
16. //닉네임체크 유효화됨
17. if ( returnCode == 1 ) {
18. //클라이언트 닉네임등록
19. clients[socket.id] = nickname;
20. //새접속자로인한 전체 유저리스트 전달함
21. io.sockets.emit('user_list',clients);
22. //전체유저 메세지전송
23. io.sockets.emit('msgPush',{"nickname":"시스템","msg":clients[socket.id]+" 유저가 입장하셨습니다."});
24. console.log('CONNECT : ',nickname+' ['+socket.id+'] '+'('+Object.keys(clients).length+'명)');
25. }
26. });
27. socket.on('msgSend',function(data){
28. //자신을 제외한 전체유저에게 메세지전송
29. socket.broadcast.emit('msgPush',data);
30. /*
31. *socket.emit('msgPush',data);//자신에게만 보낼때
32. *socket.broadcast.emit('msgPush',data);//자신제외 전체유저
33. *io.sockets.emit('msgPush',data);//자신포함 전체유저에게
34. *io.sockets.in(socket_id).emit('msgPush',data);//특정유저에게 귓속말시 socket_id추가입력하면됨
35.     *io.of('namespace').emit('msgPush', data); //of 지정된 name space의 유저
36. */
37. console.log('Chat Msg : ','['+data['nickname']+'] '+data['msg']);
38. });
39. //접속종료시처리
40. socket.on('disconnect', function(){
41. if ( clients[socket.id] ){
42. //유저이탈 메세지전달
43. io.sockets.emit('msgPush',{"nickname":"시스템","msg":clients[socket.id]+" 유저가 나가셨습니다."});
44. console.log('DISCONNECT : ', clients[socket.id]);
45. //이탈유저닉네임삭제
46. delete clients[socket.id];
47. //유저이탈 전체유저리스트 갱신
48. io.sockets.emit('user_list',clients);
49. }else{
50. console.log('NOT USER DISCONNECT : ', socket.id);
51. }
52. });
53. });

2. Client

1. <!DOCTYPE html>
2. <html>
3. <head>
4. <meta charset="UTF-8">
5. <title>Chat</title>
6. </head>
7. <body>
9. <div id="chatJoin">
10. <form id="chatJoinForm">
11. 대화명 : <input id="nickname" name="nickname" type="text"> <input type="submit" value="입장">
12. </form>
13. </div>
14. <div id="chatRoom" style="display:none;">
15. <div id="msgList" style="float:left;width:500px;height:300px;border:1px solid #1D365D;overflow:auto;"></div>
16. <div style="float:left;width:100px;height:300px;border:1px solid #1D365D;margin-left:3px;">
17. <div style="border-bottom:1px solid #1D365D;">접속자</div>
18. <div id="userList"></div>
19. </div>
20. <div style="clear:both;">
21. <form id="chatMsgForm">ChatMsg : <input id="msgText" name="msg" type="text"> <input type="submit" value="전송"></form>
22. </div>
23. </div>
24. </body>
25. <script type="text/javascript" src="jquery-1.11.1.min.js"></script>
26. <script type="text/javascript" src="socket.io.js"></script>
27. <script type="text/javascript">
28. $(function(){
29. var socket;
30. function createNickname(nickName){
31. socket.emit('create_nickname',nickName,function(returnCode){
32. if ( returnCode == 1 ){
33. //정상적인 닉네임
34. $('#chatJoin').hide();
35. $('#chatRoom').show();
36. $('#msgText').focus();
37. }else{ //아니면 닉네임중복됨
38. alert('존재하는 닉네임입니다.');
39. $('#nickname').focus();
40. socket.disconnect();
41. }
42. });
43. }
44. function msgAdd(data){
45. var sHtml = '<div><span style="color:blue;">'+data['nickname']+'</span> : '+data['msg']+'</div>';
46. $('#msgList').append(sHtml);
47. $("#msgList").scrollTop($("#msgList")[0].scrollHeight);
48. }
49. $('#chatMsgForm').submit(function(event){
50. event.preventDefault();
51. var data = {"nickname":$('#nickname').val(),"msg":$('#msgText').val()}
52. msgAdd(data);
53. $('#msgText').val('');
54. $('#msgText').focus();
55. //서버에 입력메세지전달
56. socket.emit('msgSend', data);
57. });
58. $('#chatJoinForm').submit(function(event){
59. event.preventDefault();
60. if ( !$('#nickname').val() ){
61. alert("닉네임을 입력해주세요");
62. $('#nickname').focus();
63. return false;
64. }
65. /*
66. *https://github.com/automattic/socket.io-client
67. */
68. socket = io.connect('http://127.0.0.1', {'forceNew':true,reconnection:false});
69. socket.on('connect', function () {
70. createNickname($('#nickname').val());
71. });
72. socket.on('user_list',function(clients){
73. //심플테스트 버젼이라서 삭제하고 새로 갱신하는방안
74. $('#userList').html('');
75. for ( var i in clients ){
76. if ( clients[i] == $('#nickname').val() ){
77. sHtml = '<div style="font-weight:bold;">'+clients[i]+'</div>';
78. }else{
79. sHtml = '<div>'+clients[i]+'</div>';
80. }
81. $('#userList').append(sHtml);
82. }
83. });
84. socket.on('msgPush',function(data){
85. msgAdd(data);
86. });
87. socket.on('disconnect', function(){
88. $('#msgList').html('');
89. $('#nickname').val('');
90. $('#chatJoin').show();
91. $('#chatRoom').hide();
92. alert('Server Disconnect');
93. });
94. socket.on('connect_error', function (data) {
95. alert('CONNECT_ERROR : '+data);
96. });
97. });
98. });
99. </script>
100. </html>