java伺服器tcp

㈠ 在java中實現TCP協議編程中怎麼傳

在Java中實現TCP協議編程

ServerSocket：編寫TCP網路服務程序,首先要用到java.net.ServerSocket類用以創建伺服器Socket

構造方法：

ServerSocket(intport)：創建綁定到特定埠的伺服器套接字

ServerSocket(intport,intbacklog)：利用指定的backlog(伺服器忙時保持連接請求的等待客戶數量),創建伺服器套接字並將其綁定到指定的本地埠號。

ServerSocket(intport,intbacklog,InetAddressbindAddr)：使用指定的埠、偵聽backlog和要綁定到的本地IP地址創建伺服器。

Socket：客戶端要與伺服器建立連接,必須先創建一個Socket對象

常用構造方法

Socket(Stringhost,intport)：創建一個流套接字並將其連接到指定主機上的指定埠號。

Socket(InetAddressaddress,intport)：創建一個流套接字並將其連接到指定IP地址的指定埠號。

伺服器端程序調用ServerSocket類中的accept()方法等待客戶端的連接請求，一旦accept()接收了客戶端連接請求，該方法返回一個與該客戶端建立了專線連接的Socket對象，不用程序去創建這個Socket對象。建立了連接的兩個Socket是以IO流的方式進行數據交換的，Java提供了Socket類中的getInputStream()返回Socket的輸入流對象，getOutputStream()返回Socket的輸出流對象。

TCP伺服器與TCP客戶端間的數據的接受圖示：

用TCP實現伺服器與客戶端的「聊天」：

實例代碼：

客戶端：

packagecom.hbsi.net;

importjava.net.Socket;

importjava.io.*;

publicclassTcpClient{

publicstaticvoidmain(String[]args)throwsException{

//1.建立tcp客戶端socket，要確定要連接的伺服器ip，port

Sockets=newSocket("192.168.49.87",9009);

//獲取鍵盤錄入

BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in));

//2.通過建立的socket，獲取輸出流對象

//數據輸出給伺服器端

OutputStreamout=s.getOutputStream();

BufferedWriterbwout=newBufferedWriter(newOutputStreamWriter(out));

//獲取伺服器端返回的數據

//讀取伺服器端發過來的信息InputStreamReader()

BufferedReaderbrin=newBufferedReader(newInputStreamReader(

s.getInputStream()));

Stringline=null;

while((line=br.readLine())!=null){

if(line.equals("over"))

break;

bwout.write(line);

bwout.newLine();

bwout.flush();

Stringstr=brin.readLine();

System.out.println("server:"+str);

}

br.close();

s.close();

}

}

伺服器端：

packagecom.hbsi.net;

importjava.io.BufferedReader;

importjava.io.BufferedWriter;

importjava.io.InputStream;

importjava.io.InputStreamReader;

importjava.io.OutputStreamWriter;

importjava.net.ServerSocket;

importjava.net.Socket;

publicclassTcpServer{

publicstaticvoidmain(String[]args)throwsException{

//1.建立伺服器socket

ServerSocketss=newServerSocket(9009);

//2.調用accept()

Sockets=ss.accept();

System.out.println(s.getInetAddress().getHostAddress()

+"...connection");

//讀取客戶的信息的輸入流

InputStreamin=s.getInputStream();

BufferedReaderbrin=newBufferedReader(newInputStreamReader(in));

//向客戶端發送信息輸出流，服務端向客戶端返回信息OutputStreamWriter()

BufferedWriterbrout=newBufferedWriter(newOutputStreamWriter(

s.getOutputStream())); Stringline=null;

while((line=brin.readLine())!=null){

System.out.println("client:"+line);

brout.write(line.toUpperCase());//伺服器端收到信息後，將信息轉為大寫返回給客戶端toUpperCase()

brout.newLine();

brout.flush();

}

s.close();

ss.close();

}

}

㈡ java如何通過tcp向指定的IP發送指令並獲得返回的包

以下是一個展示java使用tcp通訊的簡單例子，包括伺服器和客戶端代碼：

/**
*TCPServer
*/
import java.io.*;
import java.net.*;
class TCPServer{
public static void main(String[] args)throws IOException{
ServerSocket listen = new ServerSocket(5050);

Socket server = listen.accept();
InputStream in = server.getInputStream();
OutputStream out = server.getOutputStream();
char c = (char)in.read();
System.out.println("收到:" + c);
out.write('s');

out.close();
in.close();
server.close();
listen.close();
}
}

/**
*TCPClient
*/
import java.io.*;
import java.net.*;
class TCPClient{
public static void main(String[] args)throws IOException{
Socket client = new Socket("127.0.0.1" , 5050);
InputStream in = client.getInputStream();
OutputStream out = client.getOutputStream();

out.write('c');
char c = (char)in.read();
System.out.println("收到:" + c);
out.close();
in.close();
client.close();
}
}

㈢ JAVA的TCP伺服器搭建

請自行參考TCP/udp連接基礎解釋，然後根據自身問題進行排查。

㈣ 用java做一個TCP伺服器怎麼樣

想要用java做一個TCP伺服器，就可以使用java網路編程中的java Socket！
伺服器的socket是ServerSocket這個類，他的構造方法是：
ServerSocket ss=new ServerSocket(9999);//在埠9999監聽
ss.accpect();//靜靜等待客戶端連接！

㈤ java如何通過tcp發送指令

以下是一個展示java使用tcp通訊的簡單例子，包括伺服器和客戶端代碼：

/**
*TCPServer
*/
import java.io.*;
import java.net.*;
class TCPServer{
public static void main(String[] args)throws IOException{
ServerSocket listen = new ServerSocket(5050);

Socket server = listen.accept();
InputStream in = server.getInputStream();
OutputStream out = server.getOutputStream();
char c = (char)in.read();
System.out.println("收到:" + c);
out.write('s');

out.close();
in.close();
server.close();
listen.close();
}
}

/**
*TCPClient
*/
import java.io.*;
import java.net.*;
class TCPClient{
public static void main(String[] args)throws IOException{
Socket client = new Socket("127.0.0.1" , 5050);
InputStream in = client.getInputStream();
OutputStream out = client.getOutputStream();

out.write('c');
char c = (char)in.read();
System.out.println("收到:" + c);
out.close();
in.close();
client.close();
}
}

㈥ 怎麼用java寫一個針對各種不同請求的TCP服務端

伺服器監聽埠 做個無限循環 接到一個連接就創建一個通道線程，並將通道線程存儲到一個list集合中

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/*
* 4.用socket通訊寫出多個客戶端和一個伺服器端的通訊，
* 要求客戶發送數據後能夠回顯相同的數據（回顯功能）（實用TCP方式）。
*/
public class Test4Server {

// 主入口
public static void main(String[] args) throws IOException {
scoketServer();
}

// 開啟的tcp8888監聽埠
public static void scoketServer() throws IOException {
ServerSocket server = new ServerSocket(8888);
while (true) {
// 未連通前線程阻塞，連通後開啟一個socket通道線程後繼續監聽8888埠
Socket socket = server.accept();
System.out.println(socket.getInetAddress().getHostAddress()
+ "連接進入");
new SocketThread(socket).start();
}
}

}

// 一個伺服器埠中監聽多個客服端通道線程
class SocketThread extends Thread {
// 所有通道寫入流的集合
private static List<PrintWriter> list =new ArrayList<PrintWriter>();

private BufferedReader bufferedReader;
private PrintWriter printWriter;

public SocketThread(Socket socket) throws IOException {
this.bufferedReader = new BufferedReader(new InputStreamReader(socket
.getInputStream()));
this.printWriter = new PrintWriter(socket.getOutputStream());
list.add(printWriter);
}

@Override
public void run() {
String string = null;
while (true) {
try {
// 伺服器在通道中讀到的信息回顯給客服端
string = bufferedReader.readLine();
System.out.println("客服端信息：" + string);
for(PrintWriter printWriter:list ){
printWriter.write("伺服器回顯：" + string + "\r\n");
printWriter.flush();
}
} catch (IOException e) {

}
}

}
}

客服端代碼 可以用在區域網中用多台來連接測試

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class Test4Client {
public static Object obj = new Object();

// 客服端的主入口
public static void main(String[] args) throws IOException {
socketClient();
}

// 與伺服器連通地址本機（127.0.0.1），區域網中其他機器是（伺服器在區域網中的ip地址） 埠都是8888
public static void socketClient() throws IOException {
Socket socket = new Socket("127.0.0.1", 8888);
if (socket.isConnected()) {
// 如果連接成功了就開啟寫和讀的進程
new writer(socket).start();
new read(socket).start();
} else {
System.out.println("伺服器未開啟");
}
}
}

// 寫入到通道的線程
class writer extends Thread {
@SuppressWarnings("unused")
private Socket socket;
private PrintWriter printWriter;
private Scanner scanner = new Scanner(System.in);
private String str = null;

public writer(Socket socket) throws IOException {
this.socket = socket;
this.printWriter = new PrintWriter(socket.getOutputStream());

}

@Override
public void run() {
scanner.useDelimiter("\r\n");

while (true) {
System.out.print("請輸入信息：");
// 產生掃描器的線程阻塞
str = scanner.next();
System.out.println("我說："+str);
printWriter.write(str + "\r\n");
printWriter.flush();
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}

// 從通道中讀取的線程
class read extends Thread {
private Socket socket;
private BufferedReader bufferedReader;
private String str = null;

public read(Socket socket) throws IOException {
this.socket = socket;
this.bufferedReader = new BufferedReader(new InputStreamReader(socket
.getInputStream()));
}

@Override
public void run() {
while (true) {

try {
str = bufferedReader.readLine();
System.out.println(str);
} catch (IOException e) {
}
try {
Thread.sleep(200);
} catch (InterruptedException e) {

e.printStackTrace();
}
}
}
}

㈦ java中，用哪一個類來表示tcp協議的伺服器socket對象

服務端監聽：ServerSocket server=new ServerSocket(port);//port：綁定的埠號
Socket client=server.accept();//監聽埠，一旦取得連接則獲得客戶端的socket連接對象client

客戶端： Socket s=new Socket(ip,port);//要連接的伺服器的ip以及埠號

如果正常連接上之後，socket的對象可以獲得InputStream和OutputStreame，然後就可以進行通信了

完成通信之後，執行socket對象的close（）方法關閉連接，完成一次完整的socket連接

㈧ java的TCP和HTTP的區別和聯系是什麼

TCP是傳輸層協議，定義數據傳輸和連接方式的規范。握手過程中傳送的包里不包含數據，三次握手完畢後，客戶端與伺服器才正式開始傳送數據。

HTTP 超文本傳送協議(Hypertext Transfer Protocol )是應用層協議，定義的是傳輸數據的內容的規范。

HTTP協議中的數據是利用TCP協議傳輸的，特點是客戶端發送的每次請求都需要伺服器回送響應，它是TCP協議族中的一種，默認使用 TCP 80埠。

好比網路是路，TCP是跑在路上的車，HTTP是車上的人。每個網站內容不一樣，就像車上的每個人有不同的故事一樣。

㈨ 想用JAVA做一個伺服器，請問怎麼利用TCP和線程，實現多個客戶端同時在線，能與伺服器進行交互

伺服器監聽埠 做個無限循環 接到一個連接就創建一個通道線程，並將通道線程存儲到一個list集合中

importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.io.PrintWriter;
importjava.net.ServerSocket;
importjava.net.Socket;
importjava.text.SimpleDateFormat;
importjava.util.ArrayList;
importjava.util.Date;
importjava.util.List;

/*
*4.用socket通訊寫出多個客戶端和一個伺服器端的通訊，
*要求客戶發送數據後能夠回顯相同的數據（回顯功能）（實用TCP方式）。
*/
publicclassTest4Server{

	
	
	//主入口
	publicstaticvoidmain(String[]args)throwsIOException{
		scoketServer();
	}

	//開啟的tcp8888監聽埠
	publicstaticvoidscoketServer()throwsIOException{
		ServerSocketserver=newServerSocket(8888);
		while(true){
			//未連通前線程阻塞，連通後開啟一個socket通道線程後繼續監聽8888埠
			Socketsocket=server.accept();
			System.out.println(socket.getInetAddress().getHostAddress()
					+"連接進入");
			newSocketThread(socket).start();
		}
	}
	
	

}

//一個伺服器埠中監聽多個客服端通道線程
{
//所有通道寫入流的集合
	privatestaticList<PrintWriter>list=newArrayList<PrintWriter>();
	
	;
	privatePrintWriterprintWriter;

	publicSocketThread(Socketsocket)throwsIOException{
		this.bufferedReader=newBufferedReader(newInputStreamReader(socket
				.getInputStream()));
		this.printWriter=newPrintWriter(socket.getOutputStream());
		list.add(printWriter);
	}

	@Override
	publicvoidrun(){
		Stringstring=null;
		while(true){
			try{
				//伺服器在通道中讀到的信息回顯給客服端
				string=bufferedReader.readLine();
				System.out.println("客服端信息："+string);
				for(PrintWriterprintWriter:list){
					printWriter.write("伺服器回顯："+string+"
");
					printWriter.flush();
				}
			}catch(IOExceptione){

			}
		}

	}
}

客服端代碼 可以用在區域網中用多台來連接測試

importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.io.PrintWriter;
importjava.net.Socket;
importjava.util.Scanner;

publicclassTest4Client{
	publicstaticObjectobj=newObject();

	//客服端的主入口
	publicstaticvoidmain(String[]args)throwsIOException{
		socketClient();
	}

	//與伺服器連通地址本機（127.0.0.1），區域網中其他機器是（伺服器在區域網中的ip地址）埠都是8888
	publicstaticvoidsocketClient()throwsIOException{
		Socketsocket=newSocket("127.0.0.1",8888);
		if(socket.isConnected()){
			//如果連接成功了就開啟寫和讀的進程
			newwriter(socket).start();
			newread(socket).start();
		}else{
			System.out.println("伺服器未開啟");
		}
	}
}

//寫入到通道的線程
classwriterextendsThread{
	@SuppressWarnings("unused")
	privateSocketsocket;
	privatePrintWriterprintWriter;
	privateScannerscanner=newScanner(System.in);
	privateStringstr=null;

	publicwriter(Socketsocket)throwsIOException{
		this.socket=socket;
		this.printWriter=newPrintWriter(socket.getOutputStream());

	}

	@Override
	publicvoidrun(){
		scanner.useDelimiter("
");

		while(true){
				System.out.print("請輸入信息：");
				//產生掃描器的線程阻塞
				str=scanner.next();
				System.out.println("我說："+str);
				printWriter.write(str+"
");
				printWriter.flush();
			try{
				Thread.sleep(200);
			}catch(InterruptedExceptione){
				e.printStackTrace();
			}
		}
	}
}

//從通道中讀取的線程
classreadextendsThread{
	privateSocketsocket;
	;
	privateStringstr=null;

	publicread(Socketsocket)throwsIOException{
		this.socket=socket;
		this.bufferedReader=newBufferedReader(newInputStreamReader(socket
				.getInputStream()));
	}

	@Override
	publicvoidrun(){
		while(true){

				try{
					str=bufferedReader.readLine();
					System.out.println(str);
				}catch(IOExceptione){
				}
			try{
				Thread.sleep(200);
			}catch(InterruptedExceptione){
			
				e.printStackTrace();
			}
		}
	}
}