Java server, UWP(C#)client間でのTCPIP通信

Question

前提

Javaをサーバー，C#で書かれたUWPアプリケーション(Hololens2)をクライアントとして，TCP通信で相互通信を行いたいです。

しかし、データの送受信の以前に、サーバーを立ち上げて、クライアントを立ち上げてもこの2つが接続されなくて困っています。

実現したいこと

• [1] Hololensとほかのソフトウェアでの通信のためにその2つ間のTCPIP通信の開通

該当のソースコード

using System;
#if UNITY_UWP
using System.IO;
using System.Threading.Tasks;
using Windows.Networking;
using Windows.Networking.Sockets;
#endif

public class TcpNetworkClientManager
{

#if UNITY_UWP
    private StreamWriter writer = null;
#endif

    public TcpNetworkClientManager(string IP, int port)
    {
#if UNITY_UWP
        Task.Run(async () => {
            StreamSocket socket = new StreamSocket();
            await socket.ConnectAsync(new HostName(IP),port.ToString());
            writer = new StreamWriter(socket.OutputStream.AsStreamForWrite());
            StreamReader reader = new StreamReader(socket.InputStream.AsStreamForRead());
            try
            {
                string data = await reader.ReadToEndAsync();
            }
            catch (Exception) { }
            writer = null;
        });
#endif
    }

    public void SendMessage(string data)
    {
#if UNITY_UWP
        if (writer != null) Task.Run(async () =>
        {
            await writer.WriteAsync(data);
            await writer.FlushAsync();
        });
#endif
    }

}

該当のソースコード

using System.Collections;
using System.Collections.Generic;
using UnityEngine;

public class TCPIP : MonoBehaviour
{

    string IP = "127.0.0.1";
    int port = 3333;

  //  TcpNetworkClientManager client = null;

    // Start is called before the first frame update
    void Start()
    {
        Debug.Log("Connected");
        client = new TcpNetworkClientManager(IP, port);
    }

    // Update is called once per frame
    void Update()
    {
        
    }
}

該当のソースコード

import java.io.BufferedReader;
	import java.io.IOException;
	import java.io.InputStreamReader;
	import java.io.PrintWriter;
	import java.net.InetSocketAddress;
	import java.net.ServerSocket;
	import java.net.Socket;

public class server {
	
	public static void main(String[] args) {
		Sample1 ss = new Sample1();
		ss.runSample();

	}


}

class Sample1 {
	
	void runSample() {

		
		String data1 = "";
		String data2;
		int num;
		
	ServerSocket sSocket = null;
	Socket socket = null;
	BufferedReader reader = null;
	BufferedReader reader2 = null;
	
	PrintWriter writer = null;
	
	try{
		//IPアドレスとポート番号を指定してサーバー側のソケットを作成
		sSocket = new ServerSocket(3333);
		
	
		System.out.println("クライアントからの入力待ち状態");
		
		//クライアントからの要求を待ち続けます
		socket = sSocket.accept();
		
		System.out.println("アクセス完了");
		
		//クライアントからの受取用
		reader = new BufferedReader(
				new InputStreamReader
				(socket.getInputStream()));
		
		reader2 = new BufferedReader(
				new InputStreamReader
				(socket.getInputStream()));
		
		//クライアントへの送信用
		writer = new PrintWriter(
				socket.getOutputStream(), true);
		
        	
		while(true) {
			
			data1 = reader.readLine();
			System.out.println("1" +data1);
			if(data1.equals("bye")){
				System.out.println("2");
				break;
			}
        	
			try{
				
				num = Integer.parseInt(data1);
				
            	//data1 = reader.readLine();
				
				if(num %2 == 0){
					writer.println("OK");
				}else{
					writer.println("NG");
				}
	        	
	        	/*System.out.println("data1 ::" + data1 + "\n" );
	        	
	        	data2 = reader2.readLine();
	        	
	        	System.out.println("data2 :: " + data2 + "\n");*/
	        	
			}catch(NumberFormatException e){
        		//送信用の文字を送信
                writer.println("数値を入力して下さい");
        	}

            System.out.println("クライアントで入力された文字＝" + data1);
        }			
	}catch(Exception e){
		System.out.println("3");
		e.printStackTrace();
	}finally{
		try{
			if (reader!=null){
				reader.close();
			}
			if (writer!=null){
				writer.close();
			}
			if (socket!=null){
				socket.close();
			}
			if (sSocket!=null){
				sSocket.close();
			}
            System.out.println("サーバー側終了です");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	}
}
 

試したこと

https://akihiro-document.azurewebsites.net/post/hololens_sharingtcp/
https://qiita.com/SatoshiGachiFujimoto/items/91e28207ad48378d9c28
https://teratail.com/questions/130702
これらを参考に取り組んだのですが、うまく接続をできませんでした。

UWPを使用するのに慣れていないため、教えていただけると幸いです。

補足情報（FW/ツールのバージョンなど）

Unity2020.3.30.f1からビルドしたUWPアプリケーション(visual studio 2019)

Comments

[jimbe]

tcpip 的につながる環境で実行されているのでしょうか。
また、各々何処まで動いているのか、ログやエラー等のメッセージの状態等をご質問に追加してください。

[3-4. 発生している問題・エラーメッセージを書きましょう]
https://teratail.com/help/question-tips#questionTips34

[dodox86]

> string IP = "127.0.0.1";

ということで、サーバーもクライアントも同じPC上で、つまりはローカルで動かそうとしていますか。

[aaaddd]

>[3-4. 発生している問題・エラーメッセージを書きましょう]
特にエラーメッセージは出力されていません
また、Unity内でballというGameObjectを定義してオブジェクトの非表示を実行したところ、非表示されたので追加したところの呼び出しは確認しました。
public TcpNetworkClientManager(string IP, int port)
{
#if UNITY_UWP
//追加
ball.SetActive(false);　　//ball objectの非表示
Task.Run(async () => {
StreamSocket socket = new StreamSocket();
await socket.ConnectAsync(new HostName(IP),port.ToString());
writer = new StreamWriter(socket.OutputStream.AsStreamForWrite());
StreamReader reader = new StreamReader(socket.InputStream.AsStreamForRead());
try
{
string data = await reader.ReadToEndAsync();
}
catch (Exception) { }
writer = null;
});
#endif
}

[aaaddd]

>ということで、サーバーもクライアントも同じPC上で、つまりはローカルで動かそうとしていますか。
はい、そのとおりです
同一PC間での通信を試みています

[jimbe]

java の方が System.out.println で流れが分かるようになっているのと同じように、UWP の方にも細かく Debug.Log を入れてどこを通って何が起きているのかを調べてみては如何でしょうか。

[aaaddd]

>Debug.Log を入れてどこを通って何が起きているのかを調べてみては如何でしょうか。
そうですね、一旦その方向でやろうと考えています。

Answer 1

ソケット通信できました

Answer 2

クライアント UWP 側は分かりませんのでサーバ java 側だけ。
reader と reader2 という 2 つの BufferedReader を 1 つの socket.getInputStream から作成していますが、そのようなことはできません。

---

ご提示の java のサーバは以下のような感じで動作・テスト出来ます。
一問一答形式で"bye"が来るまで数値の奇数/偶数を判断するサーバということになりますが、クラアントに対するサーバとして妥当な機能なのでしょうか。

Server.java

package teratail_java.q_6p00dtc71nk50f;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
  public static void main(String[] args) throws IOException {
    try(ServerSocket ss = new ServerSocket(3333);) {
      System.out.println("クライアントからの接続待ち");
      try(Socket s = ss.accept();
          BufferedReader reader = new BufferedReader(new InputStreamReader(s.getInputStream()));
          PrintWriter writer = new PrintWriter(s.getOutputStream(), true);) {
        System.out.println("接続");
        while(true) {
          String line = reader.readLine();
          System.out.println("1 " + line);

          if(line.equals("bye")) {
            System.out.println("2");
            break;
          }

          try {
            int num = Integer.parseInt(line);
            writer.println(num % 2 == 0 ? "OK" : "NG");
          } catch(NumberFormatException e) {
            writer.println("数値を入力して下さい");
          }
          System.out.println("クライアントで入力された文字=" + line);
        }
      } catch(Exception e) {
        e.printStackTrace();
      }
    }
    System.out.println("サーバー側終了です");
  }
}

Client.java

package teratail_java.q_6p00dtc71nk50f;

import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
  public static void main(String[] args) throws UnknownHostException, IOException {
    try(Socket s = new Socket("127.0.0.1", 3333);
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        PrintWriter pw = new PrintWriter(s.getOutputStream(), true);) {

      for(String arg : args) {
        pw.println(arg);
        String line = br.readLine();
        System.out.println(line);
      }
      pw.println("bye");
    }
  }
}

実行結果(Server)

>java teratail_java.q_6p00dtc71nk50f.Server
クライアントからの接続待ち
接続
1 123
クライアントで入力された文字=123
1 abc
クライアントで入力された文字=abc
1 86
クライアントで入力された文字=86
1 bye
2
サーバー側終了です

実行結果(Client)

>java teratail_java.q_6p00dtc71nk50f.Client 123 abc 86
NG
数値を入力して下さい
OK

Comments

[aaaddd]

Javaのクライアントとサーバーありがとうございます。

デバックを行った結果、
public TcpNetworkClientManager(string IP, int port)
{
#if UNITY_UWP
Task.Run(async () => {
StreamSocket socket = new StreamSocket();
await socket.ConnectAsync(new HostName(IP),port.ToString());
writer = new StreamWriter(socket.OutputStream.AsStreamForWrite());
StreamReader reader = new StreamReader(socket.InputStream.AsStreamForRead());
try
{
string data = await reader.ReadToEndAsync();
}
catch (Exception) { }
writer = null;
});
#endif
}
TcpNetworkClientManager(string IP, int port)メソッド内には、入ることは確認したのですが
#if UNITY_UWPから#endif間に入らないことが確認されました。
UWP変換をした際に、どのように書けばいいのかわかるでしょうか。
もし、わかる方いましたらご教授いただきたいです。