通过wifi连接服务器和客户端套接字
Connecting server and client socket over wifi
这是服务器代码
void bind(String ip,int port)
{
socket=ServerSocketChannel.open();
socket.configureBlocking(false);
socket.register(acceptChannel=Selector.open(),SelectionKey.OP_ACCEPT);//Since Non Blocking Create Selector
socket.bind(new InetSocketAddress(ip,port));//Binding To Specified IP,Port So clients can connect
accept=threadService.scheduleAtFixedRate(this,100,interval,TimeUnit.MILLISECONDS);
}
void run()//Just Loops And Checks For New Clients
{
try
{
if(acceptChannel.selectNow()==0){return;}
Set<SelectionKey> channels=acceptChannel.selectedKeys();
Iterator<SelectionKey> iterator=channels.iterator();
while(iterator.hasNext())
{
SelectionKey key=iterator.next();
ServerSocketChannel server=(ServerSocketChannel)key.channel();
SocketChannel client=server.accept();
client.configureBlocking(false);
//Do Stuff With Client
iterator.remove();
}
channels.clear();
}
catch(Exception ex){errors.newClientError(ex,mainSocket,client);}
}
这是客户端代码
SocketChannel clientSocket;
void connect(String IP,int port)throws IOException
{
clientSocket=SocketChannel.open();
clientSocket.configureBlocking(false);
clientSocket.register(connectChannel,SelectionKey.OP_CONNECT);//Non Blocking So Loop to check for status
clientSocket.connect(new InetSocketAddress(IP,port));//Do Actual Connection Here
waiting=threadService.scheduleAtFixedRate(this,100,10,TimeUnit.MILLISECONDS);
}
public void run()//Loops and checks for successful connection
{
try
{
if(connectChannel.selectNow()==0){return;}
Set<SelectionKey> channels=connectChannel.selectedKeys();
Iterator<SelectionKey> iterator=channels.iterator();
while(iterator.hasNext())
{
SelectionKey client=iterator.next();
SocketChannel channel=(SocketChannel)client.channel();
if(channel.finishConnect())
{
client.cancel();
iterator.remove();
channels.clear();
//Yeah we are connected job done
return;
}
iterator.remove();
}
channels.clear();
}
catch(Exception ex)
{
}
}
如您所见,出于项目特定目的,我的客户端和服务器都必须处于非阻塞模式。
现在此代码在
时有效
1)客户端和服务器在同一台电脑上,客户端和服务器的IP参数都是"localhost"
2) 客户端和服务器都在同一台计算机上,客户端和服务器的 IP 参数是我路由器的网络地址[我在 windows 所以我转到 cmd 类型 ipconfig 并将 IPV4 地址传递给两者这些方法]
问题是我的客户在通过 wifi/lan 连接的不同系统上时无法连接到我的服务器。
我将我的服务器绑定到我的路由器的 IPV4 地址,并将相同的地址提供给我的客户在另一台机器上的 connect() 方法,但他得到 "ConnectionTimedOutException"
客户端和服务器的端口参数相同,均为 8001
本次测试禁用了两个系统防火墙。
知道出了什么问题吗?
我不得不使用端口转发来解决我的问题
我进行了以下步骤
1)客户端在 connect() 方法
中使用我从网络[whatsmyip.com]获得的全局[非本地 ipv4] 地址
2) 在我的服务器中,我使用本地 ipv4 地址调用 bind()[from ipconfig]
3) 我使用的公共端口是 8001,我必须在我的路由器设置中配置端口转发,以便它将所有数据包从我的全局 ip:port XXX.XXX.XXX.XXX:8001 转发到我的本地 ipv4 address:port192.168.xxx.xxx:8001
这种方法有效但效率不高,因为当我断开连接并重新连接时我的 IP 会发生变化。如果有人知道无需配置静态 IP 即可连接到服务器的更好解决方案,请分享。谢谢你
这是服务器代码
void bind(String ip,int port)
{
socket=ServerSocketChannel.open();
socket.configureBlocking(false);
socket.register(acceptChannel=Selector.open(),SelectionKey.OP_ACCEPT);//Since Non Blocking Create Selector
socket.bind(new InetSocketAddress(ip,port));//Binding To Specified IP,Port So clients can connect
accept=threadService.scheduleAtFixedRate(this,100,interval,TimeUnit.MILLISECONDS);
}
void run()//Just Loops And Checks For New Clients
{
try
{
if(acceptChannel.selectNow()==0){return;}
Set<SelectionKey> channels=acceptChannel.selectedKeys();
Iterator<SelectionKey> iterator=channels.iterator();
while(iterator.hasNext())
{
SelectionKey key=iterator.next();
ServerSocketChannel server=(ServerSocketChannel)key.channel();
SocketChannel client=server.accept();
client.configureBlocking(false);
//Do Stuff With Client
iterator.remove();
}
channels.clear();
}
catch(Exception ex){errors.newClientError(ex,mainSocket,client);}
}
这是客户端代码
SocketChannel clientSocket;
void connect(String IP,int port)throws IOException
{
clientSocket=SocketChannel.open();
clientSocket.configureBlocking(false);
clientSocket.register(connectChannel,SelectionKey.OP_CONNECT);//Non Blocking So Loop to check for status
clientSocket.connect(new InetSocketAddress(IP,port));//Do Actual Connection Here
waiting=threadService.scheduleAtFixedRate(this,100,10,TimeUnit.MILLISECONDS);
}
public void run()//Loops and checks for successful connection
{
try
{
if(connectChannel.selectNow()==0){return;}
Set<SelectionKey> channels=connectChannel.selectedKeys();
Iterator<SelectionKey> iterator=channels.iterator();
while(iterator.hasNext())
{
SelectionKey client=iterator.next();
SocketChannel channel=(SocketChannel)client.channel();
if(channel.finishConnect())
{
client.cancel();
iterator.remove();
channels.clear();
//Yeah we are connected job done
return;
}
iterator.remove();
}
channels.clear();
}
catch(Exception ex)
{
}
}
如您所见,出于项目特定目的,我的客户端和服务器都必须处于非阻塞模式。
现在此代码在
时有效1)客户端和服务器在同一台电脑上,客户端和服务器的IP参数都是"localhost"
2) 客户端和服务器都在同一台计算机上,客户端和服务器的 IP 参数是我路由器的网络地址[我在 windows 所以我转到 cmd 类型 ipconfig 并将 IPV4 地址传递给两者这些方法]
问题是我的客户在通过 wifi/lan 连接的不同系统上时无法连接到我的服务器。
我将我的服务器绑定到我的路由器的 IPV4 地址,并将相同的地址提供给我的客户在另一台机器上的 connect() 方法,但他得到 "ConnectionTimedOutException"
客户端和服务器的端口参数相同,均为 8001
本次测试禁用了两个系统防火墙。
知道出了什么问题吗?
我不得不使用端口转发来解决我的问题
我进行了以下步骤
1)客户端在 connect() 方法
中使用我从网络[whatsmyip.com]获得的全局[非本地 ipv4] 地址2) 在我的服务器中,我使用本地 ipv4 地址调用 bind()[from ipconfig]
3) 我使用的公共端口是 8001,我必须在我的路由器设置中配置端口转发,以便它将所有数据包从我的全局 ip:port XXX.XXX.XXX.XXX:8001 转发到我的本地 ipv4 address:port192.168.xxx.xxx:8001
这种方法有效但效率不高,因为当我断开连接并重新连接时我的 IP 会发生变化。如果有人知道无需配置静态 IP 即可连接到服务器的更好解决方案,请分享。谢谢你