Created
August 31, 2014 02:02
-
-
Save fayland/0058b839b98753af2425 to your computer and use it in GitHub Desktop.
pubnub
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
➜ PubNub-PubSub git:(master) ✗ perl examples/subscribe.pl | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:57 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 24 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[[],"14094504474012689"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504474012689 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 34 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message1"],"14094504595072830"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504595072830 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 255 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message2","message3","message4","message5","message6","message7","message8","message9","message10","message11","message12","message13","message14","message15","message16","message17","message18","message19","message20","message21"],"14094504595587876"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504595587876 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 395 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message22","message23","message24","message25","message26","message27","message28","message29","message30","message31","message32","message33","message34","message35","message36","message37","message38","message39","message40","message41","message42","message43","message44","message45","message46","message47","message48","message49","message50","message51","message52"],"14094504596518103"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504596518103 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 347 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message53","message54","message55","message56","message57","message58","message59","message60","message61","message62","message63","message64","message65","message66","message67","message68","message69","message70","message71","message72","message73","message74","message75","message76","message77","message78","message79"],"14094504597207731"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504597207731 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 341 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message80","message81","message82","message83","message84","message85","message86","message87","message88","message89","message90","message91","message92","message93","message94","message95","message96","message97","message98","message99","message100","message101","message102","message103","message104","message105"],"14094504597880179"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504597880179 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 387 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message106","message107","message108","message109","message110","message111","message112","message113","message114","message115","message116","message117","message118","message119","message120","message121","message122","message123","message124","message125","message126","message127","message128","message129","message130","message131","message132","message133"],"14094504598615031"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504598615031 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 361 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message134","message135","message136","message137","message138","message139","message140","message141","message142","message143","message144","message145","message146","message147","message148","message149","message150","message151","message152","message153","message154","message155","message156","message157","message158","message159"],"14094504599270108"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504599270108 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:00:59 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 361 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message160","message161","message162","message163","message164","message165","message166","message167","message168","message169","message170","message171","message172","message173","message174","message175","message176","message177","message178","message179","message180","message181","message182","message183","message184","message185"],"14094504599932295"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504599932295 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 387 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message186","message187","message188","message189","message190","message191","message192","message193","message194","message195","message196","message197","message198","message199","message200","message201","message202","message203","message204","message205","message206","message207","message208","message209","message210","message211","message212","message213"],"14094504600645316"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504600645316 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 361 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message214","message215","message216","message217","message218","message219","message220","message221","message222","message223","message224","message225","message226","message227","message228","message229","message230","message231","message232","message233","message234","message235","message236","message237","message238","message239"],"14094504601306804"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504601306804 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 465 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message240","message241","message242","message243","message244","message245","message246","message247","message248","message249","message250","message251","message252","message253","message254","message255","message256","message257","message258","message259","message260","message261","message262","message263","message264","message265","message266","message267","message268","message269","message270","message271","message272","message273"],"14094504602179928"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504602179928 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 478 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message274","message275","message276","message277","message278","message279","message280","message281","message282","message283","message284","message285","message286","message287","message288","message289","message290","message291","message292","message293","message294","message295","message296","message297","message298","message299","message300","message301","message302","message303","message304","message305","message306","message307","message308"],"14094504603105628"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504603105628 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 387 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message309","message310","message311","message312","message313","message314","message315","message316","message317","message318","message319","message320","message321","message322","message323","message324","message325","message326","message327","message328","message329","message330","message331","message332","message333","message334","message335","message336"],"14094504603821799"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504603821799 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 465 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message337","message338","message339","message340","message341","message342","message343","message344","message345","message346","message347","message348","message349","message350","message351","message352","message353","message354","message355","message356","message357","message358","message359","message360","message361","message362","message363","message364","message365","message366","message367","message368","message369","message370"],"14094504604697588"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504604697588 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 335 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message371","message372","message373","message374","message375","message376","message377","message378","message379","message380","message381","message382","message383","message384","message385","message386","message387","message388","message389","message390","message391","message392","message393","message394"],"14094504605327404"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504605327404 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 348 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message395","message396","message397","message398","message399","message400","message401","message402","message403","message404","message405","message406","message407","message408","message409","message410","message411","message412","message413","message414","message415","message416","message417","message418","message419"],"14094504605966627"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504605966627 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 374 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message420","message421","message422","message423","message424","message425","message426","message427","message428","message429","message430","message431","message432","message433","message434","message435","message436","message437","message438","message439","message440","message441","message442","message443","message444","message445","message446"],"14094504606685723"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504606685723 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 400 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message447","message448","message449","message450","message451","message452","message453","message454","message455","message456","message457","message458","message459","message460","message461","message462","message463","message464","message465","message466","message467","message468","message469","message470","message471","message472","message473","message474","message475"],"14094504607469610"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504607469610 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 556 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message476","message477","message478","message479","message480","message481","message482","message483","message484","message485","message486","message487","message488","message489","message490","message491","message492","message493","message494","message495","message496","message497","message498","message499","message500","message501","message502","message503","message504","message505","message506","message507","message508","message509","message510","message511","message512","message513","message514","message515","message516"],"14094504608526991"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504608526991 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:00 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 374 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message517","message518","message519","message520","message521","message522","message523","message524","message525","message526","message527","message528","message529","message530","message531","message532","message533","message534","message535","message536","message537","message538","message539","message540","message541","message542","message543"],"14094504609305104"] | |
<<<<<< | |
>>>>>> | |
GET /subscribe/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/sandbox/0/14094504609305104 HTTP/1.1 | |
Host: pubsub.pubnub.com | |
>>>>>> | |
<<<<<< | |
HTTP/1.1 200 OK | |
Date: Sun, 31 Aug 2014 02:01:01 GMT | |
Content-Type: text/javascript; charset="UTF-8" | |
Content-Length: 1323 | |
Connection: keep-alive | |
Cache-Control: no-cache | |
Access-Control-Allow-Origin: * | |
Access-Control-Allow-Methods: GET | |
[["message608","message609","message610","message611","message612","message613","message614","message615","message616","message617","message618","message619","message620","message621","message622","message623","message624","message625","message626","message627","message628","message629","message630","message631","message632","message633","message634","message635","message636","message637","message638","message639","message640","message641","message642","message643","message644","message645","message646","message647","message648","message649","message650","message651","message652","message653","message654","message655","message656","message657","message658","message659","message660","message661","message662","message663","message664","message665","message666","message667","message668","message669","message670","message671","message672","message673","message674","message675","message676","message677","message678","message679","message680","message681","message682","message683","message684","message685","message686","message687","message688","message689","message690","message691","message692","message693","message694","message695","message696","message697","message698","message699", | |
<<<<<< | |
<<<<<< | |
"message700","message701","message702","message703","message704","message705","message706","message707"],"14094504613690782"] |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import socket | |
import uuid | |
import random | |
import threading | |
import time | |
import random | |
import math | |
HOST = 'pubsub.pubnub.com' | |
PORT = 80 | |
numID = 2000 | |
id = [] | |
for x in range(1, numID): | |
id.append('message' + str(x)) | |
print 'We will send a random quantity of messages every 10 seconds, each contains a randomly selected UUID.' | |
def socketPool(message): | |
#TODO: Implement socketPool w/ size 100 | |
pass | |
def handleSocketRead(s): | |
while True: | |
try: | |
msg = s.recv(4096) | |
print "Got " + msg | |
except socket.timeout, e: | |
err = e.args[0] | |
print 'recv timed out, done reading' | |
break | |
except socket.error, e: | |
print e | |
break | |
else: | |
continue | |
#print repr(msg) | |
def send(): | |
# time.sleep(10) | |
# threading.Thread(target=send).start() | |
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) | |
s.connect((socket.gethostbyname(HOST), PORT)) | |
s.settimeout(2) | |
numMessages = 2000 | |
print 'Sending '+ str(numMessages) +' messages.' | |
time_start = time.time() | |
# tmr = threading.Thread(target=handleSocketRead, args=[s]) | |
# tmr.start() | |
for message in range(0, numMessages-1): | |
#print 'we are on message', message+1, 'of', numMessages | |
s.send('GET /publish/pub-c-5b5d836f-143b-48d2-882f-659e87b6c321/sub-c-a66b65f2-2d96-11e4-875c-02ee2ddab7fe/0/sandbox/0/"'+str(id[message])+'" HTTP/1.1\r\nHost: pubsub.pubnub.com\r\n\r\n') | |
print 'It took', str(time.time()-time_start), 'runtime to send', numMessages, 'messages' | |
handleSocketRead(s) | |
s.close() | |
send() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment