常連

## テーマ、知りたいこと

ローカル間でのソケット通信にもセキュリティ対策（暗号化）が必要か？

## 背景、状況

ローカル間でのソケット通信を行っています
複数台のクライアント(ハンディーターミナル)からサーバーPC(DBはsqlite)に情報問合・返信するシステムを構築運用しています

コード自体はネット情報を元に非同期で動くサーバープログラムを組んでいます

※特段プログラム関連の教育を受けた訳でなく、自己学習で組んでいます

既に運用中ですが、今回、改良をしないといけない部分があり、作業を実施しています
ついでに他の部分でも修正しようかと思って勉強しています

その中で通信のセキュリティが何もしていないので対策をとった方がいいのかと思っています
現在、特段、暗号化などのセキュリティ対策はしていません

まだ勉強中ですが、通常、プロの方ならSSL通信などにするのが普通でしょうか？
ローカル間なら必要無いって感じでしょうか？

サーバーPC(DBはsqlite)といってもこれはインターネットには繋がっていますので
完全なクローズなネットワークではありません



ローカル間でのソケット通信のセキュリティについて

### 実現したいこと
HTTPサーバーが正しくファイルアップロードを処理し、画像ファイルをサーバーに保存するようにする。

### 発生している問題・分からないこと
HTTPサーバーをC言語で実装しています。POSTリクエストを処理し、クライアントから送信されたファイルをサーバーに保存したいのですが、リクエストボディの解析が正しく行われず、ファイルデータが正しく保存されません。現在のコードでは、POSTリクエストのヘッダーは正しく受信されていますが、ファイルデータの部分がうまく処理されていない状態です。
何か解決法をご教示いただけますと幸いです。



### 該当のソースコード

```C
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/wait.h>

#define PORT 8080
#define BUFSIZE 8192

void error(const char *msg) {
    perror(msg);
    exit(1);
}

void handle_request(int newsockfd) {
    char buffer[BUFSIZE];
    int n;
    char boundary[256];

    // Read the initial request into the buffer
    n = read(newsockfd, buffer, BUFSIZE - 1);
    if (n < 0) error("ERROR reading from socket");
    buffer[n] = 0;

    printf("Here is the message: %s\n", buffer);

    if (strncmp(buffer, "GET ", 4) == 0) {
        // Handle GET request
        char *filepath = strtok(buffer + 4, " ");
        if (strcmp(filepath, "/") == 0) {
            filepath = "/index.html";
        }

        char fullpath[BUFSIZE] = ".";
        strncat(fullpath, filepath, BUFSIZE - strlen(fullpath) - 1);

        int filefd = open(fullpath, O_RDONLY);
        if (filefd < 0) {
            char *not_found = "HTTP/1.1 404 Not Found\r\nContent-Length: 13\r\n\r\n404 Not Found";
            write(newsockfd, not_found, strlen(not_found));
        } else {
            char response[BUFSIZE];
            sprintf(response, "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\n");
            write(newsockfd, response, strlen(response));

            while ((n = read(filefd, buffer, BUFSIZE)) > 0) {
                write(newsockfd, buffer, n);
            }
            close(filefd);
        }
    } else if (strncmp(buffer, "POST ", 5) == 0) {
        // Handle POST request
        char *content_length_str = strstr(buffer, "Content-Length: ");
        int content_length = 0;
        if (content_length_str) {
            sscanf(content_length_str, "Content-Length: %d", &content_length);
        }

        char *content_type_str = strstr(buffer, "Content-Type: multipart/form-data; boundary=");
        if (content_type_str) {
            sscanf(content_type_str, "Content-Type: multipart/form-data; boundary=%s", boundary);
        }

        // Read the remaining data of the request
        if (n < content_length) {
            int remaining = content_length - n;
            char *full_request = malloc(content_length + 1);
            memcpy(full_request, buffer, n);
            int read_bytes = read(newsockfd, full_request + n, remaining);
            if (read_bytes < 0) {
                error("ERROR reading remaining bytes from socket");
            }
            full_request[content_length] = 0;
            strcpy(buffer, full_request);
            free(full_request);
        }

        char *part_start = strstr(buffer, boundary);
        if (part_start) {
            part_start += strlen(boundary) + 2; // Skip boundary and \r\n

            while (part_start && *part_start != '-' && *part_start != 0) {
                char *header_end = strstr(part_start, "\r\n\r\n");
                if (header_end) {
                    header_end += 4; // Skip past \r\n\r\n

                    char *part_end = strstr(header_end, boundary);
                    if (part_end) {
                        part_end -= 2; // Exclude trailing \r\n

                        // Check for Content-Disposition header with filename
                        char *content_disposition = strstr(part_start, "Content-Disposition: ");
                        if (content_disposition && strstr(content_disposition, "filename=")) {
                            size_t data_length = part_end - header_end;
                            if (data_length > 0) {
                                FILE *file = fopen("upload.jpg", "wb");
                                if (file) {
                                    fwrite(header_end, 1, data_length, file);
                                    fclose(file);

                                    char *ok_response = "HTTP/1.1 200 OK\r\nContent-Length: 2\r\n\r\nOK";
                                    write(newsockfd, ok_response, strlen(ok_response));
                                } else {
                                    char *internal_error = "HTTP/1.1 500 Internal Server Error\r\nContent-Length: 21\r\n\r\n500 Internal Server Error";
                                    write(newsockfd, internal_error, strlen(internal_error));
                                }
                            } else {
                                char *bad_request = "HTTP/1.1 400 Bad Request\r\nContent-Length: 27\r\n\r\n400 Bad Request: No file data";
                                write(newsockfd, bad_request, strlen(bad_request));
                            }
                        }

                        part_start = part_end + strlen(boundary) + 2; // Skip past boundary and \r\n
                    } else {
                        break;
                    }
                } else {
                    break;
                }
            }
        } else {
            char *bad_request = "HTTP/1.1 400 Bad Request\r\nContent-Length: 15\r\n\r\n400 Bad Request";
            write(newsockfd, bad_request, strlen(bad_request));
        }
    } else {
        char *bad_request = "HTTP/1.1 400 Bad Request\r\nContent-Length: 15\r\n\r\n400 Bad Request";
        write(newsockfd, bad_request, strlen(bad_request));
    }
}

int main() {
    int server_fd, new_socket;
    struct sockaddr_in address;
    int addrlen = sizeof(address);

    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
        perror("Socket creation failed");
        exit(EXIT_FAILURE);
    }

    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons(PORT);

    if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("Bind failed");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    if (listen(server_fd, 10) < 0) {
        perror("Listen failed");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    printf("Server is listening on port 8080\n");

    while (1) {
        printf("Waiting for connections...\n");

        if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
            perror("Accept failed");
            continue;
        }

        pid_t pid = fork();
        if (pid < 0) {
            perror("Fork failed");
            close(new_socket);
            continue;
        }

        if (pid == 0) {
            close(server_fd);
            handle_request(new_socket);
            exit(0);
        } else {
            close(new_socket);
            waitpid(-1, NULL, WNOHANG); // Prevent zombie processes
        }
    }

    close(server_fd);
    return 0;
}

```

### 試したこと・調べたこと
- [x] teratailやGoogle等で検索した
- [x] ソースコードを自分なりに変更した
- [ ] 知人に聞いた
- [ ] その他

##### 上記の詳細・結果
POSTリクエストの読み込み処理とMultipart/form-dataのバウンダリの解析処理を追加しましたが、ファイルデータの部分がうまく処理されません。

### 補足
FW/ツールのバージョンや、補足事項があれば入力してください

開発環境：MacOS 10.15.7
コンパイラ：gcc version 10.2.0
クライアント：Google Chrome 126.0.0.0

C言語でのHTTPサーバーでPOSTリクエストのファイルアップロードが正しく処理されない

### 前提・実現したいこと
Pythonを用いて2台のパソコン間でTCP/IP通信を行いたい
（追加の質問：1台のパソコンで行ったとき、netstatで出てきたローカルアドレスがサーバ側なのか、クライアント側なのか知りたい）
### 発生している問題・エラーメッセージ
以下の用にサーバのIPアドレスを打っても通信できません。

```
接続先サーバ：サーバのIPアドレスを打ちました
接続できません

プロセスは終了コード 0 で完了しました
```
同じパソコン内で行うと通信できます
```
接続先サーバ：localhost
メッセージを入力：Hello
サーバからのメッセージ：
2020-11-22 17:19:18.560995

プロセスは終了コード 0 で完了しました
```

### 該当のソースコード1(server側)

```Python
# モジュールのインポート
import socket
import datetime


# グローバル変数
PORT = 50002     # ポート番号
BUFSIZE = 4096    # 受信バッファの大きさ

# メイン実行部
# ソケットの作成
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# アドレスの設定
server.bind(("",PORT))
# 接続の待ち受け
server.listen()

# クライアントへの対応処理
while True:                                    # 対応の繰り返し
    client, addr = server.accept()             # 通信用ソケットの取得
    msg = str(datetime.datetime.now())         # メッセージの作成
    print(msg,"接続要求あり")
    print(client)
    data = client.recv(BUFSIZE)                # クライアントより受信 
    print(data.decode("UTF-8"))                # 受信内容の出力
    client.sendall(msg.encode("utf-8"))        # メッセージの送信
    client.close()                             # コネクションのクローズ
```

### 該当のソースコード2(client側)

```Python
# モジュールのインポート
import socket
import sys

# グローバル変数
PORT = 50002  # ポート番号
BUFSIZE = 4096  # 受信バッファの大きさ

# メイン実行部
# ソケットの作成
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# サーバとの接続
host = input("接続先サーバ：")
try:
    client.connect((host, PORT))
except:
    print("接続できません")
    sys.exit()
# サーバへのメッセージの送信
msg = input("メッセージを入力：")
client.sendall(msg.encode("utf-8"))
# サーバからのメッセージの受信
data = client.recv(BUFSIZE)
print("サーバからのメッセージ：")
print(data.decode("UTF-8"))
# コネクションのクローズ
client.close()
```

### 試したこと

初めに同じパソコン内で試してみようと思い、クライアントのhostに"localhost"と入れて実行したところ通信できたが、その値を2台目のパソコンのIPアドレスにしたところできなかった。

### 補足情報（FW/ツールのバージョンなど）
Python 3.6
Anaconda3
PyCharm
Windows 10

Pythonのtcp/ip通信で、2台のパソコンを通信させたい

###質問内容
ソケットを使って，
名前，スコア，モード(easyかhardを数字で表したものの文字列)
をサーバーに送信しようと考えています．
ですが，実行しようとしてみたところ，Requester.sendScoreのshow ranking とコメントしたループのin.readLineが原因でjava.net.SocketException: Connection resetという例外が出てしまいました．
これはどのようにすれば解消できますか．

[リンク内容](https://sun0range.com/information-technology/java-net-socketexception/)
うえのようなサイトを見たところ範囲が広い例外のようで．調べてもあまり良くわかりませんでした．

###Requester
```Java
import java.net.*;
import java.util.*;
import java.io.*;

public class Requester extends Worker {
    //send score to server, show ranking
    public void sendScore(Player player){
        try {
            String name = player.getName();
            String score = String.valueOf(player.getScore());
            String mode =  String.valueOf(player.getMode());

            InetAddress addr = InetAddress.getByName("localhost");  // change for IP address
            Socket socket = new Socket(addr, 8080);   //set port No.
            PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
            out.println(name);     //send name
            out.println(score);    //send score
            out.println(mode);     //send mode

            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            
            //show ranking
            for(int i=0; i<6; i++){
                String str = in.readLine();
                System.out.println(str);
                Thread.sleep(1000);
            }

            socket.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}
```

###例外本文
```ここに言語を入力
java.net.SocketException: Connection reset
        at java.base/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:323)
        at java.base/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350)
        at java.base/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803)
        at java.base/java.net.Socket$SocketInputStream.read(Socket.java:976)
        at java.base/sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:297)
        at java.base/sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:339)
        at java.base/sun.nio.cs.StreamDecoder.read(StreamDecoder.java:188)
        at java.base/java.io.InputStreamReader.read(InputStreamReader.java:178)
        at java.base/java.io.BufferedReader.fill(BufferedReader.java:161)
        at java.base/java.io.BufferedReader.readLine(BufferedReader.java:329)
        at java.base/java.io.BufferedReader.readLine(BufferedReader.java:396)
        at Requester.sendScore(Requester.java:55)
        at ClientMain.main(ClientMain.java:57)
```


###追記
Server側
updateRankingでスコアを受け取っています．

```Java
import java.net.*;
import java.util.*;
import java.util.Map.Entry;
import java.io.*;


public class Responser{
    private static ArrayList<String> Qstring = new ArrayList<>();  //question
    private static ArrayList<Long> timeList = new ArrayList<>();      //waiting list
    
    //accept score and register it to ranking
    public void updateRanking() throws IOException {
        ServerSocket s = new ServerSocket(8080); // make socket
        Socket socket = s.accept();  // wait setting demand of connection
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        String p_name = in.readLine();    //accept name
        String p_score = in.readLine();   //accept score
        int p_mode = Integer.parseInt(in.readLine());    //accept mode

        String rankingFilePath;
        if(p_mode == 1)    rankingFilePath = "data/ranking/easyranking.txt";
        else               rankingFilePath = "data/ranking/hardranking.txt";
        
        //key=ID, value=score
        Map<Integer,Integer> scores = new HashMap<Integer,Integer>();
        ArrayList<String> playerNameList = new ArrayList<String>();
        
        Scanner s2 = new Scanner(new File(rankingFilePath));
        int count = 1;
        
        int id = -1, score = -1;
        String name = "";
        while (s2.hasNext()){
            if(count % 3 == 1){
                id = Integer.parseInt(s2.next());
            }else if(count % 3 == 2){
                score = Integer.parseInt(s2.next());
            }else{
                name = s2.next();
                scores.put(id,score);
                playerNameList.add(name);
            }
            count++;
        }

        try{
            int nextId = playerNameList.size()+1;
            File file = new File(rankingFilePath);
            FileWriter filewriter = new FileWriter(file, true);
            filewriter.write(nextId + " " + p_score + " " + p_name + "\n");
            filewriter.close();
            scores.put(nextId, Integer.parseInt(p_score));
            playerNameList.add(p_name);
        }catch(IOException e){
            System.out.println(e);
        }

        // make entry list of scorelist
        List<Entry<Integer, Integer>> list_entries = new ArrayList<Entry<Integer, Integer>>(scores.entrySet());
        
        //sort scorelist
        Collections.sort(list_entries, new Comparator<Entry<Integer, Integer>>() {
            public int compare(Entry<Integer, Integer> obj1, Entry<Integer, Integer> obj2) {
                return obj2.getValue().compareTo(obj1.getValue());
            }
        });


        PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);  //setting of sending buffer

        //send ranking data to client
        String[] ordinalNumber = {"1st", "2nd", "3rd", "4th", "5th"};
        out.println("--- Rank | Player | Score ---");
        for(int i=0; i<5; i++){
            out.println(ordinalNumber[i] + ", "  + playerNameList.get(list_entries.get(i).getKey()-1) + ", " + list_entries.get(i).getValue());
        }
        s.close();
    }

}
```


###ClientMain
```Java
import java.io.*;
import java.util.*;

public class ClientMain {
    public static void main(String[] args) throws InterruptedException{
        Player player = new Player("", 0, 0);  //(name, score, mdoe)
        GameData gameData = new GameData(player);
        ClientSystem clientsystem = new ClientSystem();
        Requester requester = new Requester();
        
        clientsystem.opening();  //op 

        clientsystem.say("Choose difficulty from easy:1 or hard:2.");
        clientsystem.say("Input the difficulty number.");
        Scanner scan = new Scanner(System.in);
        int difficulty = scan.nextInt();

        player.setMode(difficulty);
        requester.sendDifficulty(player);
        
        clientsystem.say("send difficulty");
        clientsystem.say("gamedata download...");
        Thread.sleep(1000);

        requester.requestGameData(gameData);  //download gamedata from server
        clientsystem.say("Load Successes!");
        Thread.sleep(2000);

        clientsystem.startGame(gameData);  //gamestart
        System.out.println();
        clientsystem.say("Finish");  
        
        clientsystem.showScore(player);  //show score

        
        clientsystem.say("Please input your name.");

        String playerName = scan.nextLine();
        scan.close();
        player.setName(playerName);
        
        requester.sendScore(player);  

        clientsystem.say("See you!");
    }
}
```



###実行本文
```ここに言語を入力
[Welcome to this TYPING GAME.]
[When this system says something, uses [] like this message]
[--rule--]
[Type the message enclosed in {}.]
[The next is a example.]
Q.{ もんだいぶん }
[if you misstype and enter without modifying, subtract your score.]
[There are two difficulty levels]
[Choose difficulty from easy:1 or hard:2.]
[Input the difficulty number.]
1
[send difficulty]
[gamedata download...]
[Load Successes!]
[Are you ready?]
[START!]
0

[Finish]
[Score: 0]
[Please input your name.]
--- Rank | Player | Score ---
java.net.SocketException: Connection reset
        すでに載せたので文字数の都合上割愛
[See you!]
PS C:\Users\Client>
```

###原因の推定
名前の入力をまたずに
--- Rank |
というものが出力されてしまっているので，
名前の入力をしようとしたときにupdateRankingがもう始まってしまっているのが原因だと考えられます．
本来ならこのupdateはsendScoreを待たなければいけないのに先に終わらせてしまっているからこのような例がでたと考えております．
updateRankingｇがしっかりと待機するようにするにはどうすればよいですか
文字数の都合上，必要ないと判断した関数は省略しました

java.net.SocketExceptionの対処法

現在、VisualStudio2015 のWindowsフォームアプリケーションにてソケットを使用したシリアル通信のコードを書いています。

基本的な通信（送受信）はできるようになったのですが、受信メソッドにて

```C#
 //受信データのバイト数分蓄積
  do
  {
     int length = ComPort.Read(buffer, readlen, rbyte - readlen);
     readlen += length;
  } while (readlen < rbyte);
   recData += System.Text.Encoding.ASCII.GetString(buffer);
   logText(recData, ComPort);
```
これで送られてきたByteをそのバイト分貯めてから
文字列に変換してテキストボックスにinvokeして書き込んでいますが、受信時にデータが分割されて送られてしまいます。

なので改行まで取得するように改良して以下のようにしました。
```C#
 // 受信データを改行まで蓄積
do
{
   int length = ComPort.Read(buffer, readlen, rbyte - readlen);
   readlen += length;
} while (readlen < rbyte);
 recData += System.Text.Encoding.ASCII.GetString(buffer);
 newline = recData.IndexOf(Environment.NewLine);
if (newline >= 0)
{
   logText(recData, ComPort);
}
else
{
   Sendbuffa += recData;       //データをいったん保存
}
```
ですが、これだと一度の2回送信分のデータ（改行コードがふたつある）を受信してしまったときに、
1回送信分の中に改行コードが２つあると判断されてしまいます。
なので、改行コードを見つけたらその時点でテキストボックスに書きだしたいのですが、どう修正すればよいでしょうか。

尚、上記両コードとも表記したコードをCOMポート接続されている間ループさせております。

よろしくお願いいたします。

C#　シリアル通信のバイナリデータ受信

###前提・実現したいこと
visualstudio2015
c++
win32コンソールアプリケーション
でのソケット通信
###発生している問題・エラーメッセージ
http://blog.livedoor.jp/akf0/archives/51585502.html
のサンプルコードを入力したのですが
下記のエラーがでてしまいます

エラー	C4996	'inet_addr': Use inet_pton() or InetPton() instead or define _WINSOCK_DEPRECATED_NO_WARNINGS to disable deprecated API warnings	


###該当のソースコード
include <stdio.h>
include <winsock2.h>

int main(void) {

	SOCKET s;    //ソケット
	//接続するサーバの情報
	struct sockaddr_in dest;

	//接続するサーバのIPアドレス
        //ループバックアドレスを利用
	char destination[] = "127.0.0.1";
	char buffer[1024];

	//ソケット通信の準備
	WSADATA data;
	WSAStartup(MAKEWORD(2, 0), &data);

	//接続先（サーバ）のアドレス情報を設定
	memset(&dest, 0, sizeof(dest));
	//ポート番号はサーバプログラムと共通
	dest.sin_port = htons(7000);
	dest.sin_family = AF_INET;
	dest.sin_addr.s_addr = inet_addr(destination);

	//ソケットの生成
	s = socket(AF_INET, SOCK_STREAM, 0);

	//サーバへの接続
	if (connect(s, (struct sockaddr *) &dest, sizeof(dest))) {
		printf("%sに接続できませんでした\n", destination);
		return -1;
	}

	printf("%sに接続しました\n", destination);
	printf("数値を入力してください");
	scanf_s("%s",buffer,1024);

	//サーバにデータを送信
	send(s, buffer, sizeof(buffer), 0);

	//サーバからデータを受信
	recv(s, buffer, 1024, 0);
	printf("→ %s\n\n", buffer);

	// Windows でのソケットの終了

	closesocket(s);

	WSACleanup();

	return 0;

}

###追記
define _WINSOCK_DEPRECATED_NO_WARNINGS
をプログラムのはじめに書いたところ
外部シンボル"_imp_inet_addr@4"は未解決です
のようなエラーがたくさんでてきました
どうすればエラーをなくすことができるのでしょうか

ws2_32.libはリンカーのコマンドラインの追加オプションに入れてあります

windows c++ ソケット通信

eelを使いサーバ側を python、クライアント側をJavaScriptでデータの受け渡しをしてチャットができるクライアントアプリケーションを作成したいのですが、 pythonとJavaScript間でデータを明け渡すにはどうしたらいいでしょうか？
eelを使わなくて構わないので python、JavaScript間でデータの受け渡しする、例のプログラムなどあれば嬉しいです。

pythonとJavaScript間でデータの受け渡しがしたい

### 実現したいこと
Pythonでローカルサーバーを立て、スマホからpc上の写真や動画を閲覧したいと思っています。

しかし、ファイルサイズが大きい場合(？)、下記のようなエラーが出てしまいます。

~~タイムアウトの時間を伸ばしたり~~、通信を完了することは可能でしょうか？

タイムアウトを設定したが解決できませんでした。

```
ConnectionResetError: 
[WinError 10054] 既存の接続はリモート ホストに強制的に切断されました。
```
### 前提
以下のサイトと同じ方法でローカルサーバーを立てています。
https://qiita.com/okhrn/items/4d3c74563154f191ba16
```
import http.server
import socketserver

PORT = 8000
Handler = http.server.SimpleHTTPRequestHandler

with socketserver.TCPServer(("", PORT), Handler) as httpd:
    print("serving at port", PORT)
    httpd.serve_forever()
```

### 発生している問題・エラーメッセージ

```
ConnectionResetError: [WinError 10054] 既存の接続はリモート ホストに強制的に切断されました。
```

### 試したこと

HTMLに動画を張り付けても同じエラーが出ました。
軽い動画や写真なら閲覧できます。
