Skip to content

Instantly share code, notes, and snippets.

@fayland
Created August 31, 2014 02:02
Show Gist options
  • Save fayland/0058b839b98753af2425 to your computer and use it in GitHub Desktop.
Save fayland/0058b839b98753af2425 to your computer and use it in GitHub Desktop.
pubnub
➜ 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"]
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