新增备案网站负责人/抖音优化是什么意思

新增备案网站负责人,抖音优化是什么意思,中国建设银行网站色彩,一台vps两个wordpress网站文章目录 前言一、代码层次二、详细代码1. eth_scapy_sd.py2、eth_scapy_someip.py3、network_define.py4、packet_define.py5、unpack_define.py6、someip_controller.py 前言 1、需要pip安装scapy库 2、需要修改根据实际情况配置network_define.py 3、执行someip_controller…

文章目录

  • 前言
  • 一、代码层次
  • 二、详细代码
    • 1. eth_scapy_sd.py
    • 2、eth_scapy_someip.py
    • 3、network_define.py
    • 4、packet_define.py
    • 5、unpack_define.py
    • 6、someip_controller.py


前言

1、需要pip安装scapy库
2、需要修改根据实际情况配置network_define.py
3、执行someip_controller.py运行本案例
4、本文参考github: eth-scapy-someip

注:最近没啥时间写文章,有兴趣自己研究下<~~>


一、代码层次

someip/
└── module/├── eth_scapy_sd.py          # SOME/IP SD服务发现结构体定义├── eth_scapy_someip.py      # SOME/IP标准结构体定义├── network_define.py        # 网络配置(IP/端口/多播组)├── packet_define.py         # 协议字段定义(Offer/Subscribe/ACK)├── unpack_define.py         # 接收报文解析器└── someip_controller.py     # 主控制逻辑(订阅/OFFER/ACK流程管理)

二、详细代码

1. eth_scapy_sd.py

import ctypes
import collectionsfrom eth_scapy_someip import SOMEIPfrom scapy.fields import *
from scapy.packet import *
from scapy.layers.inet6 import IP6Fieldclass _SDPacketBase(Packet):"""base class to be used among all SD Packet definitions."""# use this dictionary to set default values for desired fields (mostly on subclasses# where not all fields are defined locally)# - key : field_name, value : desired value# - it will be used from 'init_fields' function, upon packet initialization## example : _defaults = {'field_1_name':field_1_value,'field_2_name':field_2_value}_defaults = {}def _set_defaults(self):"""goes through '_defaults' dict setting field default values (for those that have been defined)."""for key in self._defaults.keys():try:self.get_field(key)except KeyError:passelse:self.setfieldval(key, self._defaults[key])def init_fields(self):"""perform initialization of packet fields with desired values.NOTE : this funtion will only be called *once* upon class (or subclass) construction"""Packet.init_fields(self)self._set_defaults()# SD ENTRY
#  - Service
#  - EventGroup
class _SDEntry(_SDPacketBase):"""Base class for SDEntry_* packages."""TYPE_FMT = ">B"TYPE_PAYLOAD_I = 0# ENTRY TYPES : SERVICETYPE_SRV_FINDSERVICE = 0x00TYPE_SRV_OFFERSERVICE = 0x01TYPE_SRV = (TYPE_SRV_FINDSERVICE, TYPE_SRV_OFFERSERVICE)# ENTRY TYPES : EVENGROUPTYPE_EVTGRP_SUBSCRIBE = 0x06TYPE_EVTGRP_SUBSCRIBE_ACK = 0x07TYPE_EVTGRP = (TYPE_EVTGRP_SUBSCRIBE, TYPE_EVTGRP_SUBSCRIBE_ACK)# overall len (UT usage)OVERALL_LEN = 16# 定义Entries Array结构体fields_desc = [ByteField("type", 0),ByteField("index_1", 0),ByteField("index_2", 0),BitField("n_opt_1", 0, 4),BitField("n_opt_2", 0, 4),ShortField("srv_id", 0),ShortField("inst_id", 0),ByteField("major_ver", 0),X3BytesField("ttl", 0),]def guess_payload_class(self, payload):"""decode SDEntry depending on its type."""pl_type = struct.unpack(_SDEntry.TYPE_FMT,payload[_SDEntry.TYPE_PAYLOAD_I : _SDEntry.TYPE_PAYLOAD_I + 1],)[0]if pl_type in _SDEntry.TYPE_SRV:return SDEntry_Serviceelif pl_type in _SDEntry.TYPE_EVTGRP:return SDEntry_EventGroupclass SDEntry_Service(_SDEntry):"""Service Entry."""_defaults = {"type": _SDEntry.TYPE_SRV_FINDSERVICE}name = "Service Entry"fields_desc = [_SDEntry, IntField("minor_ver", 0)]class SDEntry_EventGroup(_SDEntry):"""EventGroup Entry."""_defaults = {"type": _SDEntry.TYPE_EVTGRP_SUBSCRIBE}name = "Eventgroup Entry"fields_desc = [_SDEntry,BitField("res", 0, 12),BitField("cnt", 0, 4),ShortField("eventgroup_id", 0),]# SD Option
#  - Configuration
#  - LoadBalancing
#  - IPv4 EndPoint
#  - IPv6 EndPoint
#  - IPv4 MultiCast
#  - IPv6 MultiCast
#  - IPv4 EndPoint
#  - IPv6 EndPoint
class _SDOption(_SDPacketBase):"""Base class for SDOption_* packages."""TYPE_FMT = ">B"TYPE_PAYLOAD_I = 2CFG_TYPE = 0x01CFG_OVERALL_LEN = (4  # overall length of CFG SDOption,empty 'cfg_str' (to be used from UT))LOADBALANCE_TYPE = 0x02LOADBALANCE_LEN = 0x05LOADBALANCE_OVERALL_LEN = 8  # overall length of LB SDOption (to be used from UT)IP4_ENDPOINT_TYPE = 0x04IP4_ENDPOINT_LEN = 0x0009IP4_MCAST_TYPE = 0x14IP4_MCAST_LEN = 0x0009IP4_SDENDPOINT_TYPE = 0x24IP4_SDENDPOINT_LEN = 0x0009IP4_OVERALL_LEN = 12  # overall length of IP4 SDOption (to be used from UT)IP6_ENDPOINT_TYPE = 0x06IP6_ENDPOINT_LEN = 0x0015IP6_MCAST_TYPE = 0x16IP6_MCAST_LEN = 0x0015IP6_SDENDPOINT_TYPE = 0x26IP6_SDENDPOINT_LEN = 0x0015IP6_OVERALL_LEN = 24  # overall length of IP6 SDOption (to be used from UT)def guess_payload_class(self, payload):"""decode SDOption depending on its type."""pl_type = struct.unpack(_SDOption.TYPE_FMT,payload[_SDOption.TYPE_PAYLOAD_I : _SDOption.TYPE_PAYLOAD_I + 1],)[0]if pl_type == _SDOption.CFG_TYPE:return SDOption_Configelif pl_type == self.LOADBALANCE_TYPE:return SDOption_LoadBalanceelif pl_type == self.IP4_ENDPOINT_TYPE:return SDOption_IP4_EndPointelif pl_type == self.IP4_MCAST_TYPE:return SDOption_IP4_Multicastelif pl_type == self.IP4_SDENDPOINT_TYPE:return SDOption_IP4_SD_EndPointelif pl_type == self.IP6_ENDPOINT_TYPE:return SDOption_IP6_EndPointelif pl_type == self.IP6_MCAST_TYPE:return SDOption_IP6_Multicastelif pl_type == self.IP6_SDENDPOINT_TYPE:return SDOption_IP6_SD_EndPointclass _SDOption_Header(_SDOption):fields_desc = [ShortField("len", None),ByteField("type", 0),ByteField("res_hdr", 0),]class _SDOption_Tail(_SDOption):fields_desc = [ByteField("res_tail", 0),ByteEnumField("l4_proto", 0x06, {0x06: "TCP", 0x11: "UDP"}),ShortField("port", 0),]class _SDOption_IP4(_SDOption):fields_desc = [_SDOption_Header, IPField("addr", "0.0.0.0"), _SDOption_Tail]class _SDOption_IP6(_SDOption):fields_desc = [_SDOption_Header,IP6Field("addr", "2001:cdba:0000:0000:0000:0000:3257:9652"),_SDOption_Tail,]class SDOption_Config(_SDOption):# offset to be added upon length calculation (corresponding to header's "Reserved" field)LEN_OFFSET = 0x01name = "Config Option"# default values specification_defaults = {"type": _SDOption.CFG_TYPE}# package fields definitonfields_desc = [_SDOption_Header, StrField("cfg_str", "")]def post_build(self, p, pay):# length computation excluding 16b_length and 8b_typel = self.lenif l is None:l = len(self.cfg_str) + self.LEN_OFFSETp = struct.pack("!H", l) + p[2:]return p + payclass SDOption_LoadBalance(_SDOption):name = "LoadBalance Option"# default values specification_defaults = {"type": _SDOption.LOADBALANCE_TYPE, "len": _SDOption.LOADBALANCE_LEN}# package fields definitonfields_desc = [_SDOption_Header, ShortField("priority", 0), ShortField("weight", 0)]# SDOPTIONS : IPv4-specific
class SDOption_IP4_EndPoint(_SDOption_IP4):name = "IP4 EndPoint Option"# default values specification_defaults = {"type": _SDOption.IP4_ENDPOINT_TYPE, "len": _SDOption.IP4_ENDPOINT_LEN}class SDOption_IP4_Multicast(_SDOption_IP4):name = "IP4 Multicast Option"# default values specification_defaults = {"type": _SDOption.IP4_MCAST_TYPE, "len": _SDOption.IP4_MCAST_LEN}class SDOption_IP4_SD_EndPoint(_SDOption_IP4):name = "IP4 SDEndPoint Option"# default values specification_defaults = {"type": _SDOption.IP4_SDENDPOINT_TYPE,"len": _SDOption.IP4_SDENDPOINT_LEN,}# SDOPTIONS : IPv6-specific
class SDOption_IP6_EndPoint(_SDOption_IP6):name = "IP6 EndPoint Option"# default values specification_defaults = {"type": _SDOption.IP6_ENDPOINT_TYPE, "len": _SDOption.IP6_ENDPOINT_LEN}class SDOption_IP6_Multicast(_SDOption_IP6):name = "IP6 Multicast Option"# default values specification_defaults = {"type": _SDOption.IP6_MCAST_TYPE, "len": _SDOption.IP6_MCAST_LEN}class SDOption_IP6_SD_EndPoint(_SDOption_IP6):name = "IP6 SDEndPoint Option"# default values specification_defaults = {"type": _SDOption.IP6_SDENDPOINT_TYPE,"len": _SDOption.IP6_SDENDPOINT_LEN,}#
# SD PACKAGE DEFINITION
#
class SD(_SDPacketBase):"""SD PacketNOTE :   when adding 'entries' or 'options', do not use list.append() method but create a new liste.g. :  p = SD()p.option_array = [SDOption_Config(),SDOption_IP6_EndPoint()]"""SOMEIP_MSGID_SRVID = 0xFFFFSOMEIP_MSGID_SUBID = 0x1SOMEIP_MSGID_EVENTID = 0x100SOMEIP_PROTO_VER = 0x01SOMEIP_IFACE_VER = 0x01SOMEIP_MSG_TYPE = SOMEIP.TYPE_NOTIFICATIONname = "SD"# Flags definition: {"name":(mask,offset)}_sdFlag = collections.namedtuple("Flag", "mask offset")FLAGSDEF = {"REBOOT": _sdFlag(mask=0x80, offset=7),  # ReBoot flag"UNICAST": _sdFlag(mask=0x40, offset=6),  # UniCast flag}fields_desc = [ByteField("flags", 0),X3BytesField("res", 0),FieldLenField(name="len_entry_array", default=None, length_of="entry_array", fmt="!I"),PacketListField(name="entry_array",default=None,pkt_cls=_SDEntry,length_from=lambda pkt: pkt.len_entry_array,),FieldLenField(name="len_option_array", default=None, length_of="option_array", fmt="!I"),PacketListField(name="option_array",default=None,pkt_cls=_SDOption,length_from=lambda pkt: pkt.len_option_array,),]def __init__(self, *args, **kwargs):super(SD, self).__init__(*args, **kwargs)self.explicit = 1def getFlag(self, name):"""get particular flag from bitfield."""name = name.upper()if name in self.FLAGSDEF:return (self.flags & self.FLAGSDEF[name].mask) >> self.FLAGSDEF[name].offsetelse:return Nonedef setFlag(self, name, value):"""Set particular flag on bitfield.:param str name : name of the flag to set (see SD.FLAGSDEF):param int value : either 0x1 or 0x0 (provided int will be ANDed with 0x01)"""name = name.upper()if name in self.FLAGSDEF:self.flags = (self.flags & ctypes.c_ubyte(~self.FLAGSDEF[name].mask).value) | (value & 0x01) << self.FLAGSDEF[name].offsetdef setEntryArray(self, entry_list):"""Add entries to entry_array.:param entry_list: list of entries to be added. Single entry object also accepted"""if isinstance(entry_list, list):self.entry_array = entry_listelse:self.entry_array = [entry_list]def setOptionArray(self, option_list):"""Add options to option_array.:param option_list: list of options to be added. Single option object also accepted"""if isinstance(option_list, list):self.option_array = option_listelse:self.option_array = [option_list]def getSomeip(self, stacked=False):"""return SD-initialized SOME/IP packet:param stacked: boolean. Either just SOME/IP packet or stacked over SD-self"""p = SOMEIP()p.msg_id.srv_id = SD.SOMEIP_MSGID_SRVIDp.msg_id.sub_id = SD.SOMEIP_MSGID_SUBIDp.msg_id.event_id = SD.SOMEIP_MSGID_EVENTIDp.proto_ver = SD.SOMEIP_PROTO_VERp.iface_ver = SD.SOMEIP_IFACE_VERp.msg_type = SD.SOMEIP_MSG_TYPEif stacked:return p / selfelse:return pdef get_someip_with_session_id(self,session_id, stacked=False):p = SOMEIP()p.msg_id.srv_id = SD.SOMEIP_MSGID_SRVIDp.msg_id.sub_id = SD.SOMEIP_MSGID_SUBIDp.msg_id.event_id = SD.SOMEIP_MSGID_EVENTIDp.proto_ver = SD.SOMEIP_PROTO_VERp.iface_ver = SD.SOMEIP_IFACE_VERp.msg_type = SD.SOMEIP_MSG_TYPEp.req_id.session_id = session_idif stacked:return p / selfelse:return p

2、eth_scapy_someip.py

from scapy.layers.inet import *
from scapy.fields import *
from scapy.packet import *"""SOMEIP PACKAGE DEFINITION"""class _SOMEIP_MessageId(Packet):"""MessageId subpacket."""name = 'MessageId'fields_desc = [ShortField('srv_id', 0),BitEnumField('sub_id', 0, 1, {0: 'METHOD_ID', 1: 'EVENT_ID'}),ConditionalField(BitField('method_id', 0, 15), lambda pkt: pkt.sub_id == 0),ConditionalField(BitField('event_id', 0, 15), lambda pkt: pkt.sub_id == 1)]def extract_padding(self, p):return '', pclass _SOMEIP_RequestId(Packet):""" RequestId subpacket."""name = 'RequestId'fields_desc = [ShortField('client_id', 0),ShortField('session_id', 0)]def extract_padding(self, p):return '', pclass SOMEIP(Packet):""" SOME/IP Packet."""# Default valuesPROTOCOL_VERSION = 0x01INTERFACE_VERSION = 0x01# Lenght offset (without payload)LEN_OFFSET = 0x08# SOME/IP TYPE VALUESTYPE_REQUEST = 0x00TYPE_REQUEST_NO_RET = 0x01TYPE_NOTIFICATION = 0x02TYPE_REQUEST_ACK = 0x40TYPE_REQUEST_NORET_ACK = 0x41TYPE_NOTIFICATION_ACK = 0x42TYPE_RESPONSE = 0x80TYPE_ERROR = 0x81TYPE_RESPONSE_ACK = 0xc0TYPE_ERROR_ACK = 0xc1# SOME/IP-TP TYPE VALUESTYPE_REQUEST_SEGMENT = 0x20TYPE_REQUEST_NO_RET_SEGMENT = 0x21TYPE_NOTIFICATION_SEGMENT = 0x22TYPE_REQUEST_ACK_SEGMENT = 0x60TYPE_REQUEST_NORET_ACK_SEGMENT = 0x61TYPE_NOTIFICATION_ACK_SEGMENT = 0x62TYPE_RESPONSE_SEGMENT = 0xa0TYPE_ERROR_SEGMENT = 0xa1TYPE_RESPONSE_ACK_SEGMENT = 0xe0TYPE_ERROR_ACK_SEGMENT = 0xe1SOMEIP_TP_TYPES = frozenset({TYPE_REQUEST_SEGMENT, TYPE_REQUEST_NO_RET_SEGMENT, TYPE_NOTIFICATION_SEGMENT,TYPE_REQUEST_ACK_SEGMENT, TYPE_REQUEST_NORET_ACK_SEGMENT,TYPE_NOTIFICATION_ACK_SEGMENT, TYPE_RESPONSE_SEGMENT, TYPE_ERROR_SEGMENT,TYPE_RESPONSE_ACK_SEGMENT, TYPE_ERROR_ACK_SEGMENT})SOMEIP_TP_TYPE_BIT_MASK = 0x20# SOME/IP RETURN CODESRET_E_OK = 0x00RET_E_NOT_OK = 0x01RET_E_UNKNOWN_SERVICE = 0x02RET_E_UNKNOWN_METHOD = 0x03RET_E_NOT_READY = 0x04RET_E_NOT_REACHABLE = 0x05RET_E_TIMEOUT = 0x06RET_E_WRONG_PROTOCOL_V = 0x07RET_E_WRONG_INTERFACE_V = 0x08RET_E_MALFORMED_MSG = 0x09RET_E_WRONG_MESSAGE_TYPE = 0x0a# SOME/IP-TP More Segments FlagSOMEIP_TP_LAST_SEGMENT = 0SOMEIP_TP_MORE_SEGMENTS = 1_OVERALL_LEN_NOPAYLOAD = 16  # UTname = 'SOME/IP'fields_desc = [PacketField('msg_id', _SOMEIP_MessageId(), _SOMEIP_MessageId),  # MessageIDIntField('len', None),  # LengthPacketField('req_id', _SOMEIP_RequestId(), _SOMEIP_RequestId),  # RequestIDByteField('proto_ver', PROTOCOL_VERSION),  # Protocol versionByteField('iface_ver', INTERFACE_VERSION),  # Interface versionByteEnumField('msg_type', TYPE_REQUEST, {  # -- Message type --TYPE_REQUEST: 'REQUEST',  # 0x00TYPE_REQUEST_NO_RET: 'REQUEST_NO_RETURN',  # 0x01TYPE_NOTIFICATION: 'NOTIFICATION',  # 0x02TYPE_REQUEST_ACK: 'REQUEST_ACK',  # 0x40TYPE_REQUEST_NORET_ACK: 'REQUEST_NO_RETURN_ACK',  # 0x41TYPE_NOTIFICATION_ACK: 'NOTIFICATION_ACK',  # 0x42TYPE_RESPONSE: 'RESPONSE',  # 0x80TYPE_ERROR: 'ERROR',  # 0x81TYPE_RESPONSE_ACK: 'RESPONSE_ACK',  # 0xc0TYPE_ERROR_ACK: 'ERROR_ACK',  # 0xc1}),ByteEnumField('retcode', 0, {  # -- Return code --RET_E_OK: 'E_OK',  # 0x00RET_E_NOT_OK: 'E_NOT_OK',  # 0x01RET_E_UNKNOWN_SERVICE: 'E_UNKNOWN_SERVICE',  # 0x02RET_E_UNKNOWN_METHOD: 'E_UNKNOWN_METHOD',  # 0x03RET_E_NOT_READY: 'E_NOT_READY',  # 0x04RET_E_NOT_REACHABLE: 'E_NOT_REACHABLE',  # 0x05RET_E_TIMEOUT: 'E_TIMEOUT',  # 0x06RET_E_WRONG_PROTOCOL_V: 'E_WRONG_PROTOCOL_VERSION',  # 0x07RET_E_WRONG_INTERFACE_V: 'E_WRONG_INTERFACE_VERSION',  # 0x08RET_E_MALFORMED_MSG: 'E_MALFORMED_MESSAGE',  # 0x09RET_E_WRONG_MESSAGE_TYPE: 'E_WRONG_MESSAGE_TYPE',  # 0x0a}),ConditionalField(BitField('offset', 0, 28), lambda pkt: pkt.msg_type in SOMEIP.SOMEIP_TP_TYPES),ConditionalField(BitField('reserved', 0, 3), lambda pkt: pkt.msg_type in SOMEIP.SOMEIP_TP_TYPES),ConditionalField(BitEnumField('more_segments', 0, 1, {SOMEIP_TP_LAST_SEGMENT: 'Last_Segment',SOMEIP_TP_MORE_SEGMENTS: 'More_Segments'}), lambda pkt: pkt.msg_type in SOMEIP.SOMEIP_TP_TYPES)]def post_build(self, p, pay):length = self.len# length computation : RequestID + PROTOVER_IFACEVER_TYPE_RETCODE + PAYLOADif length is None:length = self.LEN_OFFSET + len(pay)p = p[:4] + struct.pack('!I', length) + p[8:]return p + payfor i in range(15):bind_layers(UDP, SOMEIP, sport=30490 + i)bind_layers(TCP, SOMEIP, sport=30490 + i)

3、network_define.py

class EthParameter:# 广播sd_network_card = "eth0.62"sd_ip = "239.0.0.255"# 本机server_network_card = "Realtek PCIe GbE Family Controller #2"server_ip = "192.168.62.31"# 域控client_network_card = "eth0.62"client_ip = "192.168.62.11"sd_port = 30490producer_port = 30500consumer_prot = 30501

4、packet_define.py

import eth_scapy_sd as sdfrom network_define import EthParameterfrom scapy.layers.l2 import Ether
from scapy.layers.inet import IP, UDPclass SomeipPacker:def __init__(self):self.eth_para = EthParameter()self.sd_session_id = 1self.client_session_id = 1def update_sd_session_id(self):"""更新session_id,从0递增到65535"""self.sd_session_id += 1if self.sd_session_id >= 65535:self.sd_session_id = 0def update_client_session_id(self):self.client_session_id += 1if self.client_session_id >= 65535:self.client_session_id = 0# ===========================##          序列化             ## ===========================#def packet_subscribe(self, service_id: list, ttl: int):"""组事件订阅包"""subscribe_packager = sd.SD()subscribe_packager.setFlag("REBOOT", 1)subscribe_packager.setFlag("UNICAST", 1)subscribe_packager.len_entry_array = 16 * len(service_id)subscribe_packager.len_option_array = 24for i in service_id:subscribe_packager.entry_array.append(sd.SDEntry_EventGroup(type=sd.SDEntry_EventGroup.TYPE_EVTGRP_SUBSCRIBE,srv_id=i,inst_id=0x1,n_opt_1=2,major_ver=0x1,ttl=ttl,eventgroup_id=0x1,))subscribe_packager.option_array = [# UDP EndPointsd.SDOption_IP4_EndPoint(addr=self.eth_para.server_ip,l4_proto=0x11,port=self.eth_para.consumer_prot,),# TCP EndPointsd.SDOption_IP4_EndPoint(addr=self.eth_para.server_ip,l4_proto=0x06,port=self.eth_para.consumer_prot,),]print(subscribe_packager.show())subscribe_package = (Ether()/ IP(src=self.eth_para.server_ip, dst=self.eth_para.client_ip)/ UDP(sport=self.eth_para.sd_port, dport=self.eth_para.sd_port)/ subscribe_packager.get_someip_with_session_id(self.client_session_id, True))self.update_client_session_id()return subscribe_packagedef packet_subscribe_ack(self, service_id: list, ttl: int):"""组ack包"""ack_packager = sd.SD()ack_packager.setFlag("REBOOT", 1)ack_packager.setFlag("UNICAST", 1)ack_packager.len_entry_array = 16 * len(service_id)ack_packager.len_option_array = 0for i in service_id:ack_packager.entry_array.append(sd.SDEntry_EventGroup(type=sd.SDEntry_EventGroup.TYPE_EVTGRP_SUBSCRIBE_ACK,srv_id=i,inst_id=0x1,major_ver=0x1,ttl=ttl,eventgroup_id=0x1,))print(ack_packager.show())ack_package = (Ether()/ IP(src=self.eth_para.server_ip, dst=self.eth_para.client_ip)/ UDP(sport=self.eth_para.sd_port, dport=self.eth_para.sd_port)/ ack_packager.get_someip_with_session_id(self.client_session_id, True))self.update_client_session_id()return ack_packagedef packet_offer(self, service_id: list, ttl: int):"""组offer包"""offer_packager = sd.SD()offer_packager.setFlag("REBOOT", 1)offer_packager.setFlag("UNICAST", 1)offer_packager.len_entry_array = 16 * len(service_id)offer_packager.len_option_array = 12for i in service_id:offer_packager.entry_array.append(sd.SDEntry_Service(type=sd.SDEntry_Service.TYPE_SRV_OFFERSERVICE,srv_id=i,inst_id=0x1,n_opt_1=1,major_ver=0x1,minor_ver=0x01,ttl=ttl,))offer_packager.option_array = [sd.SDOption_IP4_EndPoint(addr=self.eth_para.server_ip,l4_proto=0x11,port=self.eth_para.producer_port,)]print(offer_packager.show())offer_package = (Ether()/ IP(src=self.eth_para.server_ip, dst=self.eth_para.sd_ip)/ UDP(sport=self.eth_para.sd_port, dport=self.eth_para.sd_port)/ offer_packager.get_someip_with_session_id(self.sd_session_id, True))self.update_sd_session_id()return offer_package

5、unpack_define.py

from scapy.packet import Raw
from typing import Optional
from dataclasses import dataclass@dataclass
class SomeIPHeaderParams:service_id: intevent_id: int      # 或 event_id,取决于消息类型client_id: intsession_id: intmsg_type: intreturn_code: intlength: intprotocol_version: intinterface_version: intclass SomeipUnpacker:@staticmethoddef get_someip_header_params(receive_packet) -> Optional[SomeIPHeaderParams]:"""获取someip header"""try:if receive_packet.haslayer("SOME/IP"):someip_layer = receive_packet["SOME/IP"]# 获取someip header值service_id = someip_layer.msg_id.srv_idsub_id = someip_layer.msg_id.sub_idevent_id = sub_id << 15 | someip_layer.msg_id.event_id# 提取请求 ID(Client ID 和 Session ID)req_id = someip_layer.req_idclient_id = req_id.client_idsession_id = req_id.session_id# 构造头部对象return SomeIPHeaderParams(service_id=service_id,event_id=event_id,client_id=client_id,session_id=session_id,msg_type=someip_layer.msg_type,return_code=someip_layer.retcode,length=someip_layer.len,protocol_version=someip_layer.proto_ver,interface_version=someip_layer.iface_ver,)except (AttributeError, ValueError) as e:print(f"解析失败: {e}")return None@staticmethoddef get_someip_payload(receive_packet):"""获取someip payload"""try:someip_payload = receive_packet[Raw].load# print(f"someip_payload: {someip_payload}")return someip_payloadexcept AttributeError:return None

6、someip_controller.py

import threading
import socket
import time
from module.packet_define import *
from module.unpack_define import *from scapy.sendrecv import sendp, sniffclass SomeipController(threading.Thread):def __init__(self, someip_packer: SomeipPacker, someip_unpacker: SomeipUnpacker):super().__init__()self.someip_packer = someip_packerself.someip_unpacker = someip_unpackerself._stop_event = threading.Event()self.running = Truedef run(self):# 创建并发送offer以及订阅ack报文(这里忽略订阅,直接回复订阅ack)service_id_list = [0xA994, 0xA995]_offer = self.someip_packer.packet_offer(service_id=service_id_list,ttl=3)_offer_sender = SomeipSendLoop(network_card=EthParameter.sd_network_card,someip_packer=_offer,cycle_time_ms=2000,)# 回复订阅ACK_subscribe_ack = self.someip_packer.packet_subscribe_ack(service_id=service_id_list,ttl=3)_subscribe_ack_sender = SomeipSendLoop(network_card=EthParameter.sd_network_card,someip_packer=_subscribe_ack,cycle_time_ms=2000,)# 创建并发送订阅报文(订阅0xAB03, 0xAB04)_subscribe = self.someip_packer.packet_subscribe(service_id=[0xAB03,0xAB04], ttl=0x03)_subscribe_sender = SomeipSendLoop(network_card=EthParameter.server_network_card,someip_packer=_subscribe,cycle_time_ms=2000,)# 启动接收模块someip_receiver = SomeIpReceiver(EthParameter.server_network_card)while self._stop_event:time.sleep(0.01)def stop(self):self.running = False  # 设置标志位为 False 来停止self._stop_event.set()self.join()class SomeipSendLoop(threading.Thread):def __init__(self, network_card, someip_packer, cycle_time_ms):super().__init__()self.network_card = network_cardself.someip_packer = someip_packerself.cycle_time_ms = cycle_time_msself._stop_event = threading.Event()self.start()def run(self):while self._stop_event:if self.someip_packer:sendp(self.someip_packer, iface=self.network_card, verbose=0)time.sleep(self.cycle_time_ms / 1000)def stop(self):self._stop_event.set()self.join()class SomeIpReceiver(threading.Thread):def __init__(self,eth_desc: str,someip_unpacker):super().__init__()self._eth_desc = eth_descself._unpacker = someip_unpackerself._terminated = Falseself._stop_event =threading.Event()self.start()def packet_callback(self, packet):if packet:header_param = self._unpacker.get_someip_header_params(receive_packet=packet)print(f"msg_type: {header_param.msg_type}")def run(self):sniff(iface=self._eth_desc,prn=self.packet_callback,filter="udp",stop_filter=lambda x: self._terminated,)while self._stop_event:# 保持sniff嗅探不中断time.sleep(1)def stop(self):self._terminated = Trueself._stop_event.set()self.join()# 如果协议有TCP
class SomeipTcpSocket(threading.Thread):def __init__(self):super().__init__()self.tcp_sock: socket = Noneself._stop_event = threading.Event()self.start()def create_tcp_socket(self):self.tcp_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)self.tcp_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)self.tcp_sock.bind((EthParameter.icc_android_ip, EthParameter.consumer_prot))self.tcp_sock.connect((EthParameter.adcc_ip, EthParameter.producer_port))def run(self):self.create_tcp_socket()while self._stop_event:# 保持TCP通信time.sleep(1)def stop(self):self._stop_event.set()self.join()if __name__ == "__main__":s_socket = SomeipTcpSocket()s_packer = SomeipPacker()s_unpacker = SomeipUnpacker()sim_server = SomeipController(s_packer,s_unpacker)sim_server.start()

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/73517.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【Linux内核系列】:文件系统收尾以及软硬链接详解

&#x1f525; 本文专栏&#xff1a;Linux &#x1f338;作者主页&#xff1a;努力努力再努力wz &#x1f4aa; 今日博客励志语录&#xff1a; 世界上只有一种个人英雄主义&#xff0c;那么就是面对生活的种种失败却依然热爱着生活 内容回顾 那么在之前的学习中&#xff0c;我们…

最新版Chrome浏览器加载ActiveX控件技术--allWebPlugin中间件一键部署浏览器扩展

allWebPlugin简介 allWebPlugin中间件是一款为用户提供安全、可靠、便捷的浏览器插件服务的中间件产品&#xff0c;致力于将浏览器插件重新应用到所有浏览器。它将现有ActiveX控件直接嵌入浏览器&#xff0c;实现插件加载、界面显示、接口调用、事件回调等。支持Chrome、Firefo…

基于SpringBoot和MybatisPlus实现通用Controller

基于SpringBoot和MybatisPlus实现通用Controller&#xff0c;只需要创建实体类和mapper接口&#xff0c;单表增删改查接口就已经实现&#xff0c;提升开发效率 1.定义通用controller package com.xian.controller;import cn.hutool.core.map.MapUtil; import com.baomidou.my…

Axure大屏可视化原型模板及素材:数据可视化的高效解决方案

数据可视化已成为企业决策、运营分析、市场洞察的重要工具。数据可视化大屏&#xff0c;作为数据展示和交互的直观平台&#xff0c;能够实时呈现关键数据&#xff0c;帮助企业快速做出决策。Axure作为原型设计领域的领先工具&#xff0c;以其丰富的组件库、强大的交互设计能力和…

YOLOE:实时查看任何事物

摘要 https://arxiv.org/pdf/2503.07465v1 目标检测和分割在计算机视觉应用中得到了广泛应用&#xff0c;然而&#xff0c;尽管YOLO系列等传统模型高效且准确&#xff0c;但它们受限于预定义的类别&#xff0c;阻碍了在开放场景中的适应性。最近的开放集方法利用文本提示、视觉…

這是我第一次寫關於aapenal服務器管理控制面板的文章

首先我們來認識一下服務器管理面板的所有功能  網站管理功能&#xff1a; 支持創建和管理多個網站。配置虛擬主機&#xff08;Vhost&#xff09;和域名綁定。自動安裝常用應用&#xff08;如WordPress、Joomla等&#xff09;。  文件管理功能&#xff1a; 文件上傳、…

jmeter:登录接口的token用于下一个接口

问题&#xff1a; 仅仅登录接口可以使用&#xff0c;其他接口进行测试的时候都是报错&#xff1a;账号已经失效 原因&#xff1a; 应该是登录接口的token并没有用到下一个接口上来 解决方法 1、目录建设如下&#xff1a; 2、先添加一个后置处理器&#xff1a;查看结果数&…

1、操作系统引论

一、操作系统 会使用linux系统 建议大家先学会linux的基础指令&#xff0c;可以看菜鸟教程网站进行学习。 1、各种定义 操作系统定义 管理计算机的 硬件 和软件资源&#xff0c; 能对各类作业进行调度&#xff0c;方便用户使用计算机的程序集合。操作系统运行在内核态&#xf…

SpringCloud系列教程(十四):Sentinel持久化

Sentinel之前已经搭建和应用成功了&#xff0c;但是它有一个很大的缺点就是官方没有提供持久化的方案&#xff0c;从项目源码上看感觉这款工具也没有完成的太好&#xff0c;所以需要我们去对它进行二次开发。要补充的功能大概如下&#xff1a; 1、将Sentinel接入nacos中&#…

Go语言环境搭建并执行第一个Go程序

目录 一、Windows环境搭建 二、vscode安装插件 三、运行第一个go程序 一、Windows环境搭建 下载Go&#xff1a;All releases - The Go Programming Language 这里是Windows搭建&#xff0c;选择的是windows-amd64.msi&#xff0c;也可以选择zip直接解压缩到指定目录 选择msi…

Java数据结构第二十三期:Map与Set的高效应用之道(二)

专栏&#xff1a;Java数据结构秘籍 个人主页&#xff1a;手握风云 目录 一、哈希表 1.1. 概念 1.2. 冲突 1.3. 避免冲突 1.4. 解决冲突 1.5. 实现 二、OJ练习 2.1. 只出现一次的数字 2.2. 随机链表的复制 2.3. 宝石与石头 一、哈希表 1.1. 概念 顺序结构以及平衡树中…

OpenHarmony子系统开发 - Rust编译构建指导

OpenHarmony子系统开发 - Rust编译构建指导 一、Rust模块配置规则和指导 概述 Rust是一门静态强类型语言&#xff0c;具有更安全的内存管理、更好的运行性能、原生支持多线程开发等优势。Rust官方也使用Cargo工具来专门为Rust代码创建工程和构建编译。 OpenHarmony为了集成C…

STM32驱动代码规范化编写指南(嵌入式C语言方向)

点击下面图片&#xff0c;为您提供全新的嵌入式学习路线 文章目录 一、命名规范体系1.1 变量/函数命名1.2 宏定义规范1.3 类型定义 二、代码结构组织2.1 文件组织结构2.2 头文件规范模板 三、注释体系构建3.1 Doxygen风格示例3.2 复杂逻辑注释 四、硬件抽象层设计4.1 寄存器封…

Trae与Builder模式初体验

说明 下载的国际版&#xff1a;https://www.trae.ai/ 建议 要选新模型 效果 还是挺不错的&#xff0c;遇到问题反馈一下&#xff0c;AI就帮忙解决了&#xff0c;真是动动嘴&#xff08;打打字就行了&#xff09;&#xff0c;做些小的原型效果或演示Demo很方便呀&#xff…

【设计模式】《设计模式:可复用面向对象软件的基础》:设计模式怎样解决设计问题?

文章目录 ⭐前言⭐一、设计模式怎样解决设计问题&#xff1f;&#x1f31f;1、寻找合适的对象&#x1f31f;2、决定对象的粒度&#x1f31f;3、指定对象接口&#x1f31f;4、描述对象的实现&#x1f31f;5、运用复用机制✨(1)针对接口编程&#xff0c;而不是针对实现编程。✨(2…

【项目管理git】git学习

ps&#xff1a;所有东西都是个人理解 文章目录 一、git是什么&#xff0c;它用来做什么&#xff1f;二、相关知识库2.1 简单的linux指令2.2 git配置指令2.3 git常见的指令2.3.1 Git的上传原理2.3.2 版本回退相关内容 2.4 设置远程地址&#xff0c;本地上传到github2.4.1 ssh相…

python速通小笔记-------1.容器

1.字符串的标识 字符串需要用“”标识。 与c不同&#xff0c;python 写变量时 不需要标明数据类型每一行最后不需要加&#xff1b; 2.print函数的使用 与c中的printf函数一致 3.运算符 4.字符串str操作 1. 实现字符串拼接 2.% 实现字符串初始化 %s占位会把变量强制转变为…

零基础上手Python数据分析 (2):Python核心语法快速入门

写在前面 场景:每周销售数据报表整理 任务描述: 你需要每周从多个Excel文件中汇总销售数据,计算各项指标(销售额、订单量、客单价等),并生成周报。Excel操作痛点: 文件太多,手动打开复制粘贴,效率低下,容易出错。 多个Excel文件,每个都要打开、筛选、复制数据,重复…

【PHP】获取PHP-FPM的状态信息

文章目录 一、前言二、环境三、过程1&#xff09;修改PHP-FPM配置文件2&#xff09;修改Nginx配置文件3&#xff09;访问页面4&#xff09;修改状态页面端口 一、前言 PHP-FPM内置有一个状态页面&#xff0c;通过这个页面可以获取到FPM的一些状态信息&#xff08;见下图&#…

搭建Spring Boot Admin监控系统

什么是Spring Boot Admin Spring Boot Admin 是一个用于管理和监控 Spring Boot 应用程序的开源工具。它提供了一个用户友好的 Web 界面&#xff0c;用于集中管理和监控多个 Spring Boot 应用程序的运行状态、健康状况、日志、配置等信息。 Spring Boot Admin 的核心功能 应用…