java基于tcp的代碼 Java TCP

java如何通過tcp發(fā)送指令

以下是一個(gè)展示java使用tcp通訊的簡單例子，包括服務(wù)器和客戶端代碼：

創(chuàng)新互聯(lián)建站憑借在網(wǎng)站建設(shè)、網(wǎng)站推廣領(lǐng)域領(lǐng)先的技術(shù)能力和多年的行業(yè)經(jīng)驗(yàn)，為客戶提供超值的營銷型網(wǎng)站建設(shè)服務(wù)，我們始終認(rèn)為：好的營銷型網(wǎng)站就是好的業(yè)務(wù)員。我們已成功為企業(yè)單位、個(gè)人等客戶提供了成都做網(wǎng)站、成都網(wǎng)站建設(shè)服務(wù)，以良好的商業(yè)信譽(yù)，完善的服務(wù)及深厚的技術(shù)力量處于同行領(lǐng)先地位。

/**

*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/IP網(wǎng)絡(luò)通信服務(wù)器客戶端，實(shí)現(xiàn)雙方信息交互。

package?com.weixin.test;

import?java.io.IOException;

import?java.io.InputStream;

import?java.io.OutputStream;

import?java.net.InetAddress;

import?java.net.ServerSocket;

import?java.net.Socket;

import?org.junit.Test;

public?class?ScoketTest?{

@Test

public?void?client()?throws?Exception{

InetAddress?i=InetAddress.getByName("127.0.0.1");

Socket?s=new?Socket(i,?9000);

OutputStream?outputStream?=?s.getOutputStream();

outputStream.write("服務(wù)端你好,我是客戶端哦!".getBytes());

s.shutdownOutput();

InputStream?inputStream=s.getInputStream();

int?length=0;

byte[]?bytes=new?byte[1024];

while?((length=inputStream.read(bytes))!=-1)?{

System.err.println(new?String(bytes,0,length));

}

inputStream.close();

outputStream.close();

s.close();

}

@Test

public?void?server()?throws?Exception{

ServerSocket?serverSocket=new?ServerSocket(9000);

Socket?socket?=?serverSocket.accept();

InputStream?inputStream?=?socket.getInputStream();

OutputStream?outputStream?=?socket.getOutputStream();

int?length=0;

byte[]?bytes=new?byte[1024];

while?((length=inputStream.read(bytes))!=-1)?{

System.err.println(new?String(bytes,?0,length));

}

outputStream.write("客戶端你好，本王已收到!".getBytes());

outputStream.close();

inputStream.close();

socket.close();

serverSocket.close();

}

}

關(guān)于java編程。設(shè)計(jì)一個(gè)基于TCP/IP協(xié)議的網(wǎng)絡(luò)程序，實(shí)現(xiàn)如下功能：

寫好了，有什么問題請追問。

客戶端：

import java.net.*;

import java.io.*;

public class TestSocketClient {

public static void main(String[] args) {

try {

Socket socket = new Socket("127.0.0.1", 5566);

System.out.println("請輸入計(jì)算式：");

BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

String s1 = br.readLine();

DataOutputStream dos = new DataOutputStream(socket.getOutputStream());

DataInputStream dis = new DataInputStream(socket.getInputStream());

dos.writeUTF(s1);

dos.flush();

double s = dis.readDouble();

System.out.println("計(jì)算結(jié)果：" + s);

dis.close();

dos.close();

socket.close();

} catch (IOException e) {

e.printStackTrace();

System.out.println("連接出錯");

System.exit(-1);

}

}

}

服務(wù)器端：

import java.net.*;

import java.io.*;

public class TestSocketServer {

public static void main(String[] args) {

try {

ServerSocket ss = new ServerSocket(5566);

Socket socket = ss.accept();

DataOutputStream dos = new DataOutputStream(socket.getOutputStream());

DataInputStream dis = new DataInputStream(socket.getInputStream());

String s = null;

if ((s = dis.readUTF()) != null) {

System.out.println("接收到的算式：" + s);

double result = 0;

String[] sarr1 = s.split("[\\+\\-\\*\\/]");

double a = Double.parseDouble(sarr1[0].trim());

double b = Double.parseDouble(sarr1[1].trim());

String[] sarr2 = s.split("^(-?\\d+)(\\.\\d+)?");

char c = sarr2[1].trim().charAt(0);

switch (c) {

case '+':

result = a + b;

break;

case '-':

result = a - b;

break;

case '*':

result = a * b;

break;

case '/':

result = a / b;

break;

default:

break;

}

dos.writeDouble(result);

dos.flush();

}

dis.close();

dos.close();

socket.close();

} catch (IOException e) {

e.printStackTrace();

System.exit(-1);

}

}

}

用java編寫一個(gè)能進(jìn)行簡單TCP/IP通信的C/S程序

import java.net.ServerSocket;

import java.net.Socket;

public class TcpServer

{

public static void main(String[] args) throws Exception

{

// 創(chuàng)建服務(wù)器端的socket對象

ServerSocket ss = new ServerSocket(5000);

// 監(jiān)聽連接

Socket socket = ss.accept();

// 直到連接建立好之后代碼才會往下執(zhí)行

System.out.println("Connected Successfully!");

}

}

import java.net.Socket;

public class TcpClient

{

public static void main(String[] args) throws Exception

{

Socket socket = new Socket("127.0.0.1", 5000);

}

}

JAVA Tcp 通訊代碼問題

localhost是指你本機(jī)，它可以改成127.0.0.1，如果跟其他機(jī)器通訊就改成另一臺機(jī)器的ip地址。8800是指通訊端口；

你把OS里的O理解為output，IS里的I理解為input。OS是輸出端，輸出端把數(shù)據(jù)放到BufferedReader，BufferedReader通過端口傳輸?shù)絀S后，再讀取。

求 基于java的Modbus/TCP協(xié)議 源代碼

public static void TestModbus() throws Exception{

IpParameters params = new IpParameters();

params.setHost("localhost");//地址

params.setPort(502);//端口

ModbusFactory factory = new ModbusFactory();

ModbusMaster master = factory.createTcpMaster(params, true);

// 初始化

try {

master.init();

readHoldingRegistersTest(master,1,0,3);

} catch (ModbusInitException e) {

e.printStackTrace();

} finally {

master.destroy();

}

}

public static void main(String[] args) {

try {

TestModbus();

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}

}

private static void readHoldingRegistersTest(ModbusMaster master,

int slaveId, int start, int len) {

try {

// ReadInputRegistersRequest request = new ReadInputRegistersRequest(

// slaveId, start, len);

// ReadInputRegistersResponse response = (ReadInputRegistersResponse) master

// .send(request);

ReadHoldingRegistersRequest request = new ReadHoldingRegistersRequest(

slaveId, start, len);

ReadHoldingRegistersResponse response = (ReadHoldingRegistersResponse) master

.send(request);

if (response.isException()) {

System.out.println("Exception response: message="

+ response.getExceptionMessage());

} else {

ByteQueue byteQueue= new ByteQueue(12);

response.write(byteQueue);

System.out.println(byteQueue);

System.out.println(Arrays.toString(response.getShortData()));

short[] list = response.getShortData();

for(int i = 0; i list.length; i++){

System.out.print(list[i] + " ");

}

}

} catch (ModbusTransportException e) {

e.printStackTrace();

}

}

文章名稱：java基于tcp的代碼 Java TCP
文章位置：http://www.jbt999.com/article8/hppeip.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App開發(fā)、用戶體驗(yàn)、域名注冊、網(wǎng)站導(dǎo)航、云服務(wù)器、品牌網(wǎng)站設(shè)計(jì)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：[email protected]。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)