init

Author: nicolashahn

client.cpy

@@ -0,0 +1,42 @@
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netdb.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <string.h>
+
+#define BUF_SIZE 500
+
+int main():
+    HOST := "127.0.0.1"
+    PORT := "65432"
+
+    sockfd := socket(AF_INET, SOCK_STREAM, 0)
+    struct addrinfo hints;
+    struct addrinfo *result, *rp;
+    char buf[BUF_SIZE]
+
+    memset(&hints, 0, sizeof(struct addrinfo));
+    hints.ai_family = AF_UNSPEC;
+    hints.ai_socktype = SOCK_DGRAM;
+    hints.ai_flags = 0;
+    hints.ai_protocol = 0;
+
+    s := getaddrinfo(HOST, PORT, &hints, &result)
+    if s != 0:
+        fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(s));
+        exit(EXIT_FAILURE);
+
+    bytes_read := 0
+    while true:
+        if bytes_read == 0:
+            connect(sockfd, result->ai_addr, result->ai_addrlen)
+        message := "{\"a\":1}\n"
+        write(sockfd, message, strlen(message))
+        bytes_read = read(sockfd, buf, BUF_SIZE-1)
+        buf[bytes_read] = 0
+        print bytes_read, buf
+        memset(buf, 0, BUF_SIZE)
+        sleep(1)
+

client.py

@@ -0,0 +1,13 @@
+
+import json
+import socket
+
+HOST = "127.0.0.1"  # Standard loopback interface address (localhost)
+PORT = 65432  # Port to listen on (non-privileged ports are > 1023)
+
+conn = socket.create_connection((HOST, PORT))
+
+conn.send(b"{\"a\":1}\n")
+conn.close()
+while True:
+    data = conn.recv(5)

server.py

@@ -0,0 +1,45 @@
+#!/usr/bin/env python3
+
+import json
+import socket
+import threading
+
+HOST = "127.0.0.1"  # Standard loopback interface address (localhost)
+PORT = 65432  # Port to listen on (non-privileged ports are > 1023)
+
+
+class ClientThread(threading.Thread):
+    def __init__(self, addr, conn):
+        threading.Thread.__init__(self)
+        self.conn = conn
+        print("New connection added: ", addr)
+
+    def run(self):
+        # self.csocket.send(bytes("Hi, This is from Server..",'utf-8'))
+        messages = []
+        message = b""
+        while True:
+            data = self.conn.recv(1024)
+            chunks = data.split(b"\n")
+            for chunk in chunks[:-1]:
+                message += chunk
+                messages.append(json.loads(message))
+                message = b""
+            message += chunks[-1]
+            print(messages)
+            if not data:
+                break
+            conn.sendall(b"hi\n")
+        conn.close()
+
+
+with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    s.bind((HOST, PORT))
+    print("server started")
+
+    while True:
+        s.listen()
+        conn, addr = s.accept()
+        newthread = ClientThread(addr, conn)
+        newthread.start()