socket.io v1.0 introduction

Tokyo Node Gakuen #tng13

Transcript

1. socket.io v1.0 intro @yosuke_furukawa
2. @yosuke_furukawa Node.jsϢʔβʔάϧʔϓ୅ද / DeNAॴଐ
3. socket.io v1.0 ΍ͬͱग़·ͨ͠Ͷʂʂ
4. IUUQZPTVLFGVSVLBXBIBUFOBCMPHDPNFOUSZ ͋·Γͷڵฃʹ੎͍Ͱ1೔Ͱ ຋༁
5. ࠓճͷ࿩͸຋༁ͷ·ͱΊ
6. ຋༁Ͱ఻͖͑Εͳ͔ͬͨ͜ͱ ͕఻͖͑ΕΔͱ͍͍ͳͱࢥ͍ ·͢ɻ
7. New Engine, engine.io
8. Before, fallback style XFCTPDLFU
9. Before, fallback style XFCTPDLFU
10. Before, fallback style XFCTPDLFU 9)3
    MPOH
    QPMMJOH
11. Before, fallback style XFCTPDLFU 9)3
    MPOH
    QPMMJOH
12. Before, fallback style XFCTPDLFU 9)3
    MPOH
    QPMMJOH +40/1
    QPMMJOH
13. Before, fallback style XFCTPDLFU 9)3
    MPOH
    QPMMJOH +40/1
    QPMMJOH
14. Problem • ॳظ઀ଓ·Ͱʹ͕͔͔࣌ؒΔՄೳੑ͕͋Δ
15. After, Upgrade style 9)3+40/1
    QPMMJOH
16. After, Upgrade style 9)3+40/1
    QPMMJOH XFCTPDLFU
17. After, Upgrade style 9)3+40/1
    QPMMJOH XFCTPDLFU 6QHSBEFͨ͠Β
    QBVTFঢ়ଶʹͳΔɻ
18. Engine.io • ॳظ઀ଓ·Ͱͷ࣌ؒΛվળ • ଞʹ΋transports૚ͷௐ཯͸͜ͷ૚Ͱߦ͏ͷͰɺক དྷతʹ৽͍͠tranports(Google Chrome Socketͱ ͔pure TCP socket)͕ग़͖ͯͨ࣌͸ͦΕ΋ରԠͰ͖ ΔΑ͏ʹͯ͠ɺ֦ுੑ͕ߴ͍ࣄΛ͍ࣔࠦͯ͠Δ
19. Binary Support
20. Binary Support • sound • video • image • etc… ͜Ε·ͰemitͰ͖ͳ͔ͬͨ΋ͷ͕Ͱ͖ΔΑ͏ʹ ͳͬͨɻ
21. DEMO http://goo.gl/bMnN9k
22. ࣮ݱํ๏ // client side var img = canvas.toDataURL('image/webp'); var binary = window.atob(img.split(‘,')[1]); // binaryΛͦͷ·· emit socket.emit(‘image’, binary); ! // server side io.on('connection', function(socket){ // ࠓ·ͰͱมΘΒͳ͍ɺimage ΠϕϯτΛड͚औΔ socket.on('image', function(data){ // ड͚औͬͨbinaryͷσʔλΛbroadcast͢Δ socket.broadcast.volatile.emit('image', { id: socket.id, blob: data }); }); });
23. ࣮ݱํ๏ // client side var img = canvas.toDataURL('image/webp'); var binary = window.atob(img.split(‘,')[1]); // binaryΛͦͷ·· emit socket.emit(‘image’, binary); ! // server side io.on('connection', function(socket){ // ࠓ·ͰͱมΘΒͳ͍ɺimage ΠϕϯτΛड͚औΔ socket.on('image', function(data){ // ड͚औͬͨbinaryͷσʔλΛbroadcast͢Δ socket.broadcast.volatile.emit('image', { id: socket.id, blob: data }); }); }); DBOWBT͔Βը૾ΛCJOBSZ Ͱऔಘ͠ɺFNJU FNJU͞ΕౕͨΛͦͷ·· CSPBEDBTU
24. Scalability
25. Scalability 3FEJT OHJOY TPDLFUJP
26. Scalability 3FEJT OHJOY TPDLFUJP OHJOYͰTPDLFUJP
    αʔόͷৼΓ෼͚ઌΛܾΊΔ
    ৼΓ෼͚ઌ͸*1౳ΛݩʹܾΊΔ ֤ϓϩηεؒ͸3FEJTͰ
    1VC4VCͤ͞Δɻ
27. ࣮ݱํ๏(nginx) # in nginx.conf # ip_hashΛجʹ3001-3004ͷportͰಈ͍͍ͯΔserverʹ઀ଓ upstream io_nodes { ip_hash; server 127.0.0.1:3001; server 127.0.0.1:3002; server 127.0.0.1:3003; server 127.0.0.1:3004; } # ຊମ͸3000൪portͰड͚෇͚Δ server { listen 3000; server_name <io.yourhost.com>; location / { proxy_set_header Upgrade $http_upgrade; proxy_set_header Connection "upgrade"; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; proxy_set_header Host $host; proxy_http_version 1.1; # ͜͜Ͱproxy_pass ʹ io_nodesΛࢦఆ͢Δ proxy_pass http://io_nodes; } }
28. ࣮ݱํ๏(nginx) # in nginx.conf # ip_hashΛجʹ3001-3004ͷportͰಈ͍͍ͯΔserverʹ઀ଓ upstream io_nodes { ip_hash; server 127.0.0.1:3001; server 127.0.0.1:3002; server 127.0.0.1:3003; server 127.0.0.1:3004; } # ຊମ͸3000൪portͰड͚෇͚Δ server { listen 3000; server_name <io.yourhost.com>; location / { proxy_set_header Upgrade $http_upgrade; proxy_set_header Connection "upgrade"; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; proxy_set_header Host $host; proxy_http_version 1.1; # ͜͜Ͱproxy_pass ʹ io_nodesΛࢦఆ͢Δ proxy_pass http://io_nodes; } } OHJOYͰJQΛجʹόοΫΤϯυ ͷαʔόʔʹৼΓ෼͚Δ ݟͯͷ௨ΓɺDMVTUFS͸࢖ͬͯͳ͍ɻ DMVTUFSͩͱৼΓ෼͚ઌ͕Ұҙʹ
    ఆ·Βͳ͍ڪΕɺ
    DMVTUFS࢖͏৔߹͸TUJDLZTFTTJPO
    NPEVMFΛ࢖͏ɻ
29. ࣮ݱํ๏(redis) // socket.io-redisΛ࢖͏ // ͪͳΈʹadapter͸୔ࢁ͋ΔͷͰɺredis͡Όͳ͍ํ๏΋͋Δ(zero-mq etc) var sioredis = require('socket.io-redis'); ! // io.adapterͰredisαʔόΛࢦఆ͢Δɻ io.adapter(sioredis({ host: 'localhost', port: 6379, })); ! ! // جຊ͜Ε͚ͩͰϓϩηεؒͷ΍ΓͱΓ͸࣮ݱՄೳɻ
30. Integration with other process
31. Integration with other process 3FEJT OHJOY TPDLFUJP 1)13VCZ(P1ZUIPO/PEFKT
32. Integration with other process 3FEJT OHJOY TPDLFUJP 1)13VCZ(P1ZUIPO/PEFKT TPDLFUJPFNJUUFS
33. ࣮ݱํ๏(socket.io-go-emitter) // From golang code emitter := SocketIO.NewEmitter(&SocketIO.EmitterOpts{ // need Redis connect option Host:"localhost", Port:6379, }) emitter.Emit("message", “Hello World!”) ! // جຊ͜ΕΛ࣮ߦ͢Δ͚ͩɺEmitͬͯ΍Ε͹ͦΕΛon͍ͯ͠Δsocket.ioΫϥΠΞϯ τʹಧ͘ɻ ! // ݟͨײ͡ɺPHP, Python, Golang, RubyͰ͸࣮૷͞ΕͯΔ // (Perl͞Μ…)
34. Other tips
35. Other Tips • Debug͠΍͘͢ͳͬͨ # खલʹDEBUG=*ͱ͔͚ͭΔͱstdoutʹϩά͕දࣔ͞ΕΔ $ DEBUG=* node app.js ! visionmedia࡞ͷ debug module ࢖͍ͬͯΔɻ ! # ΫϥΠΞϯταΠυͷ৔߹΋localStorage.debug=“*”ͱ͔΍ΔͱϩΪϯά͞ΕΔ > localStorage.debug=“*” !
36. Other Tips • ΫϥΠΞϯτ͕CDN ͔Β΋഑৴͞ ΕΔΑ͏ʹͳͬͨ # ࠓ·Ͱ <script src="/socket.io/socket.io.js"></script> ! # CDN͔Β΋഑৴͞ΕΔɻ <script src="https://cdn.socket.io/socket.io-1.0.6.js"></script>
37. ·ͱΊ • New Engine • Binary Support • Scalability • Integration with others • Other Tips
38. Socket.io meetup in JAPAN • Guillermo Rauch comes here soon